/openjdk7/jdk/test/java/nio/channels/Selector/ |
H A D | CloseThenRegister.java | 37 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 D | SelectorLimit.java | 48 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 D | OpRead.java | 37 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 D | SelectAndCancel.java | 43 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 D | RegAfterPreClose.java | 83 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 D | BasicAccept.java | 39 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 D | SocketOptionTests.java | 39 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 D | Open.java | 38 ServerSocketChannel ssc = ServerSocketChannel.open(); 39 ssc.configureBlocking(false);
|
H A D | NonBlockingAccept.java | 42 ServerSocketChannel ssc = ServerSocketChannel.open(); 43 InetSocketAddress isa = TestUtil.bindToRandomPort(ssc); 44 ssc.configureBlocking(false); 45 ServerSocket ss = ssc.socket();
|
H A D | Basic.java | 42 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 D | ServerSocketAdaptor.java | 45 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 D | N1.java | 55 ssc.configureBlocking(false); 60 d.register(ssc, SelectionKey.OP_ACCEPT, 61 new AcceptHandler(ssc, d, sslContext));
|
H A D | Acceptor.java | 54 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 D | N2.java | 56 Acceptor a = new Acceptor(ssc, d, sslContext);
|
/openjdk7/jdk/test/java/nio/channels/SocketChannel/ |
H A D | CloseAfterConnect.java | 35 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 D | Shutdown.java | 39 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 D | SocketInheritance.java | 98 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 D | Write.java | 90 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 D | Hangup.java | 79 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 D | UnboundSocketTests.java | 75 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 D | StateTest.java | 55 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 D | Launcher.java | 71 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 D | TestUtil.java | 45 // 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 D | Accept.java | 115 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 D | PipeImpl.java | 80 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();
|