| /external/python/cpython3/Lib/multiprocessing/ |
| reduction.py | 16 import socket
25 (hasattr(socket, 'CMSG_LEN') and
26 hasattr(socket, 'SCM_RIGHTS') and
27 hasattr(socket.socket, 'sendmsg')))
142 '''Send an array of fds over an AF_UNIX socket.'''
145 sock.sendmsg([msg], [(socket.SOL_SOCKET, socket.SCM_RIGHTS, fds)])
150 '''Receive an array of fds over an AF_UNIX socket.'''
153 msg, ancdata, flags, addr = sock.recvmsg(1, socket.CMSG_LEN(bytes_size)
[all...] |
| /external/strace/tests/ |
| scm_rights-fd.test | 55 socket='<socket:\[[0-9]+\]>'
68 sendmsg\\(3$socket, $msg_head\\[$rights\\]$msg_tail\\}, 0\\) = 15
69 recvmsg\\(0$socket, $msg_head\\[$creds, $rights\\]$msg_tail\\}, 0\\) = 15
|
| getpeername.c | 36 int lfd = socket(AF_UNIX, SOCK_STREAM, 0);
37 int cfd = socket(AF_UNIX, SOCK_STREAM, 0);
39 perror_msg_and_skip("socket");
|
| /external/strace/tests-m32/ |
| scm_rights-fd.test | 55 socket='<socket:\[[0-9]+\]>'
68 sendmsg\\(3$socket, $msg_head\\[$rights\\]$msg_tail\\}, 0\\) = 15
69 recvmsg\\(0$socket, $msg_head\\[$creds, $rights\\]$msg_tail\\}, 0\\) = 15
|
| getpeername.c | 36 int lfd = socket(AF_UNIX, SOCK_STREAM, 0);
37 int cfd = socket(AF_UNIX, SOCK_STREAM, 0);
39 perror_msg_and_skip("socket");
|
| /external/strace/tests-mx32/ |
| scm_rights-fd.test | 55 socket='<socket:\[[0-9]+\]>'
68 sendmsg\\(3$socket, $msg_head\\[$rights\\]$msg_tail\\}, 0\\) = 15
69 recvmsg\\(0$socket, $msg_head\\[$creds, $rights\\]$msg_tail\\}, 0\\) = 15
|
| getpeername.c | 36 int lfd = socket(AF_UNIX, SOCK_STREAM, 0);
37 int cfd = socket(AF_UNIX, SOCK_STREAM, 0);
39 perror_msg_and_skip("socket");
|
| /external/webrtc/webrtc/base/ |
| asyncsocket.h | 16 #include "webrtc/base/socket.h"
20 // TODO: Remove Socket and rename AsyncSocket to Socket.
22 // Provides the ability to perform socket I/O asynchronously.
23 class AsyncSocket : public Socket {
46 // The adapted socket may explicitly be NULL, and later assigned using Attach.
50 explicit AsyncSocketAdapter(AsyncSocket* socket);
52 void Attach(AsyncSocket* socket);
72 virtual void OnConnectEvent(AsyncSocket* socket);
73 virtual void OnReadEvent(AsyncSocket* socket);
[all...] |
| asyncsocket.cc | 21 AsyncSocketAdapter::AsyncSocketAdapter(AsyncSocket* socket) : socket_(NULL) {
22 Attach(socket);
29 void AsyncSocketAdapter::Attach(AsyncSocket* socket) {
31 socket_ = socket;
111 void AsyncSocketAdapter::OnConnectEvent(AsyncSocket* socket) {
115 void AsyncSocketAdapter::OnReadEvent(AsyncSocket* socket) {
119 void AsyncSocketAdapter::OnWriteEvent(AsyncSocket* socket) {
123 void AsyncSocketAdapter::OnCloseEvent(AsyncSocket* socket, int err) {
|
| /external/webrtc/webrtc/examples/peerconnection/server/ |
| data_socket.h | 18 typedef SOCKET NativeSocket;
22 #include <sys/socket.h>
40 explicit SocketBase(NativeSocket socket) : socket_(socket) { }
43 NativeSocket socket() const { return socket_; } function in class:SocketBase
53 // Represents an HTTP server socket.
63 explicit DataSocket(NativeSocket socket)
64 : SocketBase(socket),
118 // Clears all held state and prepares the socket for receiving a new request.
143 // The server socket. Accepts connections and generates DataSocket instance
[all...] |
| /frameworks/base/core/java/android/net/ |
| Network.java | 37 import java.net.Socket;
53 * It is used to direct traffic to the given {@code Network}, either on a {@link Socket} basis
169 * A {@code SocketFactory} that produces {@code Socket}'s bound to this network.
179 private Socket connectToHost(String host, int port, SocketAddress localAddress)
186 Socket socket = createSocket(); local
189 if (localAddress != null) socket.bind(localAddress);
190 socket.connect(new InetSocketAddress(hostAddresses[i], port));
192 return socket;
194 if (failed) IoUtils.closeQuietly(socket);
211 Socket socket = createSocket(); local
225 Socket socket = createSocket(); local
243 Socket socket = new Socket(); local
[all...] |
| /prebuilts/go/darwin-x86/src/runtime/ |
| stubs_android.go | 5 // Return values of access/connect/socket are the return values of the syscall
15 // int socket(int, int, int)
16 func socket(domain int32, typ int32, prot int32) int32 func
|
| /prebuilts/go/linux-x86/src/runtime/ |
| stubs_android.go | 5 // Return values of access/connect/socket are the return values of the syscall
15 // int socket(int, int, int)
16 func socket(domain int32, typ int32, prot int32) int32 func
|
| /device/linaro/bootloader/edk2/AppPkg/Applications/Python/Python-2.7.2/Demo/sockets/ |
| echosvr.py | 8 from socket import *
20 s = socket(AF_INET, SOCK_STREAM)
|
| /external/apache-harmony/support/src/test/java/tests/support/ |
| Support_HttpSocket.java | 23 import java.net.Socket;
30 private final Socket instance;
34 Support_HttpSocket(Socket socket) {
35 instance = socket;
|
| /external/autotest/client/site_tests/kernel_CryptoAPI/src/ |
| crypto_load_mod.c | 6 #include <sys/socket.h>
26 sock = socket(AF_ALG, SOCK_SEQPACKET, 0);
28 perror("socket(AF_ALG)");
|
| /external/ltp/testcases/network/rpc/rpc-tirpc/tests_pack/rpc_suite/rpc/rpc_createdestroy_svctcp_create/ |
| rpc_svctcp_create.c | 33 #include <sys/socket.h>
51 sock = socket(AF_UNIX, SOCK_DGRAM, IPPROTO_TCP);
|
| /external/ltp/testcases/network/rpc/rpc-tirpc/tests_pack/rpc_suite/rpc/rpc_createdestroy_svcudp_bufcreate/ |
| rpc_svcudp_bufcreate.c | 33 #include <sys/socket.h>
56 sock = socket(AF_UNIX, SOCK_SEQPACKET, IPPROTO_UDP);
|
| /external/ltp/testcases/network/rpc/rpc-tirpc/tests_pack/rpc_suite/rpc/rpc_createdestroy_svcudp_create/ |
| rpc_svcudp_create.c | 33 #include <sys/socket.h>
52 sock = socket(AF_UNIX, SOCK_SEQPACKET, IPPROTO_UDP);
|
| /external/okhttp/okhttp-tests/src/test/java/com/squareup/okhttp/ |
| ConnectionPoolTest.java | 24 import java.net.Socket;
56 assertFalse(c1.socket.isClosed());
61 assertFalse(c1.socket.isClosed());
66 assertFalse(c1.socket.isClosed());
71 assertTrue(c1.socket.isClosed());
76 assertTrue(c1.socket.isClosed());
90 assertFalse(c1.socket.isClosed());
95 assertFalse(c1.socket.isClosed());
100 assertFalse(c1.socket.isClosed());
121 assertFalse(c1.socket.isClosed())
[all...] |
| ConnectionSpecTest.java | 87 SSLSocket socket = (SSLSocket) SSLSocketFactory.getDefault().createSocket(); local
88 socket.setEnabledCipherSuites(new String[] {
92 socket.setEnabledProtocols(new String[] {
97 assertTrue(tlsSpec.isCompatible(socket));
98 tlsSpec.apply(socket, false /* isFallback */);
100 assertEquals(set(TlsVersion.TLS_1_2.javaName), set(socket.getEnabledProtocols()));
115 SSLSocket socket = (SSLSocket) SSLSocketFactory.getDefault().createSocket(); local
116 socket.setEnabledCipherSuites(new String[] {
120 socket.setEnabledProtocols(new String[] {
125 assertTrue(tlsSpec.isCompatible(socket));
147 SSLSocket socket = (SSLSocket) SSLSocketFactory.getDefault().createSocket(); local
185 SSLSocket socket = (SSLSocket) SSLSocketFactory.getDefault().createSocket(); local
246 SSLSocket socket = (SSLSocket) SSLSocketFactory.getDefault().createSocket(); local
[all...] |
| /external/python/cpython2/Demo/sockets/ |
| echosvr.py | 8 from socket import *
20 s = socket(AF_INET, SOCK_STREAM)
|
| /external/webrtc/webrtc/test/channel_transport/ |
| udp_socket_wrapper_unittest.cc | 48 // Creates a socket using the static constructor method and verifies that
49 // it's added to the socket manager.
52 // We can't test deletion of sockets without a socket manager.
55 UdpSocketWrapper* socket = local
62 socket->CloseBlocking();
|
| /libcore/luni/src/test/java/libcore/javax/net/ |
| ServerSocketFactoryTest.java | 25 import java.net.Socket;
71 Socket s = serverSocket.accept();
79 Socket socket = new Socket(InetAddress.getLocalHost(), serverSocket.getLocalPort()); local
83 InputStream in = socket.getInputStream();
87 socket.close();
97 List<Socket> backlog = new ArrayList<Socket>();
102 Socket socket = new Socket() local
[all...] |
| /libcore/ojluni/src/main/java/javax/net/ssl/ |
| X509ExtendedTrustManager.java | 28 import java.net.Socket;
65 * If the <code>socket</code> parameter is an instance of
68 * man-in-the-middle attacks, the address that the <code>socket</code>
73 * If the <code>socket</code> parameter is an instance of
78 * algorithm constraints in place on this socket.
82 * @param socket the socket used for this connection. This parameter
97 String authType, Socket socket) throws CertificateException;
113 * If the <code>socket</code> parameter is an instance o
[all...] |
