/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();
|
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...] |
/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...] |
/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/mockftpserver/MockFtpServer/src/test/java/org/mockftpserver/core/socket/ |
StubServerSocketFactory.java | 19 import java.net.ServerSocket;
23 * ServerSocket instance specified on the constructor.
34 * ServerSocket instance.
35 * @param serverSocket - the ServerSocket instance to be returned by this factory
37 public StubServerSocketFactory(StubServerSocket serverSocket) {
38 this.stubServerSocket = serverSocket;
42 * Return the predefined ServerSocket instance.
45 public ServerSocket createServerSocket(int port) throws IOException {
|
/external/mockftpserver/branches/1.x_Branch/src/test/java/org/mockftpserver/core/socket/ |
StubServerSocketFactory.java | 19 import java.net.ServerSocket;
25 * ServerSocket instance specified on the constructor.
36 * ServerSocket instance.
37 * @param serverSocket - the ServerSocket instance to be returned by this factory
39 public StubServerSocketFactory(StubServerSocket serverSocket) {
40 this.stubServerSocket = serverSocket;
44 * Return the predefined ServerSocket instance.
47 public ServerSocket createServerSocket(int port) throws IOException {
|
/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/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/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...] |
/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...] |
/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...] |
/packages/apps/Nfc/tests/src/com/android/nfc/snep/ |
SnepBasicTests.java | 38 MockLlcpSocket serverSocket = new MockLlcpSocket(); 39 MockLlcpSocket.bind(clientSocket, serverSocket); 42 final SnepMessenger server = new SnepMessenger(false, serverSocket, MIU); 69 MockLlcpSocket serverSocket = new MockLlcpSocket(); 70 MockLlcpSocket.bind(clientSocket, serverSocket); 73 final SnepMessenger server = new SnepMessenger(false, serverSocket, MIU); 100 MockLlcpSocket serverSocket = new MockLlcpSocket(); 101 MockLlcpSocket.bind(clientSocket, serverSocket); 104 final SnepMessenger server = new SnepMessenger(false, serverSocket, MIU); 131 MockLlcpSocket serverSocket = new MockLlcpSocket() [all...] |
/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();
|
/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...] |
/libcore/luni/src/test/java/libcore/java/net/ |
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...] |
OldSocketTest.java | 30 import java.net.ServerSocket; 48 ServerSocket ss; 83 ServerSocket ss = null; 86 ss = new ServerSocket(0); 210 ServerSocket server = new ServerSocket(0); 594 ServerSocket serverSocket = new ServerSocket(0, 5, addr); 595 Socket theSocket = new Socket(addr, serverSocket.getLocalPort()) [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/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/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/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...] |
/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/conscrypt/testing/src/main/java/org/conscrypt/ |
ChannelType.java | 24 import java.net.ServerSocket; 47 ServerSocket newServerSocket(SSLServerSocketFactory factory) throws IOException { 52 SSLSocket accept(ServerSocket socket, SSLSocketFactory unused) throws IOException { 67 ServerSocket newServerSocket(SSLServerSocketFactory unused) throws IOException { 73 SSLSocket accept(ServerSocket serverSocket, SSLSocketFactory factory) throws IOException { 74 assertFalse(serverSocket instanceof SSLServerSocket); 75 Socket wrapped = serverSocket.accept(); 91 ServerSocket newServerSocket(SSLServerSocketFactory unused) throws IOException { 98 SSLSocket accept(ServerSocket serverSocket, SSLSocketFactory factory) throws IOException [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());
|