| /external/okhttp/mockwebserver/src/main/java/com/squareup/okhttp/mockwebserver/ |
| MockWebServer.java | 43 import java.net.Socket;
114 private final Set<Socket> openClientSockets =
115 Collections.newSetFromMap(new ConcurrentHashMap<Socket, Boolean>());
330 * @param inetAddress the address to create the server socket on
341 * Starts the server and binds to the given socket address.
343 * @param inetSocketAddress the socket address to bind the server on
368 for (Iterator<Socket> s = openClientSockets.iterator(); s.hasNext(); ) {
381 Socket socket;
383 socket = serverSocket.accept()
[all...] |
| /external/okhttp/okio/okio/src/main/java/okio/ |
| Okio.java | 26 import java.net.Socket;
108 * Returns a sink that writes to {@code socket}. Prefer this over {@link
109 * #sink(OutputStream)} because this method honors timeouts. When the socket
110 * write times out, the socket is asynchronously closed by a watchdog thread.
112 public static Sink sink(Socket socket) throws IOException {
113 if (socket == null) throw new IllegalArgumentException("socket == null");
114 AsyncTimeout timeout = timeout(socket);
115 Sink sink = sink(socket.getOutputStream(), timeout)
[all...] |
| /external/webrtc/talk/media/base/ |
| fakenetworkinterface.h | 168 virtual int SetOption(SocketType type, rtc::Socket::Option opt,
170 if (opt == rtc::Socket::OPT_SNDBUF) {
172 } else if (opt == rtc::Socket::OPT_RCVBUF) {
174 } else if (opt == rtc::Socket::OPT_DSCP) {
|
| /libcore/ojluni/src/main/java/java/net/ |
| ServerSocket.java | 35 * This class implements server sockets. A server socket waits for
39 * The actual work of the server socket is performed by an instance
41 * change the socket factory that creates the socket
54 * Various states of this socket.
62 * The implementation of this Socket.
81 * Creates an unbound server socket.
83 * @exception IOException IO error when opening the socket.
91 * Creates a server socket, bound to the specified port. A port number
100 * If the application has specified a server socket factory, tha
[all...] |
| /libcore/ojluni/src/main/java/sun/nio/ch/ |
| FileDescriptorHolderSocketImpl.java | 29 import java.net.Socket;
37 * {@link Socket}. As such none of the methods in this class are implemented
38 * since {@link SocketAdaptor} should override everything in {@link Socket}
|
| /libcore/support/src/test/java/libcore/javax/net/ssl/ |
| TestKeyManager.java | 20 import java.net.Socket;
63 public String chooseClientAlias(String[] keyTypes, Principal[] issuers, Socket socket) {
71 dumpSocket(socket);
73 return dumpAlias(keyManager.chooseClientAlias(keyTypes, issuers, socket));
88 public String chooseServerAlias(String keyType, Principal[] issuers, Socket socket) {
94 dumpSocket(socket);
96 return dumpAlias(keyManager.chooseServerAlias(keyType, issuers, socket));
99 private void dumpSocket(Socket socket)
[all...] |
| /packages/apps/Email/provider_src/com/android/email/mail/transport/ |
| MailTransport.java | 37 import java.net.Socket;
61 private Socket mSocket;
118 mSocket = new Socket();
121 // After the socket connects to an SSL server, confirm that the hostname is as expected
162 * TODO should we explicitly close the old socket? This seems funky to abandon it.
199 * connected socket. You MUST call this if you did not supply a hostname
207 * @param socket An SSL socket which has been connected to a server
212 private static void verifyHostname(Socket socket, String hostname) throws IOException
[all...] |
| /prebuilts/go/darwin-x86/src/syscall/ |
| lsf_linux.go | 5 // Linux socket filter
26 s, e := Socket(AF_PACKET, SOCK_RAW, proto)
49 s, e := Socket(AF_INET, SOCK_DGRAM, 0)
|
| /prebuilts/go/linux-x86/src/syscall/ |
| lsf_linux.go | 5 // Linux socket filter
26 s, e := Socket(AF_PACKET, SOCK_RAW, proto)
49 s, e := Socket(AF_INET, SOCK_DGRAM, 0)
|
| /cts/tests/tests/os/src/android/os/cts/ |
| ParcelFileDescriptorTest.java | 57 import java.net.Socket;
109 Socket sSocket = ss.accept();
123 Socket socket; local
124 socket = new Socket(InetAddress.getLocalHost(), PORT);
125 ParcelFileDescriptor pfd = ParcelFileDescriptor.fromSocket(socket);
129 socket.close();
192 ParcelFileDescriptor pfd = ParcelFileDescriptor.fromSocket(new Socket());
247 ParcelFileDescriptor pfd = ParcelFileDescriptor.fromSocket(new 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...] |
| /libcore/luni/src/test/java/libcore/java/nio/channels/ |
| AsynchronousServerSocketChannelTest.java | 25 import java.net.Socket;
113 Socket s = new Socket();
138 Socket s = new Socket();
166 Socket s = new Socket();
|
| /prebuilts/go/darwin-x86/src/runtime/ |
| os2_nacl.go | 97 _ENOTSOCK = 88 /* Socket operation on non-socket */
100 _EPROTOTYPE = 91 /* Protocol wrong type for socket */
103 _ESOCKTNOSUPPORT = 94 /* Socket type not supported */
115 _EISCONN = 106 /* Socket is already connected */
116 _ENOTCONN = 107 /* Socket is not connected */
117 _ESHUTDOWN = 108 /* Can't send after socket shutdown */
123 _EALREADY = 114 /* Socket already connected */
|
| /prebuilts/go/linux-x86/src/runtime/ |
| os2_nacl.go | 97 _ENOTSOCK = 88 /* Socket operation on non-socket */
100 _EPROTOTYPE = 91 /* Protocol wrong type for socket */
103 _ESOCKTNOSUPPORT = 94 /* Socket type not supported */
115 _EISCONN = 106 /* Socket is already connected */
116 _ENOTCONN = 107 /* Socket is not connected */
117 _ESHUTDOWN = 108 /* Can't send after socket shutdown */
123 _EALREADY = 114 /* Socket already connected */
|
| /device/linaro/bootloader/edk2/Vlv2TbltDevicePkg/SmBiosMiscDxe/ |
| MiscProcessorInformationFunction.c | 160 CHAR16 *Socket=NULL;
265 // Token to get for Socket Name
268 Socket = SmbiosMiscGetString (TokenToGet);
269 SocketStrLen = StrLen(Socket);
337 SmbiosRecord-> Socket= 1;
440 UnicodeStrToAsciiStr(Socket, OptionalStrStart);
|
| /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 | 70 void sendMessage (de::Socket& socket, const Message& message)
76 // Write to socket.
82 deSocketResult result = socket.send(&buf[pos], numLeft, &numSent);
91 void readBytes (de::Socket& socket, vector<deUint8>& dst, size_t numBytes)
99 deSocketResult result = socket.receive(&dst[numRead], numLeft, &curNumRead);
108 Message* readMessage (de::Socket& socket)
112 readBytes(socket, header, MESSAGE_HEADER_SIZE)
299 de::Socket socket; local
[all...] |
| /device/linaro/bootloader/OpenPlatformPkg/Platforms/Hisilicon/D02/OemNicConfigD02/ |
| OemNicConfigD02.c | 58 stI2cDev.Socket = 0;
88 stI2cDev.Socket = 0;
|
| /device/linaro/bootloader/edk2/NetworkPkg/TcpDxe/ |
| SockInterface.c | 2 Interface function of the Socket.
54 in the related socket's lists.
56 @param[in] Sock Pointer to the instance's socket.
59 @retval TRUE The Event exists in related socket's lists.
60 @retval FALSE The Event is not in related socket's lists.
65 IN SOCKET *Sock,
92 Buffer a token into the specific list of the socket Sock.
94 @param[in] Sock Pointer to the instance's socket.
104 IN SOCKET *Sock,
132 Destroy the socket Sock and its associated protocol control block.
[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/android-stub/src/main/java/com/android/org/conscrypt/ |
| OpenSSLSocketImpl.java | 23 import java.net.Socket;
73 protected OpenSSLSocketImpl(Socket socket, String host, int port, boolean autoClose,
254 * Set the handshake timeout on this socket. This timeout is specified in
|
| /external/conscrypt/android-stub/src/main/java/org/apache/harmony/xnet/provider/jsse/ |
| OpenSSLSocketImpl.java | 23 import java.net.Socket;
73 protected OpenSSLSocketImpl(Socket socket, String host, int port, boolean autoClose,
255 * Set the handshake timeout on this socket. This timeout is specified in
|
