Searched refs:ssc (Results 1 - 25 of 66) sorted by relevance

123

/openjdk7/jdk/test/java/nio/channels/Selector/
H A DCloseThenRegister.java37 ServerSocketChannel ssc = ServerSocketChannel.open();
39 ssc.bind(new InetSocketAddress(0));
40 ssc.configureBlocking(false);
41 ssc.register(sel, SelectionKey.OP_ACCEPT);
46 ssc.close();
H A DSelectorLimit.java48 private ServerSocketChannel ssc; field in class:SelectorLimit.Listener
50 Listener(ServerSocketChannel ssc) { argument
52 this.ssc = ssc;
57 ssc.accept();
77 ServerSocketChannel ssc = ServerSocketChannel.open();
78 TestUtil.bind(ssc);
79 Listener lth = new Listener(ssc);
88 sc.connect(ssc.socket().getLocalSocketAddress());
H A DOpRead.java37 ServerSocketChannel ssc = null;
41 ssc = ServerSocketChannel.open().bind(new InetSocketAddress(0));
45 sc = SocketChannel.open(new InetSocketAddress(lh, ssc.socket().getLocalPort()));
46 peer = ssc.accept();
85 if (ssc != null) ssc.close();
H A DSelectAndCancel.java43 final ServerSocketChannel ssc =
46 new InetSocketAddress(InetAddress.getLocalHost(), ssc.socket().getLocalPort());
52 ssc.configureBlocking(false);
53 sk = ssc.register(selector, SelectionKey.OP_ACCEPT);
71 ssc.close();
H A DRegAfterPreClose.java83 ServerSocketChannel ssc = ServerSocketChannel.open();
84 ssc.socket().bind(isa);
88 ssc.configureBlocking(false);
89 SelectionKey key = ssc.register(sel, SelectionKey.OP_ACCEPT);
105 executor.execute(new Connector(ssc.socket().getLocalPort()));
112 SocketChannel sc = ssc.accept();
H A DBasicAccept.java39 static void server(ServerSocketChannel ssc) throws Exception { argument
42 ssc.configureBlocking(false);
44 = ssc.register(acceptSelector, SelectionKey.OP_ACCEPT);
70 final ServerSocketChannel ssc; field in class:BasicAccept.Server
73 this.ssc = ServerSocketChannel.open()
77 return ssc.socket().getLocalPort();
81 server(ssc);
83 ssc.close();
/openjdk7/jdk/test/java/nio/channels/ServerSocketChannel/
H A DSocketOptionTests.java39 static void checkOption(ServerSocketChannel ssc, SocketOption name, Object expectedValue) argument
42 Object value = ssc.getOption(name);
48 ServerSocketChannel ssc = ServerSocketChannel.open();
51 Set<SocketOption<?>> options = ssc.supportedOptions();
58 ssc.setOption(SO_RCVBUF, 256*1024); // can't check
59 int before = ssc.getOption(SO_RCVBUF);
60 int after = ssc.setOption(SO_RCVBUF, Integer.MAX_VALUE).getOption(SO_RCVBUF);
63 ssc.setOption(SO_REUSEADDR, true);
64 checkOption(ssc, SO_REUSEADDR, true);
65 ssc
[all...]
H A DOpen.java38 ServerSocketChannel ssc = ServerSocketChannel.open();
39 ssc.configureBlocking(false);
H A DNonBlockingAccept.java42 ServerSocketChannel ssc = ServerSocketChannel.open();
43 InetSocketAddress isa = TestUtil.bindToRandomPort(ssc);
44 ssc.configureBlocking(false);
45 ServerSocket ss = ssc.socket();
H A DBasic.java42 ServerSocketChannel ssc; field in class:Basic.Server
45 Server(ServerSocketChannel ssc, boolean block) { argument
47 this.ssc = ssc;
55 ssc.configureBlocking(false);
56 log.println(" " + ssc);
57 //log.println(" " + ssc.options());
60 sc = ssc.accept();
80 ssc.close();
126 ServerSocketChannel ssc
[all...]
/openjdk7/jdk/src/share/classes/sun/nio/ch/
H A DServerSocketAdaptor.java45 private final ServerSocketChannelImpl ssc; field in class:ServerSocketAdaptor
50 public static ServerSocket create(ServerSocketChannelImpl ssc) { argument
52 return new ServerSocketAdaptor(ssc);
59 private ServerSocketAdaptor(ServerSocketChannelImpl ssc) argument
62 this.ssc = ssc;
74 ssc.bind(local, backlog);
81 if (!ssc.isBound())
83 return Net.getRevealedLocalAddress(ssc.localAddress()).getAddress();
88 if (!ssc
[all...]
/openjdk7/jdk/src/share/sample/nio/server/
H A DN1.java55 ssc.configureBlocking(false);
60 d.register(ssc, SelectionKey.OP_ACCEPT,
61 new AcceptHandler(ssc, d, sslContext));
H A DAcceptor.java54 private ServerSocketChannel ssc; field in class:Acceptor
59 Acceptor(ServerSocketChannel ssc, Dispatcher d, SSLContext sslContext) { argument
60 this.ssc = ssc;
68 SocketChannel sc = ssc.accept();
H A DN2.java56 Acceptor a = new Acceptor(ssc, d, sslContext);
/openjdk7/jdk/test/java/nio/channels/SocketChannel/
H A DCloseAfterConnect.java35 ServerSocketChannel ssc = ServerSocketChannel.open();
36 ssc.socket().bind(new InetSocketAddress(0));
41 new InetSocketAddress(lh, ssc.socket().getLocalPort());
75 ssc.accept().close();
76 ssc.close();
H A DShutdown.java39 static void acceptAndReset(ServerSocketChannel ssc) throws IOException { argument
40 SocketChannel peer = ssc.accept();
51 ServerSocketChannel ssc = ServerSocketChannel.open()
55 int port = ((InetSocketAddress)(ssc.getLocalAddress())).getPort();
62 acceptAndReset(ssc);
72 acceptAndReset(ssc);
83 ssc.close();
H A DSocketInheritance.java98 ServerSocketChannel ssc = ServerSocketChannel.open();
99 ssc.socket().bind( new InetSocketAddress(0) );
101 int port = ssc.socket().getLocalPort();
104 SocketChannel sc2 = ssc.accept();
120 SocketChannel sc3 = ssc.accept();
126 ssc.close();
131 ssc = ServerSocketChannel.open();
132 ssc.socket().bind(new InetSocketAddress(port));
133 ssc.close();
H A DWrite.java90 final ServerSocketChannel ssc; field in class:WriteServer
94 this.ssc = ServerSocketChannel.open().bind(new InetSocketAddress(0));
98 return ssc.socket().getLocalPort();
112 ssc.configureBlocking(false);
115 sc = ssc.accept();
126 ssc.close();
H A DHangup.java79 ServerSocketChannel ssc = null;
93 ssc = ServerSocketChannel.open();
94 SocketAddress sa = TestUtil.bindToRandomPort(ssc);
96 + ssc.socket().getLocalPort());
104 sv = ssc.accept();
156 if (ssc != null)
157 ssc.close();
H A DUnboundSocketTests.java75 ServerSocketChannel ssc = ServerSocketChannel.open();
77 check("getLocalPort()", ssc.socket().getLocalPort(), -1);
78 check("getInetAddress()", ssc.socket().getInetAddress(), null);
79 check("getLocalSocketAddress()", ssc.socket().getLocalSocketAddress(), null);
81 ssc.close();
/openjdk7/jdk/test/java/nio/channels/spi/SelectorProvider/inheritedChannel/
H A DStateTest.java55 private static void waitForTestResult(ServerSocketChannel ssc, boolean expectFail) throws IOException { argument
56 Selector sel = ssc.provider().openSelector();
63 ssc.configureBlocking(false);
64 sk = ssc.register(sel, SelectionKey.OP_ACCEPT);
70 if (sk.isAcceptable() && ((sc = ssc.accept()) != null)) {
81 ssc.configureBlocking(false);
148 ServerSocketChannel ssc = ServerSocketChannel.open();
149 ssc.socket().bind(new InetSocketAddress(0));
154 int port = ssc.socket().getLocalPort();
162 waitForTestResult(ssc, expectFai
[all...]
H A DLauncher.java71 ServerSocketChannel ssc = ServerSocketChannel.open();
72 ssc.socket().bind(new InetSocketAddress(0));
74 ssc.socket().getLocalPort());
76 SocketChannel sc2 = ssc.accept();
79 ssc.close();
100 ServerSocketChannel ssc = ServerSocketChannel.open();
101 ssc.socket().bind(new InetSocketAddress(0));
102 int port = ssc.socket().getLocalPort();
103 launch(className, options, args, Util.getFD(ssc));
104 ssc
[all...]
/openjdk7/jdk/test/java/nio/channels/
H A DTestUtil.java45 // ServerSocketChannel ssc = ServerSocketChannel.open();
46 // ssc.socket().bind(new InetSocketAddress(0));
47 // SocketAddress sa = ssc.socket().getLocalSocketAddress();
53 static int bind(ServerSocketChannel ssc) throws IOException { argument
60 ssc.socket().bind(isa);
71 static InetSocketAddress bindToRandomPort(ServerSocketChannel ssc) argument
74 int p = bind(ssc);
/openjdk7/jdk/test/com/sun/nio/sctp/SctpServerChannel/
H A DAccept.java115 private SctpServerChannel ssc; field in class:Accept.AcceptServer
119 ssc = SctpServerChannel.open();
124 ssc.accept();
133 ssc.bind(null);
134 java.util.Set<SocketAddress> addrs = ssc.getAllLocalAddresses();
142 ssc.configureBlocking(false);
145 SctpChannel sc = ssc.accept();
150 ssc.configureBlocking(true);
165 return ssc;
178 sc = ssc
[all...]
/openjdk7/jdk/src/windows/classes/sun/nio/ch/
H A DPipeImpl.java80 ServerSocketChannel ssc = null;
90 ssc = ServerSocketChannel.open();
91 ssc.socket().bind(new InetSocketAddress(lb, 0));
96 = new InetSocketAddress(lb, ssc.socket().getLocalPort());
106 sc2 = ssc.accept();
131 if (ssc != null)
132 ssc.close();

Completed in 130 milliseconds

123