| /external/conscrypt/libcore-stub/src/main/java/libcore/io/ |
| IoUtils.java | 21 import java.net.Socket;
41 * Closes 'socket', ignoring any exceptions. Does nothing if 'socket' is null.
43 public static void closeQuietly(Socket socket) {
44 if (socket != null) {
46 socket.close();
|
| /external/swiftshader/src/Common/ |
| Socket.hpp | 21 #include <sys/socket.h>
22 typedef int SOCKET;
27 class Socket
30 Socket(SOCKET socket);
31 Socket(const char *address, const char *port);
32 ~Socket();
36 Socket *accept();
45 SOCKET socket member in class:sw::Socket
[all...] |
| /external/webrtc/webrtc/base/ |
| ssladapter.h | 23 explicit SSLAdapter(AsyncSocket* socket)
24 : AsyncSocketAdapter(socket), ignore_bad_cert_(false) { }
33 // If StartSSL is called while the socket is closed or connecting, the SSL
34 // negotiation will begin as soon as the socket connects.
38 // and deletes |socket|. Otherwise, the returned SSLAdapter takes ownership
39 // of |socket|.
40 static SSLAdapter* Create(AsyncSocket* socket);
|
| proxyserver.cc | 43 void ProxyServer::OnAcceptEvent(AsyncSocket* socket) {
44 ASSERT(socket != NULL && socket == server_socket_.get());
45 AsyncSocket* int_socket = socket->Accept(NULL);
53 LOG(LS_ERROR) << "Unable to create external socket on proxy accept event";
83 void ProxyBinding::OnConnectRequest(AsyncProxyServerSocket* socket,
90 void ProxyBinding::OnInternalRead(AsyncSocket* socket) {
95 void ProxyBinding::OnInternalWrite(AsyncSocket* socket) {
99 void ProxyBinding::OnInternalClose(AsyncSocket* socket, int err) {
103 void ProxyBinding::OnExternalConnect(AsyncSocket* socket) {
[all...] |
| /system/netd/server/dns/ |
| DnsTlsSocketFactory.h | 38 auto socket = std::make_unique<DnsTlsSocket>(server, mark, observer, cache); variable
39 if (!socket->initialize()) {
42 return std::move(socket);
|
| /bionic/libc/bionic/ |
| accept.cpp | 17 #include <sys/socket.h>
|
| connect.cpp | 19 #include <sys/socket.h>
|
| /bionic/libc/kernel/uapi/linux/ |
| un.h | 21 #include <linux/socket.h>
|
| /external/kernel-headers/original/uapi/linux/ |
| un.h | 5 #include <linux/socket.h>
14 #define SIOCUNIXFILE (SIOCPROTOPRIVATE + 0) /* open a socket file with O_PATH */
|
| /external/libpcap/config/ |
| have_siocglifconf.c | 2 #include <sys/socket.h>
|
| /external/strace/tests/ |
| shutdown.c | 5 #include <sys/socket.h>
|
| /external/strace/tests-m32/ |
| shutdown.c | 5 #include <sys/socket.h>
|
| /external/strace/tests-mx32/ |
| shutdown.c | 5 #include <sys/socket.h>
|
| /prebuilts/gcc/linux-x86/host/x86_64-linux-glibc2.15-4.8/sysroot/usr/include/linux/ |
| un.h | 4 #include <linux/socket.h>
|
| /prebuilts/gcc/linux-x86/host/x86_64-linux-glibc2.15-4.8/sysroot/usr/include/netatalk/ |
| at.h | 26 #include <sys/socket.h>
|
| /device/google/cuttlefish_common/guest/libs/remoter/ |
| remoter_framework_pkt.h | 133 const cvd::SharedFD& socket,
139 if ((len = socket->Read(request, sizeof(request->length))) < 0) {
141 __FUNCTION__, socket->StrError());
157 if ((len = socket->Read(cursor, remaining_data)) < 0) {
159 __FUNCTION__, socket->StrError());
171 int socket, struct remoter_response_packet* response) {
177 ALOGI("remoter_read_response(): socket %d, length length = %d", socket,
181 read(socket, response, sizeof(response->length)))) < 0) {
200 ALOGI("remoter_read_request(): socket %d, data length = %d"
272 int socket; local
[all...] |
| /external/autotest/client/cros/netprotos/ |
| interface_host.py | 6 import socket
29 """Close the underlying socket."""
34 def socket(self, family, sock_type): member in class:InterfaceHost
35 """Get a socket bound to this interface.
39 @param family: must be socket.AF_INET.
40 @param sock_type: must be socket.SOCK_DGRAM.
43 if family != socket.AF_INET or sock_type != socket.SOCK_DGRAM:
47 'multicast socket.')
54 """Handle traffic from our socket until |predicate|() is true
[all...] |
| /external/okhttp/okhttp-tests/src/test/java/com/squareup/okhttp/internal/ |
| ConnectionSpecSelectorTest.java | 48 SSLSocket socket = createSocketWithEnabledProtocols(TlsVersion.TLS_1_1, TlsVersion.TLS_1_0); local
49 connectionSpecSelector.configureSecureSocket(socket);
54 socket.close();
61 SSLSocket socket = createSocketWithEnabledProtocols(TlsVersion.TLS_1_1, TlsVersion.TLS_1_0); local
62 connectionSpecSelector.configureSecureSocket(socket);
69 socket.close();
76 SSLSocket socket = createSocketWithEnabledProtocols(TlsVersion.TLS_1_1, TlsVersion.TLS_1_0); local
77 connectionSpecSelector.configureSecureSocket(socket);
81 socket.close();
95 SSLSocket socket = createSocketWithEnabledProtocols(enabledSocketTlsVersions) local
123 SSLSocket socket = (SSLSocket) sslContext.getSocketFactory().createSocket(); local
[all...] |
| /cts/suite/audio_quality/lib/include/audio/ |
| AudioProtocol.h | 74 * @param socket socket to read
79 static bool handleReplyHeader(ClientSocket& socket, uint32_t* data, CommandId& id);
82 AudioProtocol(ClientSocket& socket, uint32_t command)
84 mSocket(socket) {};
105 explicit CmdDownload(ClientSocket& socket)
106 : AudioProtocol(socket, ECmdDownload) {};
114 explicit CmdStartPlayback(ClientSocket& socket)
115 : AudioProtocol(socket, ECmdStartPlayback) {};
122 explicit CmdStopPlayback(ClientSocket& socket)
[all...] |
| /external/webrtc/webrtc/p2p/base/ |
| testrelayserver.h | 57 rtc::AsyncSocket* socket = local
59 socket->Bind(addr);
60 socket->Listen(5);
61 socket->SignalReadEvent.connect(this, &TestRelayServer::OnAccept);
62 return socket;
64 void OnAccept(rtc::AsyncSocket* socket) {
65 bool external = (socket == tcp_ext_socket_.get() ||
66 socket == ssl_ext_socket_.get());
67 bool ssl = (socket == ssl_int_socket_.get() ||
68 socket == ssl_ext_socket_.get())
[all...] |
| /external/autotest/server/cros/network/rf_switch/ |
| scpi.py | 17 import socket
58 # Open a socket connection for communication with chassis.
60 self.socket = socket.socket()
61 self.socket.connect((host, port))
62 except (socket.error, socket.timeout) as e:
68 if hasattr(self, 'socket'):
69 self.socket.close(
[all...] |
| /external/caliper/caliper/src/main/java/com/google/caliper/bridge/ |
| OpenedSocket.java | 28 import java.net.Socket;
32 * A simple tuple for the opened streams of a socket.
38 public static OpenedSocket fromSocket(SocketChannel socket) throws IOException {
39 socket.configureBlocking(true);
40 socket.finishConnect();
41 return fromSocket(socket.socket());
44 * Returns a new {@link OpenedSocket} for the given connected {@link Socket} instance.
46 public static OpenedSocket fromSocket(Socket socket) throws IOException
[all...] |
| /bionic/libc/private/ |
| NetdClientDispatch.h | 21 #include <sys/socket.h>
28 int (*socket)(int, int, int); member in struct:NetdClientDispatch
|
| /device/linaro/bootloader/edk2/AppPkg/Applications/Python/Python-2.7.2/Demo/sockets/ |
| broadcast.py | 6 from socket import *
8 s = socket(AF_INET, SOCK_DGRAM)
|
| radio.py | 6 from socket import *
8 s = socket(AF_INET, SOCK_DGRAM)
|
