/system/connectivity/shill/net/ |
netlink_socket_unittest.cc | 55 EXPECT_CALL(*mock_sockets_, Socket(PF_NETLINK, SOCK_DGRAM, NETLINK_GENERIC)) 101 EXPECT_CALL(*mock_sockets_, Socket(PF_NETLINK, SOCK_DGRAM, NETLINK_GENERIC)) 111 EXPECT_CALL(*mock_sockets_, Socket(PF_NETLINK, SOCK_DGRAM, NETLINK_GENERIC)) 126 EXPECT_CALL(*mock_sockets_, Socket(PF_NETLINK, SOCK_DGRAM, NETLINK_GENERIC))
|
/cts/tests/tests/os/src/android/os/cts/ |
ParcelFileDescriptorTest.java | 43 import java.net.Socket; 88 Socket sSocket = ss.accept(); 102 Socket socket; local 103 socket = new Socket(InetAddress.getLocalHost(), PORT); 104 ParcelFileDescriptor pfd = ParcelFileDescriptor.fromSocket(socket); 108 socket.close(); 170 ParcelFileDescriptor pfd = ParcelFileDescriptor.fromSocket(new Socket()); 221 ParcelFileDescriptor pfd = ParcelFileDescriptor.fromSocket(new Socket()); [all...] |
/external/conscrypt/src/compat/java/org/conscrypt/ |
Platform.java | 30 import java.net.Socket; 63 public static FileDescriptor getFileDescriptor(Socket s) { 67 Method m_getFileDescriptor = Socket.class.getDeclaredMethod("getFileDescriptor$"); 76 Field f_impl = Socket.class.getDeclaredField("impl"); 84 throw new RuntimeException("Can't get FileDescriptor from socket", e); 115 public static void setSocketWriteTimeout(Socket s, long timeoutMillis) throws SocketException { 120 Log.w(TAG, "Cannot find StructTimeval; not setting socket write timeout"); 129 Log.w(TAG, "Cannot find libcore.os.Libcore; not setting socket write timeout"); 147 Log.w(TAG, "Could not set socket write timeout: " + e.getMessage()); 152 OpenSSLSocketImpl socket) { [all...] |
/external/webrtc/webrtc/examples/peerconnection/client/ |
peer_connection_client.cc | 162 ASSERT(control_socket_->GetState() == rtc::Socket::CS_CLOSED); 184 control_socket_->GetState() != rtc::Socket::CS_CLOSED; 191 if (hanging_get_->GetState() != rtc::Socket::CS_CLOSED) 194 if (control_socket_->GetState() == rtc::Socket::CS_CLOSED) { 228 ASSERT(control_socket_->GetState() == rtc::Socket::CS_CLOSED); 237 void PeerConnectionClient::OnConnect(rtc::AsyncSocket* socket) { 239 size_t sent = socket->Send(onconnect_data_.c_str(), onconnect_data_.length()); 245 void PeerConnectionClient::OnHangingGetConnect(rtc::AsyncSocket* socket) { 250 int sent = socket->Send(buffer, len); 294 bool PeerConnectionClient::ReadIntoBuffer(rtc::AsyncSocket* socket, [all...] |
/frameworks/base/tests/SoundTriggerTests/src/android/hardware/soundtrigger/stubhal/ |
GenericSoundModelTest.java | 42 import java.net.Socket; 165 Socket socket = new Socket(InetAddress.getLocalHost(), 14035); local 166 DataOutputStream out = new DataOutputStream(socket.getOutputStream()); 169 socket.close(); 241 Socket socket = new Socket(InetAddress.getLocalHost(), 14035); local 242 DataOutputStream out = new DataOutputStream(socket.getOutputStream()) [all...] |
/packages/apps/Email/emailcommon/src/com/android/emailcommon/utility/ |
SSLUtils.java | 34 import java.net.Socket; 252 String[] keyTypes, Principal[] issuers, Socket socket); 263 String keyType, Principal[] issuers, Socket socket) { 289 public String chooseClientAlias(String[] keyTypes, Principal[] issuers, Socket socket) { 291 InetAddress address = socket.getInetAddress(); 386 public String chooseClientAlias(String[] keyTypes, Principal[] issuers, Socket socket) { [all...] |
/external/deqp/execserver/tools/ |
xsTest.cpp | 69 void sendMessage (de::Socket& socket, const Message& message) 75 // Write to socket. 81 deSocketResult result = socket.send(&buf[pos], numLeft, &numSent); 90 void readBytes (de::Socket& socket, vector<deUint8>& dst, size_t numBytes) 98 deSocketResult result = socket.receive(&dst[numRead], numLeft, &curNumRead); 107 Message* readMessage (de::Socket& socket) 111 readBytes(socket, header, MESSAGE_HEADER_SIZE) 298 de::Socket socket; local [all...] |
/external/caliper/caliper/src/main/java/com/google/caliper/runner/ |
ServerSocketService.java | 33 import java.net.Socket; 51 * <li>It adapts {@link ServerSocket#accept()} to a {@link ListenableFuture} of an opened socket. 53 * sent over the socket. 61 * from the socket. 62 * <li>{@linkplain State#STOPPING STOPPING} : The server socket is closing and all pending 64 * <li>{@linkplain State#TERMINATED TERMINATED} : Idle state, the socket is closed. 78 * close the socket (this holds for ServerSocketChannels and normal ServerSockets), but we 79 * cannot do that in this case because the socket is a shared resource. 84 * messages over its output streams and then calls Socket.connect, and no printing to stdout 121 checkState(serverSocket != null, "Socket has not been opened yet") 143 Socket socket; local [all...] |
/external/caliper/caliper/src/test/java/com/google/caliper/runner/ |
FakeWorkers.java | 31 import java.net.Socket; 168 * Connects to a socket on localhost on the port provided as the first argument and echos all 177 new Socket(InetAddress.getLocalHost(), port));
|
ServerSocketServiceTest.java | 34 import java.net.Socket; 92 assertEquals("The socket has been closed", e.getCause().getMessage()); 102 return OpenedSocket.fromSocket(new Socket(InetAddress.getLoopbackAddress(), port));
|
/external/conscrypt/src/stub/java/com/android/org/conscrypt/ |
OpenSSLSocketImpl.java | 23 import java.net.Socket; 83 protected OpenSSLSocketImpl(Socket socket, String host, int port, 234 * Set the handshake timeout on this socket. This timeout is specified in
|
/external/conscrypt/src/stub/java/org/apache/harmony/xnet/xnet/provider/jsse/ |
OpenSSLSocketImpl.java | 23 import java.net.Socket; 83 protected OpenSSLSocketImpl(Socket socket, String host, int port, 234 * Set the handshake timeout on this socket. This timeout is specified in
|
/external/jacoco/org.jacoco.core.test/src/org/jacoco/core/tools/ |
ExecDumpClientTest.java | 23 import java.net.Socket; 151 private void handleConnection(Socket socket) throws IOException { 153 socket.getOutputStream()); 155 socket.getInputStream());
|
/external/libgdx/gdx/src/com/badlogic/gdx/ |
Net.java | 31 import com.badlogic.gdx.net.Socket;
36 /** Provides methods to perform networking operations, such as simple HTTP get and post requests, and TCP server/client socket
44 * To create a TCP client socket to communicate with a remote TCP server, invoke the
45 * {@link #newClientSocket(Protocol, String, int, SocketHints)} method. The returned {@link Socket} offers an {@link InputStream}
48 * To create a TCP server socket that waits for incoming connections, invoke the
337 /** Creates a new server socket on the given address and port, using the given {@link Protocol}, waiting for incoming connections.
339 * @param hostname the hostname or ip address to bind the socket to
341 * @param hints additional {@link ServerSocketHints} used to create the socket. Input null to use the default setting provided
344 * @throws GdxRuntimeException in case the socket couldn't be opened */
347 /** Creates a new server socket on the given port, using the given {@link Protocol}, waiting for incoming connections. [all...] |
/external/mockwebserver/src/main/java/com/google/mockwebserver/ |
RecordedRequest.java | 20 import java.net.Socket; 50 int bodySize, byte[] body, int sequenceNumber, Socket socket) { 58 if (socket instanceof SSLSocket) { 59 SSLSocket sslSocket = (SSLSocket) socket;
|
/external/nist-sip/java/gov/nist/javax/sip/stack/ |
TCPMessageProcessor.java | 31 import java.net.Socket; 50 * accept socket). 108 * Run method for the thread that gets created for each accept socket. 111 // Accept new connectins on our socket. 133 Socket newsock = sock.accept();
|
/external/webrtc/webrtc/base/ |
physicalsocketserver.h | 23 typedef int SOCKET; 50 virtual SOCKET GetSocket() = 0; 58 // A socket server that provides the real sockets of the underlying OS. 65 Socket* CreateSocket(int type) override; 66 Socket* CreateSocket(int family, int type) override; 72 AsyncSocket* WrapSocket(SOCKET s); 121 PhysicalSocket(PhysicalSocketServer* ss, SOCKET s = INVALID_SOCKET); 124 // Creates the underlying OS socket (same as the "socket" function). 162 virtual SOCKET DoAccept(SOCKET socket, sockaddr* addr, socklen_t* addrlen) [all...] |
sslsocketfactory.cc | 24 // the socket adapter is the more appropriate idiom for automatic proxy 115 Socket* SslSocketFactory::CreateSocket(int type) { 119 Socket* SslSocketFactory::CreateSocket(int family, int type) { 139 AsyncSocket* socket = factory_->CreateAsyncSocket(family, type); local 140 if (!socket) 145 socket = new LoggingSocketAdapter(socket, logging_level_, 152 proxy_socket = new AsyncSocksProxySocket(socket, proxy.address, 157 new AsyncHttpsProxySocket(socket, agent_, proxy.address, 163 delete socket; [all...] |
/external/webrtc/webrtc/p2p/base/ |
basicpacketsocketfactory.cc | 51 rtc::AsyncSocket* socket = local 54 if (!socket) { 57 if (BindSocket(socket, address, min_port, max_port) < 0) { 59 << socket->GetError(); 60 delete socket; 63 return new rtc::AsyncUDPSocket(socket); 77 rtc::AsyncSocket* socket = local 80 if (!socket) { 84 if (BindSocket(socket, local_address, min_port, max_port) < 0) { 86 << socket->GetError() 111 rtc::AsyncSocket* socket = local [all...] |
tcpport.h | 55 int GetOption(rtc::Socket::Option opt, int* value) override; 56 int SetOption(rtc::Socket::Option opt, int value) override; 74 // Handles sending using the local TCP socket. 82 void OnNewConnection(rtc::AsyncPacketSocket* socket, 88 rtc::AsyncPacketSocket* socket; member in struct:cricket::TCPPort::Incoming 94 // Receives packet signal from the local TCP Socket. 95 void OnReadPacket(rtc::AsyncPacketSocket* socket, 100 void OnSentPacket(rtc::AsyncPacketSocket* socket, 103 void OnReadyToSend(rtc::AsyncPacketSocket* socket); 105 void OnAddressReady(rtc::AsyncPacketSocket* socket, 130 rtc::AsyncPacketSocket* socket() { return socket_.get(); } function in class:cricket::TCPConnection [all...] |
/frameworks/base/packages/Osu/src/com/android/hotspot2/osu/service/ |
RedirectListener.java | 15 import java.net.Socket; 135 try (Socket instance = mServerSocket.accept()) {
|
/libcore/luni/src/main/java/libcore/io/ |
IoUtils.java | 26 import java.net.Socket; 75 * Closes 'socket', ignoring any exceptions. Does nothing if 'socket' is null. 77 public static void closeQuietly(Socket socket) { 78 if (socket != null) { 80 socket.close();
|
/packages/apps/Bluetooth/src/com/android/bluetooth/opp/ |
BluetoothOppRfcommListener.java | 37 import java.net.Socket; 95 Socket clientSocket = mTcpServerSocket.accept(); 97 if (V) Log.v(TAG, "Socket connected!");
|
/cts/tests/tests/net/src/android/net/cts/ |
TrafficStatsTest.java | 31 import java.net.Socket; 118 // Transfer 1MB of data across an explicitly localhost socket. 127 Socket socket = new Socket("localhost", server.getLocalPort()); local 130 socket.setTcpNoDelay(true); 131 OutputStream out = socket.getOutputStream(); 134 TrafficStats.tagSocket(socket); 147 socket.close(); 150 Log.i(LOG_TAG, "Badness during writes to socket: " + e) 157 Socket socket = server.accept(); local [all...] |
/external/apache-http/android/src/android/net/http/ |
AndroidHttpClientConnection.java | 54 import java.net.Socket; 75 private Socket socket = null; field in class:AndroidHttpClientConnection 83 * Bind socket and set HttpParams to AndroidHttpClientConnection 84 * @param socket outgoing socket 89 final Socket socket, 91 if (socket == null) { 92 throw new IllegalArgumentException("Socket may not be null") [all...] |