| /external/webrtc/rtc_base/ |
| D | proxy_server.cc | 44 void ProxyServer::OnAcceptEvent(AsyncSocket* socket) { in OnAcceptEvent()
83 void ProxyBinding::OnConnectRequest(AsyncProxyServerSocket* socket, in OnConnectRequest()
91 void ProxyBinding::OnInternalRead(AsyncSocket* socket) { in OnInternalRead()
96 void ProxyBinding::OnInternalWrite(AsyncSocket* socket) { in OnInternalWrite()
100 void ProxyBinding::OnInternalClose(AsyncSocket* socket, int err) { in OnInternalClose()
104 void ProxyBinding::OnExternalConnect(AsyncSocket* socket) { in OnExternalConnect()
110 void ProxyBinding::OnExternalRead(AsyncSocket* socket) { in OnExternalRead()
115 void ProxyBinding::OnExternalWrite(AsyncSocket* socket) { in OnExternalWrite()
119 void ProxyBinding::OnExternalClose(AsyncSocket* socket, int err) { in OnExternalClose()
126 void ProxyBinding::Read(AsyncSocket* socket, FifoBuffer* buffer) { in Read()
[all …]
|
| D | socket_stream.cc | 18 SocketStream::SocketStream(AsyncSocket* socket) : socket_(nullptr) { in SocketStream()
26 void SocketStream::Attach(AsyncSocket* socket) { in Attach()
39 AsyncSocket* socket = socket_; in Detach() local
107 void SocketStream::OnConnectEvent(AsyncSocket* socket) { in OnConnectEvent()
112 void SocketStream::OnReadEvent(AsyncSocket* socket) { in OnReadEvent()
117 void SocketStream::OnWriteEvent(AsyncSocket* socket) { in OnWriteEvent()
122 void SocketStream::OnCloseEvent(AsyncSocket* socket, int err) { in OnCloseEvent()
|
| D | async_tcp_socket.cc | 49 rtc::AsyncSocket* socket, in ConnectSocket()
64 AsyncTCPSocketBase::AsyncTCPSocketBase(AsyncSocket* socket, in AsyncTCPSocketBase()
196 void AsyncTCPSocketBase::OnConnectEvent(AsyncSocket* socket) { in OnConnectEvent()
200 void AsyncTCPSocketBase::OnReadEvent(AsyncSocket* socket) { in OnReadEvent()
262 void AsyncTCPSocketBase::OnWriteEvent(AsyncSocket* socket) { in OnWriteEvent()
274 void AsyncTCPSocketBase::OnCloseEvent(AsyncSocket* socket, int error) { in OnCloseEvent()
282 AsyncTCPSocket* AsyncTCPSocket::Create(AsyncSocket* socket, in Create()
290 AsyncTCPSocket::AsyncTCPSocket(AsyncSocket* socket, bool listen) in AsyncTCPSocket()
346 void AsyncTCPSocket::HandleIncomingConnection(AsyncSocket* socket) { in HandleIncomingConnection()
|
| D | test_utils.h | 65 void Monitor(rtc::AsyncSocket* socket) { in Monitor()
73 void Unmonitor(rtc::AsyncSocket* socket) { in Unmonitor()
98 void OnConnectEvent(rtc::AsyncSocket* socket) { AddEvents(socket, SSE_OPEN); } in OnConnectEvent()
99 void OnReadEvent(rtc::AsyncSocket* socket) { AddEvents(socket, SSE_READ); } in OnReadEvent()
100 void OnWriteEvent(rtc::AsyncSocket* socket) { AddEvents(socket, SSE_WRITE); } in OnWriteEvent()
101 void OnCloseEvent(rtc::AsyncSocket* socket, int error) { in OnCloseEvent()
|
| /external/sl4a/Common/src/com/googlecode/android_scripting/facade/net/ |
| D | SocketFacade.java | 73 private String getDatagramSocketId(DatagramSocket socket) { in getDatagramSocketId()
82 private String getSocketId(Socket socket) { in getSocketId()
91 private String getServerSocketId(ServerSocket socket) { in getServerSocketId()
162 Socket socket = new Socket(remoteAddr, remotePort.intValue(), localAddr, in openTcpSocket() local
181 Socket socket = sSocketHashMap.get(socketId); in getPortOfSocket() local
192 Socket socket = sSocketHashMap.get(socketId); in closeTcpSocket() local
230 ServerSocket socket = sServerSocketHashMap.get(serverSocketId); in getPortOfServerSocket() local
241 ServerSocket socket = sServerSocketHashMap.get(serverSocketId); in closeTcpServerSocket() local
259 Socket socket = sSocketHashMap.get(socketId); in getFileDescriptorOfSocket() local
294 ServerSocket socket = sServerSocketHashMap.get(serverSocketId); in getTcpServerSocketPort() local
[all …]
|
| /external/webrtc/p2p/base/ |
| D | tcp_port.cc | 148 if (rtc::AsyncPacketSocket* socket = GetIncoming(address.address(), true)) { in CreateConnection() local
203 rtc::AsyncPacketSocket* socket = NULL; in SendTo() local
276 void TCPPort::OnNewConnection(rtc::AsyncPacketSocket* socket, in OnNewConnection()
308 rtc::AsyncPacketSocket* socket = NULL; in GetIncoming() local
321 void TCPPort::OnReadPacket(rtc::AsyncPacketSocket* socket, in OnReadPacket()
329 void TCPPort::OnSentPacket(rtc::AsyncPacketSocket* socket, in OnSentPacket()
334 void TCPPort::OnReadyToSend(rtc::AsyncPacketSocket* socket) { in OnReadyToSend()
338 void TCPPort::OnAddressReady(rtc::AsyncPacketSocket* socket, in OnAddressReady()
351 rtc::AsyncPacketSocket* socket) in TCPConnection()
434 void TCPConnection::OnConnect(rtc::AsyncPacketSocket* socket) { in OnConnect()
[all …]
|
| /external/conscrypt/testing/src/main/java/tests/net/ |
| D | DelegatingSSLSocketFactory.java | 37 protected SSLSocket configureSocket(SSLSocket socket) throws IOException { in configureSocket()
50 SSLSocket socket = (SSLSocket) mDelegate.createSocket(); in createSocket() local
56 SSLSocket socket = (SSLSocket) mDelegate.createSocket(s, host, port, autoClose); in createSocket() local
61 SSLSocket socket = (SSLSocket) mDelegate.createSocket(host, port); in createSocket() local
67 SSLSocket socket = (SSLSocket) mDelegate.createSocket(host, port, localHost, localPort); in createSocket() local
72 SSLSocket socket = (SSLSocket) mDelegate.createSocket(host, port); in createSocket() local
78 … SSLSocket socket = (SSLSocket) mDelegate.createSocket(address, port, localAddress, localPort); in createSocket() local
|
| D | DelegatingSocketFactory.java | 36 protected Socket configureSocket(Socket socket) throws IOException { in configureSocket()
41 Socket socket = mDelegate.createSocket(); in createSocket() local
46 Socket socket = mDelegate.createSocket(host, port); in createSocket() local
52 Socket socket = mDelegate.createSocket(host, port, localHost, localPort); in createSocket() local
57 Socket socket = mDelegate.createSocket(host, port); in createSocket() local
63 Socket socket = mDelegate.createSocket(address, port, localAddress, localPort); in createSocket() local
|
| /external/conscrypt/repackaged/testing/src/main/java/tests/net/ |
| D | DelegatingSSLSocketFactory.java | 39 protected SSLSocket configureSocket(SSLSocket socket) throws IOException { in configureSocket()
52 SSLSocket socket = (SSLSocket) mDelegate.createSocket(); in createSocket() local
58 SSLSocket socket = (SSLSocket) mDelegate.createSocket(s, host, port, autoClose); in createSocket() local
63 SSLSocket socket = (SSLSocket) mDelegate.createSocket(host, port); in createSocket() local
69 SSLSocket socket = (SSLSocket) mDelegate.createSocket(host, port, localHost, localPort); in createSocket() local
74 SSLSocket socket = (SSLSocket) mDelegate.createSocket(host, port); in createSocket() local
80 … SSLSocket socket = (SSLSocket) mDelegate.createSocket(address, port, localAddress, localPort); in createSocket() local
|
| D | DelegatingSocketFactory.java | 38 protected Socket configureSocket(Socket socket) throws IOException { in configureSocket()
43 Socket socket = mDelegate.createSocket(); in createSocket() local
48 Socket socket = mDelegate.createSocket(host, port); in createSocket() local
54 Socket socket = mDelegate.createSocket(host, port, localHost, localPort); in createSocket() local
59 Socket socket = mDelegate.createSocket(host, port); in createSocket() local
65 Socket socket = mDelegate.createSocket(address, port, localAddress, localPort); in createSocket() local
|
| /external/okhttp/okhttp-tests/src/test/java/com/squareup/okhttp/ |
| D | DelegatingSocketFactory.java | 38 Socket socket = delegate.createSocket(); in createSocket() local
44 Socket socket = delegate.createSocket(host, port); in createSocket() local
51 Socket socket = delegate.createSocket(host, port, localAddress, localPort); in createSocket() local
57 Socket socket = delegate.createSocket(host, port); in createSocket() local
64 Socket socket = delegate.createSocket(host, port, localAddress, localPort); in createSocket() local
68 protected Socket configureSocket(Socket socket) throws IOException { in configureSocket()
|
| /external/okhttp/okio/okio/src/test/java/okio/ |
| D | SocketTimeoutTest.java | 39 Socket socket = socket(ONE_MB, 0); in readWithoutTimeout() local
47 Socket socket = socket(0, 0); in readWithTimeout() local
59 Socket socket = socket(0, ONE_MB); in writeWithoutTimeout() local
69 Socket socket = socket(0, 0); in writeWithTimeout() local
92 …static Socket socket(final int readableByteCount, final int writableByteCount) throws IOException { in socket() method in SocketTimeoutTest
117 Socket socket = new Socket(serverSocket.getInetAddress(), serverSocket.getLocalPort()); in socket() local
|
| /external/okio/okio/src/jvmTest/java/okio/ |
| D | SocketTimeoutTest.java | 39 Socket socket = socket(ONE_MB, 0); in readWithoutTimeout() local
47 Socket socket = socket(0, 0); in readWithTimeout() local
59 Socket socket = socket(0, ONE_MB); in writeWithoutTimeout() local
69 Socket socket = socket(0, 0); in writeWithTimeout() local
92 …static Socket socket(final int readableByteCount, final int writableByteCount) throws IOException { in socket() method in SocketTimeoutTest
117 Socket socket = new Socket(serverSocket.getInetAddress(), serverSocket.getLocalPort()); in socket() local
|
| /external/conscrypt/openjdk/src/test/java/org/conscrypt/ |
| D | DuckTypedPSKKeyManagerTest.java | 180 public String chooseServerKeyIdentityHint(Socket socket) { in chooseServerKeyIdentityHint()
188 public String chooseClientKeyIdentity(String identityHint, Socket socket) { in chooseClientKeyIdentity()
196 public SecretKey getKey(String identityHint, String identity, Socket socket) { in getKey()
211 public String chooseServerKeyIdentityHint(Socket socket) { in chooseServerKeyIdentityHint()
219 public String chooseClientKeyIdentity(String identityHint, Socket socket) { in chooseClientKeyIdentity()
227 public SecretKey getKey(String identityHint, String identity, Socket socket) { in getKey()
244 public String chooseServerKeyIdentityHint(Socket socket) { in chooseServerKeyIdentityHint()
252 public String chooseClientKeyIdentity(String identityHint, Socket socket) { in chooseClientKeyIdentity()
261 public SecretKeySpec getKey(String identityHint, String identity, Socket socket) { in getKey()
279 public String chooseServerKeyIdentityHint(Socket socket) { in chooseServerKeyIdentityHint()
[all …]
|
| /external/conscrypt/repackaged/openjdk/src/test/java/com/android/org/conscrypt/ |
| D | DuckTypedPSKKeyManagerTest.java | 184 public String chooseServerKeyIdentityHint(Socket socket) { in chooseServerKeyIdentityHint()
192 public String chooseClientKeyIdentity(String identityHint, Socket socket) { in chooseClientKeyIdentity()
200 public SecretKey getKey(String identityHint, String identity, Socket socket) { in getKey()
215 public String chooseServerKeyIdentityHint(Socket socket) { in chooseServerKeyIdentityHint()
223 public String chooseClientKeyIdentity(String identityHint, Socket socket) { in chooseClientKeyIdentity()
231 public SecretKey getKey(String identityHint, String identity, Socket socket) { in getKey()
248 public String chooseServerKeyIdentityHint(Socket socket) { in chooseServerKeyIdentityHint()
256 public String chooseClientKeyIdentity(String identityHint, Socket socket) { in chooseClientKeyIdentity()
265 public SecretKeySpec getKey(String identityHint, String identity, Socket socket) { in getKey()
283 public String chooseServerKeyIdentityHint(Socket socket) { in chooseServerKeyIdentityHint()
[all …]
|
| /external/okhttp/okhttp-tests/src/test/java/com/squareup/okhttp/internal/ |
| D | ConnectionSpecSelectorTest.java | 48 SSLSocket socket = createSocketWithEnabledProtocols(TlsVersion.TLS_1_1, TlsVersion.TLS_1_0); in nonRetryableIOException() local
61 SSLSocket socket = createSocketWithEnabledProtocols(TlsVersion.TLS_1_1, TlsVersion.TLS_1_0); in nonRetryableSSLHandshakeException() local
76 SSLSocket socket = createSocketWithEnabledProtocols(TlsVersion.TLS_1_1, TlsVersion.TLS_1_0); in retryableSSLHandshakeException() local
95 SSLSocket socket = createSocketWithEnabledProtocols(enabledSocketTlsVersions); in someFallbacksSupported() local
123 SSLSocket socket = (SSLSocket) sslContext.getSocketFactory().createSocket(); in createSocketWithEnabledProtocols() local
128 private static void assertEnabledProtocols(SSLSocket socket, TlsVersion... required) { in assertEnabledProtocols()
|
| /external/grpc-grpc/src/core/lib/iomgr/ |
| D | tcp_uv.cc | 82 static void uv_socket_destroy(grpc_custom_socket* socket) { in uv_socket_destroy()
111 grpc_custom_socket* socket = (grpc_custom_socket*)stream->data; in uv_read_callback() local
117 grpc_custom_socket* socket = (grpc_custom_socket*)handle->data; in uv_close_callback() local
126 static void uv_socket_read(grpc_custom_socket* socket, char* buffer, in uv_socket_read()
145 grpc_custom_socket* socket = (grpc_custom_socket*)req->data; in uv_write_callback() local
151 void uv_socket_write(grpc_custom_socket* socket, in uv_socket_write()
175 static void uv_socket_shutdown(grpc_custom_socket* socket) { in uv_socket_shutdown()
181 static void uv_socket_close(grpc_custom_socket* socket, in uv_socket_close()
216 static grpc_error* uv_socket_init(grpc_custom_socket* socket, int domain) { in uv_socket_init()
227 static grpc_error* uv_socket_getpeername(grpc_custom_socket* socket, in uv_socket_getpeername()
[all …]
|
| D | socket_windows.cc | 42 grpc_winsocket* grpc_winsocket_create(SOCKET socket, const char* name) { in grpc_winsocket_create()
55 SOCKET grpc_winsocket_wrapped_socket(grpc_winsocket* socket) { in grpc_winsocket_wrapped_socket()
119 static void socket_notify_on_iocp(grpc_winsocket* socket, grpc_closure* closure, in socket_notify_on_iocp()
132 void grpc_socket_notify_on_write(grpc_winsocket* socket, in grpc_socket_notify_on_write()
137 void grpc_socket_notify_on_read(grpc_winsocket* socket, grpc_closure* closure) { in grpc_socket_notify_on_read()
141 void grpc_socket_become_ready(grpc_winsocket* socket, in grpc_socket_become_ready()
|
| /external/rust/crates/grpcio-sys/grpc/src/core/lib/iomgr/ |
| D | tcp_uv.cc | 81 static void uv_socket_destroy(grpc_custom_socket* socket) { in uv_socket_destroy()
110 grpc_custom_socket* socket = (grpc_custom_socket*)stream->data; in uv_read_callback() local
116 grpc_custom_socket* socket = (grpc_custom_socket*)handle->data; in uv_close_callback() local
125 static void uv_socket_read(grpc_custom_socket* socket, char* buffer, in uv_socket_read()
144 grpc_custom_socket* socket = (grpc_custom_socket*)req->data; in uv_write_callback() local
150 void uv_socket_write(grpc_custom_socket* socket, in uv_socket_write()
174 static void uv_socket_shutdown(grpc_custom_socket* socket) { in uv_socket_shutdown()
180 static void uv_socket_close(grpc_custom_socket* socket, in uv_socket_close()
215 static grpc_error* uv_socket_init(grpc_custom_socket* socket, int domain) { in uv_socket_init()
226 static grpc_error* uv_socket_getpeername(grpc_custom_socket* socket, in uv_socket_getpeername()
[all …]
|
| D | socket_windows.cc | 45 grpc_winsocket* grpc_winsocket_create(SOCKET socket, const char* name) { in grpc_winsocket_create()
56 SOCKET grpc_winsocket_wrapped_socket(grpc_winsocket* socket) { in grpc_winsocket_wrapped_socket()
120 static void socket_notify_on_iocp(grpc_winsocket* socket, grpc_closure* closure, in socket_notify_on_iocp()
133 void grpc_socket_notify_on_write(grpc_winsocket* socket, in grpc_socket_notify_on_write()
138 void grpc_socket_notify_on_read(grpc_winsocket* socket, grpc_closure* closure) { in grpc_socket_notify_on_read()
142 void grpc_socket_become_ready(grpc_winsocket* socket, in grpc_socket_become_ready()
|
| /external/openscreen/osp/impl/testing/ |
| D | fake_mdns_responder_adapter.cc | 23 UdpSocket* socket) { in MakePtrEvent()
39 UdpSocket* socket) { in MakeSrvEvent()
60 UdpSocket* socket) { in MakeTxtEvent()
73 UdpSocket* socket) { in MakeAEvent()
85 UdpSocket* socket) { in MakeAaaaEvent()
103 UdpSocket* socket) { in AddEventsForNewService()
210 UdpSocket* socket) { in RegisterInterface()
224 Error FakeMdnsResponderAdapter::DeregisterInterface(UdpSocket* socket) { in DeregisterInterface()
237 void FakeMdnsResponderAdapter::OnRead(UdpSocket* socket, in OnRead()
242 void FakeMdnsResponderAdapter::OnSendError(UdpSocket* socket, Error error) { in OnSendError()
[all …]
|
| /external/conscrypt/common/src/test/java/org/conscrypt/javax/net/ssl/ |
| D | SSLServerSocketTest.java | 49 SSLServerSocket socket = in testSetEnabledCipherSuitesAffectsGetter_TLS12() local
60 SSLServerSocket socket = in testSetEnabledCipherSuitesAffectsGetter_TLS13() local
73 SSLServerSocket socket = in testSetEnabledCipherSuitesStoresCopy() local
84 SSLServerSocket socket = in testSetEnabledProtocolsAffectsGetter() local
93 SSLServerSocket socket = in testSetEnabledProtocolsStoresCopy() local
|
| /external/conscrypt/repackaged/common/src/test/java/com/android/org/conscrypt/javax/net/ssl/ |
| D | SSLServerSocketTest.java | 53 SSLServerSocket socket = in testSetEnabledCipherSuitesAffectsGetter_TLS12() local
64 SSLServerSocket socket = in testSetEnabledCipherSuitesAffectsGetter_TLS13() local
77 SSLServerSocket socket = in testSetEnabledCipherSuitesStoresCopy() local
88 SSLServerSocket socket = in testSetEnabledProtocolsAffectsGetter() local
97 SSLServerSocket socket = in testSetEnabledProtocolsStoresCopy() local
|
| /external/grpc-grpc/src/python/grpcio/grpc/_cython/_cygrpc/ |
| D | grpc_gevent.pyx.pxi | 87 cdef grpc_error* socket_init(grpc_custom_socket* socket, int domain) with gil:
113 cdef void socket_connect(grpc_custom_socket* socket, const grpc_sockaddr* addr,
128 cdef void socket_destroy(grpc_custom_socket* socket) with gil:
131 cdef void socket_shutdown(grpc_custom_socket* socket) with gil:
138 cdef void socket_close(grpc_custom_socket* socket,
150 def socket_sendmsg(socket, write_bytes): argument
178 cdef void socket_write(grpc_custom_socket* socket, grpc_slice_buffer* buffer,
206 cdef void socket_read(grpc_custom_socket* socket, char* buffer,
214 cdef grpc_error* socket_getpeername(grpc_custom_socket* socket,
227 cdef grpc_error* socket_getsockname(grpc_custom_socket* socket,
[all …]
|
| /external/usrsctp/usrsctplib/ |
| D | user_socketvar.h | 127 struct socket { struct
129 short so_type; /* (a) generic type, see socket.h */ argument
130 short so_options; /* from socket call, see socket.h */ argument
139 * If so_head is 0, socket is not related to an accept. argument
147 struct socket *so_head; /* (e) back pointer to listen socket */ argument
162 TAILQ_HEAD(, aiocblist) so_aiojobq; /* AIO ops waiting on socket */ argument
178 short sb_state; /* (c/d) socket state on sockbuf */ argument
199 … (64*1024*2) /*Aligning so->so_rcv.sb_hiwat with the receive buffer size of raw socket*/ argument
212 void (*so_upcall)(struct socket *, void *, int); argument
215 struct label *so_label; /* (b) MAC label for socket */ argument
[all …]
|