| /cts/tests/tests/net/src/android/net/cts/ |
| LocalSocketTest.java | 46 LocalSocket clientSocket = new LocalSocket();
50 assertFalse(clientSocket.isConnected());
51 clientSocket.connect(locSockAddr);
52 assertTrue(clientSocket.isConnected());
68 Credentials credent = clientSocket.getPeerCredentials();
72 OutputStream clientOutStream = clientSocket.getOutputStream();
80 InputStream clientInStream = clientSocket.getInputStream();
84 clientSocket.setFileDescriptorsForSend(new FileDescriptor[]{FileDescriptor.in});
90 FileDescriptor fd = clientSocket.getFileDescriptor();
94 clientSocket.shutdownInput()
[all...] |
| LocalServerSocketTest.java | 35 LocalSocket clientSocket = new LocalSocket();
38 clientSocket.connect(new LocalSocketAddress(address));
45 OutputStream clientOutStream = clientSocket.getOutputStream();
53 InputStream clientInStream = clientSocket.getInputStream();
|
| /system/chre/host/common/ |
| socket_server.cc | 93 int clientSocket = pair.first;
94 if (close(clientSocket) != 0) {
110 int clientSocket = pair.first;
112 if (sendToClientSocket(data, length, clientSocket, clientId)) {
134 int clientSocket = pair.first;
135 sent = sendToClientSocket(data, length, clientSocket, thisClientId);
144 int clientSocket = accept(mSockFd, NULL, NULL);
145 if (clientSocket < 0) {
149 close(clientSocket);
166 mPollFds[i].fd = clientSocket;
[all...] |
| /external/apache-harmony/jdwp/src/test/java/org/apache/harmony/jpda/tests/share/ |
| JPDADebuggeeSynchronizer.java | 53 protected Socket clientSocket = null;
220 clientSocket = serverSocket.accept();
223 clientSocket.setSoTimeout((int) timeout);
224 out = new DataOutputStream(clientSocket.getOutputStream());
225 in = new DataInputStream(clientSocket.getInputStream());
240 clientSocket = new Socket(serverAddress.getAddress(), serverAddress.getPort());
243 clientSocket.setSoTimeout((int) timeout);
244 out = new DataOutputStream(clientSocket.getOutputStream());
245 in = new DataInputStream(clientSocket.getInputStream());
262 if (clientSocket != null
[all...] |
| /external/caliper/caliper/src/test/java/com/google/caliper/runner/ |
| ServerSocketServiceTest.java | 61 OpenedSocket clientSocket = openConnectionAndIdentify(id);
63 assertEndsConnected(clientSocket, pendingServerConnection.get());
68 OpenedSocket clientSocket = openConnectionAndIdentify(id);
73 assertEndsConnected(clientSocket, serverSocket);
109 OpenedSocket clientSocket = openClientConnection();
110 OpenedSocket.Writer writer = clientSocket.writer();
113 return clientSocket;
116 private void assertEndsConnected(OpenedSocket clientSocket, OpenedSocket serverSocket)
120 assertEquals("hello client!", clientSocket.reader().read());
122 clientSocket.writer().write("hello server!")
[all...] |
| /packages/apps/Nfc/tests/src/com/android/nfc/snep/ |
| SnepBasicTests.java | 37 MockLlcpSocket clientSocket = new MockLlcpSocket();
39 MockLlcpSocket.bind(clientSocket, serverSocket);
41 final SnepMessenger client = new SnepMessenger(true, clientSocket, MIU);
68 MockLlcpSocket clientSocket = new MockLlcpSocket();
70 MockLlcpSocket.bind(clientSocket, serverSocket);
72 final SnepMessenger client = new SnepMessenger(true, clientSocket, MIU);
99 MockLlcpSocket clientSocket = new MockLlcpSocket();
101 MockLlcpSocket.bind(clientSocket, serverSocket);
103 final SnepMessenger client = new SnepMessenger(true, clientSocket, MIU);
130 MockLlcpSocket clientSocket = new MockLlcpSocket()
[all...] |
| /packages/apps/Nfc/nci/jni/ |
| NativeLlcpServiceSocket.cpp | 51 jobject clientSocket = NULL;
72 &(clientSocket)) == -1) {
78 clsNativeLlcpSocket = e->GetObjectClass(clientSocket);
87 e->SetIntField(clientSocket, f, (jint)connHandle);
91 e->SetIntField(clientSocket, f, (jint)miu);
95 e->SetIntField(clientSocket, f, (jint)rw);
99 return clientSocket;
|
| /external/deqp/framework/delibs/decpp/ |
| deSocket.cpp | 134 deSocket* clientSocket = deSocket_accept(m_socket, clientAddress);
135 if (!clientSocket)
140 return new Socket(clientSocket);
144 deSocket_destroy(clientSocket);
|
| /system/chre/host/common/include/chre_host/ |
| socket_server.h | 114 void disconnectClient(int clientSocket);
115 void handleClientData(int clientSocket);
116 bool sendToClientSocket(const void *data, size_t length, int clientSocket,
|
| /external/deqp/execserver/ |
| xsTcpServer.cpp | 48 de::Socket* clientSocket = DE_NULL;
51 while ((clientSocket = m_socket.accept(clientAddr)) != DE_NULL)
57 handler = createHandler(clientSocket, clientAddr);
61 delete clientSocket;
|
| /external/swiftshader/src/Main/ |
| SwiftConfig.hpp | 91 void respond(Socket *clientSocket, const char *request);
94 void send(Socket *clientSocket, Status code, std::string body = "");
|
| SwiftConfig.cpp | 134 Socket *clientSocket = listenSocket->accept();
139 if(clientSocket->select(10))
141 bytesReceived = clientSocket->receive(receiveBuffer, bufferLength);
147 respond(clientSocket, receiveBuffer);
152 delete clientSocket;
171 void SwiftConfig::respond(Socket *clientSocket, const char *request)
179 return send(clientSocket, OK, page());
200 int bytesReceived = clientSocket->receive(receiveBuffer, bufferLength);
219 return send(clientSocket, OK, page());
223 return send(clientSocket, OK, profile())
[all...] |
| /packages/apps/Nfc/src/com/android/nfc/echoserver/ |
| EchoServer.java | 173 LlcpSocket clientSocket;
222 clientSocket = serverSocket.accept();
223 if (DBG) Log.d(TAG, "accept returned " + clientSocket);
224 handleClient(clientSocket);
237 clientSocket.close();
241 clientSocket = null;
253 if (clientSocket != null) {
255 clientSocket.send(data);
|
| /external/mockftpserver/MockFtpServer/src/main/java/org/mockftpserver/core/server/ |
| AbstractFtpServer.java | 153 Socket clientSocket = serverSocket.accept();
154 LOG.info("Connection accepted from host " + clientSocket.getInetAddress());
156 Session session = createSession(clientSocket);
161 sessionInfo.socket = clientSocket;
342 * @param clientSocket - the Socket associated with the client
345 protected Session createSession(Socket clientSocket) {
346 return new DefaultSession(clientSocket, commandHandlers);
|
| /system/netd/tests/ |
| binder_test.cpp | 120 static void fakeRemoteSocketPair(int *clientSocket, int *serverSocket, int *acceptedSocket);
540 void BinderTest::fakeRemoteSocketPair(int *clientSocket, int *serverSocket, int *acceptedSocket) {
549 *clientSocket = socket(AF_INET6, SOCK_STREAM, 0);
551 ASSERT_EQ(0, bind(*clientSocket, (struct sockaddr *) &client6, sizeof(client6)));
552 ASSERT_EQ(0, connect(*clientSocket, (struct sockaddr *) &server6, sizeof(server6)));
553 ASSERT_EQ(0, getsockname(*clientSocket, (struct sockaddr *) &client6, &addrlen));
561 void checkSocketpairOpen(int clientSocket, int acceptedSocket) {
563 EXPECT_EQ(4, write(clientSocket, "foo", sizeof("foo")));
568 void checkSocketpairClosed(int clientSocket, int acceptedSocket) {
570 int ret = write(clientSocket, "foo", sizeof("foo"))
[all...] |
| /tools/tradefederation/core/src/com/android/tradefed/command/remote/ |
| RemoteManager.java | 215 Socket clientSocket = null;
219 clientSocket = serverSocket.accept();
220 in = new BufferedReader(new InputStreamReader(clientSocket.getInputStream()));
221 out = new PrintWriter(clientSocket.getOutputStream(), true);
231 closeSocket(clientSocket);
505 private void closeSocket(Socket clientSocket) {
506 StreamUtil.close(clientSocket);
|
| /libcore/harmony-tests/src/test/java/org/apache/harmony/tests/java/net/ |
| ServerSocketTest.java | 431 Socket clientSocket = new Socket();
434 clientSocket.connect(clAddress);
437 assertEquals(clAddress, clientSocket.getRemoteSocketAddress());
440 clientSocket.close();
516 Socket clientSocket = new Socket();
517 clientSocket.connect(localAddress);
520 assertTrue(clientSocket.getRemoteSocketAddress().equals(localAddress));
523 clientSocket.close();
[all...] |
| /libcore/luni/src/test/java/libcore/java/net/ |
| OldServerSocketTest.java | 75 Socket clientSocket = new Socket();
78 clientSocket.connect(clAddress);
81 assertEquals(clAddress, clientSocket.getRemoteSocketAddress());
84 clientSocket.close();
|
| /external/conscrypt/openjdk/src/test/java/org/conscrypt/ |
| ConscryptSocketTest.java | 552 OpenSSLSocketImpl clientSocket = null;
555 clientSocket = (OpenSSLSocketImpl) socketType.newClientSocket(
559 clientSocket.setAlpnProtocols((byte[]) null);
560 clientSocket.setAlpnProtocols((String[]) null);
562 if (clientSocket != null) {
563 clientSocket.close();
|
| /external/mockftpserver/branches/1.x_Branch/src/main/java/org/mockftpserver/stub/ |
| StubFtpServer.java | 246 Socket clientSocket = serverSocket.accept();
247 LOG.info("Connection accepted from host " + clientSocket.getInetAddress());
249 DefaultSession session = new DefaultSession(clientSocket, commandHandlers);
254 sessionInfo.socket = clientSocket;
|
| /libcore/harmony-tests/src/test/java/org/apache/harmony/tests/javax/net/ssl/ |
| HandshakeCompletedEventTest.java | 425 SSLSocket clientSocket = (SSLSocket)serverSocket.accept();
427 InputStream istream = clientSocket.getInputStream();
436 OutputStream ostream = clientSocket.getOutputStream();
445 clientSocket.close();
|
| SSLSocketTest.java | 549 SSLSocket clientSocket = (SSLSocket)serverSocket.accept();
552 InputStream stream = clientSocket.getInputStream();
565 clientSocket.close();
|
| SSLSessionTest.java | 522 SSLSocket clientSocket = (SSLSocket)serverSocket.accept();
524 InputStream istream = clientSocket.getInputStream();
528 OutputStream ostream = clientSocket.getOutputStream();
536 clientSocket.close();
|
| /development/cmds/monkey/src/com/android/commands/monkey/ |
| MonkeySourceNetwork.java | 554 private Socket clientSocket;
572 clientSocket = serverSocket.accept();
581 input = new BufferedReader(new InputStreamReader(clientSocket.getInputStream()));
583 output = new PrintWriter(clientSocket.getOutputStream(), true);
590 clientSocket.close();
|
| /packages/apps/Bluetooth/src/com/android/bluetooth/opp/ |
| TestActivity.java | 413 Socket clientSocket = mServerSocket.accept();
414 if (clientSocket == null) {
423 "remote addr is " + clientSocket.getRemoteSocketAddress());
424 TestTcpTransport transport = new TestTcpTransport(clientSocket);
|
