| /frameworks/base/packages/services/Proxy/src/com/android/proxyhandler/ |
| ProxyServer.java | 31 import java.net.ServerSocket;
59 private ServerSocket serverSocket;
331 serverSocket = new ServerSocket(0);
333 setPort(serverSocket.getLocalPort());
337 Socket socket = serverSocket.accept();
388 if (serverSocket != null) {
390 serverSocket.close();
391 serverSocket = null
[all...] |
| /external/caliper/caliper/src/test/java/com/google/caliper/runner/ |
| ServerSocketServiceTest.java | 72 OpenedSocket serverSocket = pendingServerConnection.get();
73 assertEndsConnected(clientSocket, serverSocket);
116 private void assertEndsConnected(OpenedSocket clientSocket, OpenedSocket serverSocket)
118 serverSocket.writer().write("hello client!");
119 serverSocket.writer().flush(); // necessary to prevent deadlock
124 assertEquals("hello server!", serverSocket.reader().read());
|
| /external/okhttp/mockwebserver/src/main/java/com/squareup/okhttp/mockwebserver/ |
| MockWebServer.java | 42 import java.net.ServerSocket;
121 private ServerSocket serverSocket;
351 serverSocket = serverSocketFactory.createServerSocket();
353 serverSocket.setReuseAddress(inetSocketAddress.getPort() != 0);
354 serverSocket.bind(inetSocketAddress, 50);
356 port = serverSocket.getLocalPort();
367 Util.closeQuietly(serverSocket);
383 socket = serverSocket.accept();
403 if (serverSocket == null) throw new IllegalStateException("shutdown() before start()")
[all...] |
| /external/okhttp/okio/okio/src/test/java/okio/ |
| SocketTimeoutTest.java | 22 import java.net.ServerSocket;
93 final ServerSocket serverSocket = new ServerSocket(0);
94 serverSocket.setReuseAddress(true);
95 serverSocket.setReceiveBufferSize(SOCKET_BUFFER_SIZE);
101 socket = serverSocket.accept();
117 Socket socket = new Socket(serverSocket.getInetAddress(), serverSocket.getLocalPort());
|
| /libcore/harmony-tests/src/test/java/org/apache/harmony/tests/javax/net/ssl/ |
| HandshakeCompletedEventTest.java | 202 private SSLServerSocket serverSocket;
410 serverSocket = (SSLServerSocket) sslContext.getServerSocketFactory().createServerSocket();
413 serverSocket.setWantClientAuth(true);
415 serverSocket.setNeedClientAuth(true);
417 serverSocket.setWantClientAuth(false);
420 serverSocket.bind(new InetSocketAddress(0));
425 SSLSocket clientSocket = (SSLSocket)serverSocket.accept();
446 serverSocket.close();
495 socket.connect(serverSocket.getLocalSocketAddress());
|
| SSLSocketTest.java | 542 SSLServerSocket serverSocket = (SSLServerSocket)
545 serverSocket.bind(new InetSocketAddress(0));
546 sport = serverSocket.getLocalPort();
549 SSLSocket clientSocket = (SSLSocket)serverSocket.accept();
568 serverSocket.close();
|
| /libcore/luni/src/test/java/libcore/java/net/ |
| SocketTimeoutTest.java | 26 import java.net.ServerSocket;
92 try (ServerSocket ss = new ServerSocket(0)) {
109 ServerSocket serverSocket = new ServerSocket(0)) {
115 serverSocket.setReceiveBufferSize(1);
116 int actualSize = sock.getSendBufferSize() + serverSocket.getReceiveBufferSize();
118 sock.connect(serverSocket.getLocalSocketAddress());
154 checkOperationTimesOut(() -> new ServerSocket(0)
[all...] |
| ServerSocketConcurrentCloseTest.java | 26 import java.net.ServerSocket;
36 * Tests for race conditions between {@link ServerSocket#close()} and
37 * {@link ServerSocket#accept()}.
43 * The implementation of {@link ServerSocket#accept()} checks closed state before
44 * delegating to the {@link ServerSocket#implAccept(Socket)}, however this is not
50 /** A ServerSocket that exposes implAccept() */
51 class ExposedServerSocket extends ServerSocket {
60 final ExposedServerSocket serverSocket = new ExposedServerSocket();
61 serverSocket.close();
65 Thread thread = new Thread("implAccept() closed ServerSocket") {
[all...] |
| FtpURLConnectionTest.java | 34 import java.net.ServerSocket;
356 * Counts the number of attempts to connect to a ServerSocket exposed
372 Socket socket = serverSocket.accept();
387 private final ServerSocket serverSocket;
395 serverSocket = new ServerSocket(0 /* allocate port number automatically */);
396 SocketAddress socketAddress = serverSocket.getLocalSocketAddress();
416 * Returns the HTTP {@link Proxy} that can represents the ServerSocket
424 * Causes the ServerSocket represented by {@link #asProxy()} to stop acceptin
[all...] |
| /libcore/ojluni/src/main/java/java/net/ |
| SocketImpl.java | 50 ServerSocket serverSocket = null;
299 void setServerSocket(ServerSocket soc) {
300 this.serverSocket = soc;
303 ServerSocket getServerSocket() {
304 return serverSocket;
|
| AbstractPlainSocketImpl.java | 132 if (serverSocket != null)
133 serverSocket.setCreated();
430 if (serverSocket != null)
431 serverSocket.setBound();
|
| /libcore/ojluni/src/main/java/sun/net/ |
| NetworkClient.java | 51 protected Socket serverSocket = null;
134 if (serverSocket != null)
136 serverSocket = doConnect (server, port);
139 serverSocket.getOutputStream()),
144 serverInput = new BufferedInputStream(serverSocket.getInputStream());
201 if (serverSocket == null)
206 return serverSocket.getLocalAddress();
217 serverSocket.close();
218 serverSocket = null;
225 return serverSocket != null
[all...] |
| /cts/hostsidetests/devicepolicy/app/DeviceOwner/src/com/android/cts/deviceowner/ |
| NetworkLoggingTest.java | 37 import java.net.ServerSocket;
282 final ServerSocket serverSocket = new ServerSocket(0);
283 final Thread serverThread = startDummyServer(serverSocket);
285 final int reqNo = makeDummyRequests(serverSocket.getLocalPort());
287 serverSocket.close();
308 private Thread startDummyServer(ServerSocket serverSocket) throws InterruptedException {
310 while (!serverSocket.isClosed())
[all...] |
| /cts/tests/tests/networksecurityconfig/networksecurityconfig-downloadmanager/src/android/security/net/config/cts/ |
| DownloadManagerTest.java | 36 import java.net.ServerSocket;
69 SSLServerSocket serverSocket = bindTLSServer(R.raw.valid_chain, R.raw.test_key);
70 runDownloadManagerTest(serverSocket, true);
75 SSLServerSocket serverSocket = bindTLSServer(R.raw.invalid_chain, R.raw.test_key);
76 runDownloadManagerTest(serverSocket, true);
83 ServerSocket serverSocket = new ServerSocket();
84 serverSocket.bind(null);
85 runDownloadManagerTest(serverSocket, false)
[all...] |
| /external/mockftpserver/MockFtpServer/src/main/java/org/mockftpserver/core/server/ |
| AbstractFtpServer.java | 90 private ServerSocket serverSocket = null;
140 serverSocket = serverSocketFactory.createServerSocket(serverControlPort);
142 this.serverControlPort = serverSocket.getLocalPort();
153 Socket clientSocket = serverSocket.accept();
183 if (serverSocket != null) {
184 serverSocket.close();
207 if (serverSocket != null) {
209 serverSocket.close();
294 * @param serverControlPort - the port number for the server control connection ServerSocket
[all...] |
| /libcore/luni/src/test/java/org/apache/harmony/luni/tests/internal/net/www/protocol/http/ |
| HttpURLConnectionTest.java | 27 import java.net.ServerSocket;
47 ServerSocket serverSocket;
53 serverSocket = new ServerSocket(0);
54 serverSocket.setSoTimeout(1000);
58 return serverSocket.getLocalPort();
69 serverSocket.accept().close();
73 serverSocket.close();
91 Socket socket = serverSocket.accept()
[all...] |
| /libcore/support/src/test/java/libcore/javax/net/ssl/ |
| TestSSLContext.java | 98 public final SSLServerSocket serverSocket;
213 SSLServerSocket serverSocket,
226 this.serverSocket = serverSocket;
233 serverSocket.close();
292 SSLServerSocket serverSocket = (SSLServerSocket)
295 int port = serverSocket.getLocalPort();
304 serverSocket, host, port);
|
| /libcore/support/src/test/java/tests/http/ |
| MockWebServer.java | 30 import java.net.ServerSocket;
75 private ServerSocket serverSocket;
178 serverSocket = new ServerSocket(port);
179 serverSocket.setReuseAddress(true);
181 this.port = serverSocket.getLocalPort();
195 serverSocket.close();
218 socket = serverSocket.accept();
236 if (serverSocket != null)
[all...] |
| /cts/tests/tests/net/src/android/net/cts/ |
| IpSecBaseTest.java | 38 import java.net.ServerSocket;
377 ServerSocket serverSocket = new ServerSocket();
378 serverSocket.bind(new InetSocketAddress(localAddr, 0));
387 FileDescriptor serverFd = serverSocket.getImpl().getFD$();
392 clientSock.mSocket.connect(new InetSocketAddress(localAddr, serverSocket.getLocalPort()));
393 JavaTcpSocket acceptedSock = new JavaTcpSocket(serverSocket.accept());
396 serverSocket.close();
|
| /libcore/harmony-tests/src/test/java/org/apache/harmony/tests/java/net/ |
| ServerSocketTest.java | 35 import java.net.ServerSocket;
56 ServerSocket s;
95 * java.net.ServerSocket#ServerSocket()
98 // Test for method java.net.ServerSocket(int)
103 * java.net.ServerSocket#ServerSocket(int)
106 // Test for method java.net.ServerSocket(int)
111 * java.net.ServerSocket#ServerSocket(int
[all...] |
| /cts/apps/CtsVerifier/src/com/android/cts/verifier/sensors/helpers/ |
| PowerTestHostLink.java | 109 LocalServerSocket serverSocket = createSocket();
110 if (null == serverSocket) {
121 receiverSocket = serverSocket.accept();
183 if (serverSocket != null) {
185 serverSocket.close();
|
| /external/mockwebserver/src/main/java/com/google/mockwebserver/ |
| MockWebServer.java | 31 import java.net.ServerSocket;
88 private ServerSocket serverSocket;
220 serverSocket = new ServerSocket(port);
221 serverSocket.setReuseAddress(true);
223 this.port = serverSocket.getLocalPort();
237 serverSocket.close();
265 socket = serverSocket.accept();
283 if (serverSocket != null)
[all...] |
| /packages/apps/Nfc/src/com/android/nfc/echoserver/ |
| EchoServer.java | 172 LlcpServerSocket serverSocket;
207 serverSocket = mService.createLlcpServerSocket(DEFAULT_CO_SAP,
212 if (serverSocket == null) {
222 clientSocket = serverSocket.accept();
244 serverSocket.close();
248 serverSocket = null;
265 if (serverSocket != null) {
267 serverSocket.close();
271 serverSocket = null;
|
| /external/antlr/antlr-3.4/runtime/C/src/ |
| antlr3debughandlers.c | 199 SOCKET serverSocket;
251 serverSocket = socket(AF_INET, SOCK_STREAM, 0);
253 if (serverSocket == INVALID_SOCKET)
269 if (bind(serverSocket, (pANTLR3_SOCKADDRC)&server, sizeof(server)) == -1)
277 if (listen(serverSocket, 1) == -1)
287 delboy->socket = accept(serverSocket, (pANTLR3_SOCKADDRC)&client, &sockaddr_len);
291 shutdown (serverSocket, 0x02);
292 ANTLR3_CLOSESOCKET (serverSocket);
|
| /external/antlr/antlr-3.4/runtime/CSharp2/Sources/Antlr3.Runtime/Antlr.Runtime.Debug/ |
| DebugEventSocketProxy.cs | 56 protected TcpListener serverSocket;
95 if (serverSocket == null) {
98 serverSocket = new TcpListener(ipAddress, port);
99 socket = serverSocket.AcceptSocket();
107 //serverSocket = new ServerSocket( port );
108 //socket = serverSocket.accept();
|
