/openjdk7/jdk/test/java/nio/channels/SocketChannel/ |
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 | 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 | VectorIO.java | 106 final ServerSocketChannel ssc; field in class:VectorIO.Server 111 this.ssc = ServerSocketChannel.open().bind(new InetSocketAddress(0)); 115 return ssc.socket().getLocalPort(); 139 ssc.configureBlocking(false); 142 sc = ssc.accept(); 181 ssc.close();
|
/openjdk7/jdk/src/share/sample/nio/server/ |
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 | AcceptHandler.java | 59 AcceptHandler(ServerSocketChannel ssc, Dispatcher dsp, argument 61 channel = ssc;
|
H A D | Server.java | 58 ServerSocketChannel ssc; field in class:Server 72 ssc = ServerSocketChannel.open(); 73 ssc.socket().setReuseAddress(true); 74 ssc.socket().bind(new InetSocketAddress(port), backlog);
|
/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 | 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/test/java/nio/channels/Selector/ |
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();
|
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 | SelectorTest.java | 137 private final ServerSocketChannel ssc; field in class:SelectorTest.Server 148 this.ssc = ServerSocketChannel.open().bind(new InetSocketAddress(port)); 152 return ssc.socket().getLocalPort(); 167 ssc.configureBlocking(false); 168 SelectionKey acceptKey = ssc.register(acceptSelector,
|
/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/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 | Util.java | 68 public static int getFD(ServerSocketChannel ssc) { argument 70 Object fdObj = get("sun.nio.ch.ServerSocketChannelImpl", "fd", ssc);
|
/openjdk7/corba/src/share/classes/com/sun/corba/se/spi/protocol/ |
H A D | RequestDispatcherRegistry.java | 68 void registerServerRequestDispatcher( CorbaServerRequestDispatcher ssc, int scid) ; argument 77 void registerServerRequestDispatcher( CorbaServerRequestDispatcher ssc, String name ) ; argument
|
/openjdk7/jdk/test/java/nio/channels/AsynchronousSocketChannel/ |
H A D | Basic.java | 71 private final ServerSocketChannel ssc; field in class:Basic.Server 75 ssc = ServerSocketChannel.open().bind(new InetSocketAddress(0)); 78 int port = ((InetSocketAddress)(ssc.getLocalAddress())).getPort(); 87 return ssc.accept(); 91 ssc.close();
|
/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/corba/src/share/classes/com/sun/corba/se/impl/protocol/ |
H A D | RequestDispatcherRegistryImpl.java | 95 CorbaServerRequestDispatcher ssc, int scid) 97 SDRegistry.set( scid, ssc ) ; 94 registerServerRequestDispatcher( CorbaServerRequestDispatcher ssc, int scid) argument
|
/openjdk7/jdk/test/com/sun/nio/sctp/SctpChannel/ |
H A D | Receive.java | 220 private SctpServerChannel ssc; field in class:Receive.Server 223 ssc = SctpServerChannel.open().bind(null); 224 java.util.Set<SocketAddress> addrs = ssc.getAllLocalAddresses(); 242 SctpChannel sc = ssc.accept(); 269 sc = ssc.accept(); 270 ssc.close();
|
H A D | Send.java | 289 private SctpServerChannel ssc; field in class:Send.Server 292 ssc = SctpServerChannel.open().bind(null); 293 java.util.Set<SocketAddress> addrs = ssc.getAllLocalAddresses(); 313 sc1 = ssc.accept(); 356 sc2 = ssc.accept(); 389 try { if (ssc != null) ssc.close(); }
|
H A D | Shutdown.java | 178 private SctpServerChannel ssc; field in class:Shutdown.ShutdownServer 181 ssc = SctpServerChannel.open().bind(null); 182 //serverAddr = (InetSocketAddress)(ssc.getAllLocalAddresses().iterator().next()); 184 java.util.Set<SocketAddress> addrs = ssc.getAllLocalAddresses(); 204 sc = ssc.accept(); 232 try { if (ssc != null) ssc.close(); }
|
H A D | CommUp.java | 204 private SctpServerChannel ssc; field in class:CommUp.CommUpServer 208 ssc = SctpServerChannel.open().bind(null); 209 java.util.Set<SocketAddress> addrs = ssc.getAllLocalAddresses(); 236 sc = ssc.accept(); 286 try { if (ssc != null) ssc.close(); }
|
/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...] |
H A D | NonBlockingAccept.java | 109 private SctpServerChannel ssc; field in class:NonBlockingAccept.NonblockingServer 113 ssc = SctpServerChannel.open().bind(null); 114 java.util.Set<SocketAddress> addrs = ssc.getAllLocalAddresses(); 138 ssc.configureBlocking(false); 139 check(ssc.isBlocking() == false, "Should be in non-blocking mode"); 140 acceptKey = ssc.register(acceptSelector, SelectionKey.OP_ACCEPT); 153 check(nextReady.equals(ssc), 182 try { if (ssc != null) ssc.close(); }
|
/openjdk7/hotspot/src/share/vm/runtime/ |
H A D | sharedRuntime.cpp | 1269 CompiledStaticCall* ssc = compiledStaticCall_before(caller_frame.pc()); local 1270 if (ssc->is_clean()) ssc->set(static_call_info); 1606 CompiledStaticCall* ssc= compiledStaticCall_at(call_addr); local 1607 ssc->set_to_clean();
|