| /external/vogar/src/vogar/monitor/ |
| TargetMonitor.java | 23 import java.net.ServerSocket;
50 final ServerSocket serverSocket = new ServerSocket(port);
51 serverSocket.setSoTimeout(ACCEPT_TIMEOUT_MILLIS);
52 serverSocket.setReuseAddress(true);
53 final Socket socket = serverSocket.accept();
57 serverSocket.close();
|
| /libcore/harmony-tests/src/test/java/org/apache/harmony/tests/java/net/ |
| TestServerSocketInit.java | 21 import java.net.ServerSocket;
26 ServerSocket serverSocket = new ServerSocket();
27 serverSocket.setReuseAddress(true);
28 serverSocket.close();
|
| /cts/tests/tests/net/src/android/net/cts/ |
| LocalServerSocketTest.java | 39 LocalSocket serverSocket = localServerSocket.accept();
41 assertTrue(serverSocket.isConnected());
42 assertTrue(serverSocket.isBound());
47 InputStream serverInStream = serverSocket.getInputStream();
51 OutputStream serverOutStream = serverSocket.getOutputStream();
|
| LocalSocketTest.java | 54 LocalSocket serverSocket = localServerSocket.accept();
55 assertTrue(serverSocket.isConnected());
56 assertTrue(serverSocket.isBound());
58 serverSocket.bind(localServerSocket.getLocalSocketAddress());
63 serverSocket.connect(locSockAddr);
74 InputStream serverInStream = serverSocket.getInputStream();
78 OutputStream serverOutStream = serverSocket.getOutputStream();
88 FileDescriptor[] out = serverSocket.getAncillaryFileDescriptors();
107 serverSocket.shutdownInput();
111 serverSocket.shutdownOutput()
[all...] |
| /external/antlr/antlr-3.4/runtime/ObjC/ANTLR.framework/Headers/ |
| ANTLRDebugEventProxy.h | 39 int serverSocket;
57 - (NSInteger) serverSocket;
|
| /external/antlr/antlr-3.4/runtime/ObjC/ANTLR.framework/Versions/A/Headers/ |
| ANTLRDebugEventProxy.h | 39 int serverSocket;
57 - (NSInteger) serverSocket;
|
| /external/antlr/antlr-3.4/runtime/ObjC/ANTLR.framework/Versions/Current/Headers/ |
| ANTLRDebugEventProxy.h | 39 int serverSocket;
57 - (NSInteger) serverSocket;
|
| /external/antlr/antlr-3.4/runtime/ObjC/Framework/ |
| ANTLRDebugEventProxy.h | 39 int serverSocket;
57 - (NSInteger) serverSocket;
|
| /external/jacoco/org.jacoco.agent.rt.test/src/org/jacoco/agent/rt/internal/output/ |
| MockServerSocketTest.java | 20 import java.net.ServerSocket;
36 private ServerSocket serverSocket;
52 serverSocket = new ServerSocket(16300, 1, addr);
54 serverSocket = new MockServerSocket();
61 serverSocket.close();
70 return ((MockServerSocket) serverSocket).connect();
77 assertFalse(serverSocket.isClosed());
78 serverSocket.close()
[all...] |
| TcpServerOutputTest.java | 22 import java.net.ServerSocket;
48 private MockServerSocket serverSocket;
58 serverSocket = new MockServerSocket();
61 protected ServerSocket createServerSocket(AgentOptions options)
63 return serverSocket;
72 serverSocket.waitForAccept();
79 serverSocket.waitForAccept();
80 new ExecutionDataWriter(serverSocket.connect().getOutputStream());
90 final Socket socket = serverSocket.connect();
121 final Socket socket = serverSocket.connect()
[all...] |
| /external/okhttp/okhttp-tests/src/test/java/com/squareup/okhttp/ |
| DelegatingServerSocketFactory.java | 20 import java.net.ServerSocket;
25 * overriding {@link #configureServerSocket(java.net.ServerSocket)}.
36 public ServerSocket createServerSocket() throws IOException {
37 ServerSocket serverSocket = delegate.createServerSocket();
38 return configureServerSocket(serverSocket);
42 public ServerSocket createServerSocket(int port) throws IOException {
43 ServerSocket serverSocket = delegate.createServerSocket(port);
44 return configureServerSocket(serverSocket);
[all...] |
| SocksProxy.java | 25 import java.net.ServerSocket;
59 private ServerSocket serverSocket;
63 serverSocket = new ServerSocket(0);
64 executor.execute(new NamedRunnable("SocksProxy %s", serverSocket.getLocalPort()) {
68 Socket socket = serverSocket.accept();
83 "localhost", serverSocket.getLocalPort()));
91 serverSocket.close();
|
| /external/jacoco/org.jacoco.cli.test/src/org/jacoco/cli/internal/commands/ |
| DumpTest.java | 20 import java.net.ServerSocket;
40 private ServerSocket serverSocket;
44 if (serverSocket != null) {
45 serverSocket.close();
93 serverSocket = new ServerSocket(0, 0, InetAddress.getByName(null));
98 serveRequest(serverSocket.accept());
104 return serverSocket.getLocalPort();
124 final ServerSocket serverSocket = new ServerSocket(0, 0
[all...] |
| /libcore/luni/src/test/java/libcore/javax/net/ |
| ServerSocketFactoryTest.java | 24 import java.net.ServerSocket;
35 ServerSocket serverSocket = ServerSocketFactory.getDefault().createServerSocket();
36 serverSocket.bind(new InetSocketAddress(0));
37 testSocket(serverSocket, 50);
41 ServerSocket serverSocket = ServerSocketFactory.getDefault().createServerSocket(0);
42 testSocket(serverSocket, 50);
50 ServerSocket serverSocket = ServerSocketFactory.getDefault().createServerSocket(0, 1)
[all...] |
| /external/jacoco/org.jacoco.agent.rt/src/org/jacoco/agent/rt/internal/output/ |
| TcpServerOutput.java | 16 import java.net.ServerSocket;
37 private ServerSocket serverSocket;
53 serverSocket = createServerSocket(options);
56 while (!serverSocket.isClosed()) {
58 synchronized (serverSocket) {
60 serverSocket.accept(), data);
65 // If the serverSocket is closed while accepting
67 if (!serverSocket.isClosed()) {
80 serverSocket.close()
[all...] |
| /external/testng/src/main/java/org/testng/remote/adapter/ |
| DefaultWorkerAdapter.java | 4 import java.net.ServerSocket;
76 ServerSocket serverSocket = new ServerSocket(clientPort);
77 serverSocket.setReuseAddress(true);
79 Socket socket = serverSocket.accept();
|
| /external/apache-harmony/jdwp/src/test/java/org/apache/harmony/jpda/tests/framework/jdwp/ |
| SocketTransportWrapper.java | 30 import java.net.ServerSocket;
48 private ServerSocket serverSocket;
85 serverSocket = new ServerSocket(port, 0, hostAddr);
87 serverSocket = new ServerSocket(port);
93 iAddress = serverSocket.getInetAddress();
102 address = hostNameOrAddress + ":" + serverSocket.getLocalPort();
111 if (serverSocket != null)
[all...] |
| /external/apache-harmony/jdwp/src/test/java/org/apache/harmony/jpda/tests/share/ |
| JPDADebuggeeSynchronizer.java | 35 import java.net.ServerSocket;
55 protected ServerSocket serverSocket = null;
201 serverSocket = new ServerSocket(serverAddress.getPort(), 0, serverAddress.getAddress());
202 int localPort = serverSocket.getLocalPort();
218 serverSocket.setSoTimeout((int) timeout);
220 clientSocket = serverSocket.accept();
264 if (serverSocket != null)
265 serverSocket.close()
[all...] |
| /external/conscrypt/testing/src/main/java/org/conscrypt/javax/net/ssl/ |
| TestSSLContext.java | 83 public final SSLServerSocket serverSocket;
175 SSLContext serverContext, SSLServerSocket serverSocket, InetAddress host, int port) {
186 this.serverSocket = serverSocket;
192 serverSocket.close();
321 SSLServerSocket serverSocket =
326 serverSocket.setReceiveBufferSize(serverReceiveBufferSize);
329 serverSocket.bind(new InetSocketAddress(host, 0));
330 int port = serverSocket.getLocalPort();
336 serverSocket, host, port)
[all...] |
| /developers/samples/android/connectivity/wifidirect/DirectP2P/Application/src/main/java/com/example/android/wifidirectp2p/ |
| DeviceDetailFragment.java | 45 import java.net.ServerSocket;
228 ServerSocket serverSocket = new ServerSocket(8988);
230 Socket client = serverSocket.accept();
244 serverSocket.close();
|
| /development/samples/WiFiDirectDemo/src/com/example/android/wifidirect/ |
| DeviceDetailFragment.java | 46 import java.net.ServerSocket;
227 ServerSocket serverSocket = new ServerSocket(8988);
229 Socket client = serverSocket.accept();
243 serverSocket.close();
|
| /external/caliper/caliper/src/main/java/com/google/caliper/runner/ |
| ServerSocketService.java | 32 import java.net.ServerSocket;
47 * A {@link Service} that manages a {@link ServerSocket}.
51 * <li>It adapts {@link ServerSocket#accept()} to a {@link ListenableFuture} of an opened socket.
58 * <li>{@linkplain State#NEW NEW} : Idle state, the {@link ServerSocket} is not open yet.
59 * <li>{@linkplain State#STARTING STARTING} : {@link ServerSocket} is opened
115 private ServerSocket serverSocket;
121 checkState(serverSocket != null, "Socket has not been opened yet");
122 return serverSocket.getLocalPort();
138 serverSocket = new ServerSocket(0 /* bind to any available port */)
[all...] |
| /external/caliper/caliper/src/test/java/com/google/caliper/runner/ |
| StreamServiceTest.java | 48 import java.net.ServerSocket;
64 private ServerSocket serverSocket;
78 serverSocket = new ServerSocket(0);
82 serverSocket.close();
127 int localport = serverSocket.getLocalPort();
144 int localport = serverSocket.getLocalPort();
162 serverSocket.close(); // This will force serverSocket.accept to throw a SocketExceptio
[all...] |
| /external/conscrypt/benchmark-base/src/main/java/org/conscrypt/ |
| ServerEndpoint.java | 23 import java.net.ServerSocket;
63 private final ServerSocket serverSocket;
81 this.serverSocket = channelType.newServerSocket(serverSocketFactory);
112 serverSocket.close();
125 return serverSocket.getLocalPort();
135 socket = channelType.accept(serverSocket, socketFactory);
|
| /external/mockftpserver/branches/1.x_Branch/src/main/java/org/mockftpserver/stub/ |
| StubFtpServer.java | 19 import java.net.ServerSocket;
147 private ServerSocket serverSocket = null;
236 serverSocket = serverSocketFactory.createServerSocket(serverControlPort);
243 serverSocket.setSoTimeout(500);
246 Socket clientSocket = serverSocket.accept();
271 if (serverSocket != null) {
272 serverSocket.close();
371 * @param serverControlPort - the port number for the server control connection ServerSocket
387 boolean shutdown = !serverThread.isAlive() && serverSocket.isClosed();
[all...] |
