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

/openjdk7/jdk/test/java/nio/channels/SocketChannel/
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 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 DVectorIO.java106 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 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 DAcceptHandler.java59 AcceptHandler(ServerSocketChannel ssc, Dispatcher dsp, argument
61 channel = ssc;
H A DServer.java58 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 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 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/test/java/nio/channels/Selector/
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();
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 DSelectorTest.java137 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 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/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 DUtil.java68 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 DRequestDispatcherRegistry.java68 void registerServerRequestDispatcher( CorbaServerRequestDispatcher ssc, int scid) ; argument
77 void registerServerRequestDispatcher( CorbaServerRequestDispatcher ssc, String name ) ; argument
/openjdk7/jdk/test/java/nio/channels/AsynchronousSocketChannel/
H A DBasic.java71 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 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/corba/src/share/classes/com/sun/corba/se/impl/protocol/
H A DRequestDispatcherRegistryImpl.java95 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 DReceive.java220 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 DSend.java289 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 DShutdown.java178 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 DCommUp.java204 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 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...]
H A DNonBlockingAccept.java109 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 DsharedRuntime.cpp1269 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();

Completed in 285 milliseconds