| /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...] |
