| /libcore/benchmarks/src/benchmarks/regression/ |
| SSLLoopbackBenchmark.java | 30 SSLSocket[] sockets = TestSSLSocketPair.connect(context, null, null); local
32 sockets[0].close();
33 sockets[1].close();
|
| /bootable/recovery/minadbd/ |
| fuse_adb_provider_test.cpp | 31 int sockets[2]; local
33 ASSERT_EQ(0, socketpair(AF_UNIX, SOCK_STREAM, 0, sockets));
34 data.sfd = sockets[0];
36 int host_socket = sockets[1];
69 close(sockets[0]);
70 close(sockets[1]);
75 int sockets[2]; local
77 ASSERT_EQ(0, socketpair(AF_UNIX, SOCK_STREAM, 0, sockets));
78 data.sfd = sockets[0];
80 ASSERT_EQ(0, close(sockets[1]))
[all...] |
| /external/swiftshader/src/Common/ |
| Socket.cpp | 72 fd_set sockets; local
73 FD_ZERO(&sockets);
74 FD_SET(socket, &sockets);
78 return ::select(FD_SETSIZE, &sockets, 0, 0, &timeout) >= 1;
|
| /external/webrtc/webrtc/base/ |
| macsocketserver.h | 49 const std::set<MacAsyncSocket*>& sockets() { function in class:rtc::MacBaseSocketServer
|
| /external/webrtc/webrtc/examples/peerconnection/server/ |
| main.cc | 79 SocketArray sockets; local
87 for (SocketArray::iterator i = sockets.begin(); i != sockets.end(); ++i)
96 for (SocketArray::iterator i = sockets.begin(); i != sockets.end(); ++i) {
148 i = sockets.erase(i);
149 if (i == sockets.end())
158 if (sockets.size() >= kMaxConnections) {
162 sockets.push_back(s);
168 for (SocketArray::iterator i = sockets.begin(); i != sockets.end(); ++i
[all...] |
| /frameworks/native/libs/sensor/ |
| BitTube.cpp | 69 int sockets[2]; local
70 if (socketpair(AF_UNIX, SOCK_SEQPACKET, 0, sockets) == 0) {
72 setsockopt(sockets[0], SOL_SOCKET, SO_RCVBUF, &rcvbuf, sizeof(rcvbuf));
73 setsockopt(sockets[1], SOL_SOCKET, SO_SNDBUF, &sndbuf, sizeof(sndbuf));
75 setsockopt(sockets[0], SOL_SOCKET, SO_SNDBUF, &size, sizeof(size));
76 setsockopt(sockets[1], SOL_SOCKET, SO_RCVBUF, &size, sizeof(size));
77 fcntl(sockets[0], F_SETFL, O_NONBLOCK);
78 fcntl(sockets[1], F_SETFL, O_NONBLOCK);
79 mReceiveFd = sockets[0];
80 mSendFd = sockets[1]
[all...] |
| /system/core/adb/ |
| sysdeps_test.cpp | 178 std::vector<int> sockets; local
180 sockets.resize(num_sockets * 2);
182 ASSERT_EQ(0, adb_socketpair(&sockets[i * 2])) << strerror(errno);
183 ASSERT_TRUE(WriteFdExactly(sockets[i * 2], &i, sizeof(i)));
186 pfd.fd = sockets[i * 2 + 1];
199 for (int fd : sockets) {
|
| shell_service.cpp | 129 int sockets[2]; local
130 if (adb_socketpair(sockets) < 0) {
134 fd1->reset(sockets[0]);
135 fd2->reset(sockets[1]);
|
| sysdeps_win32.cpp | 35 #include <cutils/sockets.h>
499 // non-blocking sockets can cause an error code of WSAEWOULDBLOCK and
530 std::vector<WSAPOLLFD> sockets; local
543 sockets.push_back(wsapollfd);
548 if (sockets.empty()) {
552 int result = WSAPoll(sockets.data(), sockets.size(), timeout);
559 for (size_t i = 0; i < sockets.size(); ++i) {
560 original[i]->revents = sockets[i].revents;
[all...] |
| /frameworks/native/libs/gui/ |
| BitTube.cpp | 48 int sockets[2]; local
49 if (socketpair(AF_UNIX, SOCK_SEQPACKET, 0, sockets) == 0) {
51 setsockopt(sockets[0], SOL_SOCKET, SO_RCVBUF, &rcvbuf, sizeof(rcvbuf));
52 setsockopt(sockets[1], SOL_SOCKET, SO_SNDBUF, &sndbuf, sizeof(sndbuf));
54 setsockopt(sockets[0], SOL_SOCKET, SO_SNDBUF, &size, sizeof(size));
55 setsockopt(sockets[1], SOL_SOCKET, SO_RCVBUF, &size, sizeof(size));
56 fcntl(sockets[0], F_SETFL, O_NONBLOCK);
57 fcntl(sockets[1], F_SETFL, O_NONBLOCK);
58 mReceiveFd.reset(sockets[0]);
59 mSendFd.reset(sockets[1])
[all...] |
| /external/conscrypt/testing/src/main/java/org/conscrypt/javax/net/ssl/ |
| TestSSLSocketPair.java | 50 public SSLSocket[] sockets() { method in class:TestSSLSocketPair
|
| /external/testng/src/main/java/org/testng/remote/adapter/ |
| DefaultMastertAdapter.java | 45 Socket[] sockets = new Socket[m_hosts.length];
local
50 sockets[i] = new Socket(s[0], Integer.parseInt(s[1]));
63 m_slavePool.addSlaves(sockets);
|
| /libcore/support/src/test/java/libcore/javax/net/ssl/ |
| TestSSLSocketPair.java | 60 SSLSocket[] sockets = connect(c, null, null); local
61 return new TestSSLSocketPair(c, sockets[0], sockets[1]);
|
| /external/curl/tests/libtest/ |
| lib582.c | 32 struct Sockets
34 curl_socket_t *sockets; member in struct:Sockets
35 int count; /* number of sockets actually stored in array */
36 int max_count; /* max number of sockets that fit in allocated array */
41 struct Sockets read, write;
45 * Remove a file descriptor from a sockets array.
47 static void removeFd(struct Sockets* sockets, curl_socket_t fd, int mention)
54 for(i = 0; i < sockets->count; ++i) {
55 if(sockets->sockets[i] == fd)
108 struct ReadWriteSockets* sockets = userp; local
233 struct ReadWriteSockets sockets = {{NULL, 0, 0}, {NULL, 0, 0}}; local
[all...] |
| libntlmconnect.c | 36 static curl_socket_t sockets[MAX_EASY_HANDLES]; variable
66 if(sockets[idx] == CURL_SOCKET_BAD) {
68 sockets[idx] = sock;
70 else if(sock != sockets[idx]) {
74 curlx_sztosi(idx), (int)sockets[idx], (int)sock);
107 sockets[i] = CURL_SOCKET_BAD;
|
| /packages/apps/Bluetooth/src/com/android/bluetooth/ |
| ObexServerSockets.java | 31 * Create an instance using {@link #create()}, which will block until the sockets have been created
54 /* The wrapped sockets */
170 Log.d(STAG, "Succeed to create listening sockets ");
172 ObexServerSockets sockets = new ObexServerSockets(validator, rfcommSocket, l2capSocket); local
173 sockets.startAccept();
174 return sockets;
385 // sockets - and that is true, but it closes the l2cap connections, and
386 // therefore it implicitly also closes the accepted sockets...
|
| /libcore/luni/src/test/java/libcore/java/io/ |
| InterruptedStreamTest.java | 47 private Socket[] sockets; field in class:InterruptedStreamTest
57 if (sockets != null) {
58 sockets[0].close();
59 sockets[1].close();
98 sockets = newSocketChannelPair();
99 testInterruptReadableChannel(sockets[0].getChannel());
103 sockets = newSocketChannelPair();
104 testInterruptWritableChannel(sockets[0].getChannel());
108 * Returns a pair of connected sockets backed by NIO socket channels.
|
| /external/libevent/ |
| http-internal.h | 142 TAILQ_HEAD(boundq, evhttp_bound_socket) sockets; member in struct:evhttp
|
| /external/syslinux/core/lwip/src/api/ |
| sockets.c | 3 * Sockets BSD-Like API module
45 #include "lwip/sockets.h"
65 /** sockets currently are built on netconns, each socket has one netconn */
125 /** The global array of available sockets */
126 static struct lwip_sock sockets[NUM_SOCKETS]; variable in typeref:struct:lwip_sock
205 sock = &sockets[s];
228 if (!sockets[s].conn) {
231 return &sockets[s];
252 if (!sockets[i].conn) {
253 sockets[i].conn = newconn
[all...] |
| /frameworks/native/libs/input/ |
| InputTransport.cpp | 125 int sockets[2]; local
126 if (socketpair(AF_UNIX, SOCK_SEQPACKET, 0, sockets)) {
136 setsockopt(sockets[0], SOL_SOCKET, SO_SNDBUF, &bufferSize, sizeof(bufferSize));
137 setsockopt(sockets[0], SOL_SOCKET, SO_RCVBUF, &bufferSize, sizeof(bufferSize));
138 setsockopt(sockets[1], SOL_SOCKET, SO_SNDBUF, &bufferSize, sizeof(bufferSize));
139 setsockopt(sockets[1], SOL_SOCKET, SO_RCVBUF, &bufferSize, sizeof(bufferSize));
143 outServerChannel = new InputChannel(serverChannelName, sockets[0]);
147 outClientChannel = new InputChannel(clientChannelName, sockets[1]);
[all...] |
| /packages/apps/Bluetooth/src/com/android/bluetooth/map/ |
| BluetoothMapMasInstance.java | 262 * Start Obex Server Sockets and create the SDP record.
436 ObexServerSockets sockets = mServerSockets; local
437 if (sockets != null) {
438 sockets.shutdown(block);
|
| /cts/tests/tests/net/src/android/net/cts/ |
| IpSecBaseTest.java | 200 // Fail loudly if we can't set up sockets properly. And without the timeout, we
253 // Fail loudly if we can't set up sockets properly. And without the timeout, we
458 SocketPair<JavaTcpSocket> sockets = getJavaTcpSocketPair(local, mISM, transform); local
459 checkSocketPair(sockets.mLeftSock, sockets.mRightSock);
468 SocketPair<JavaUdpSocket> sockets = local
470 checkSocketPair(sockets.mLeftSock, sockets.mRightSock);
479 SocketPair<JavaUdpSocket> sockets = local
481 checkUnconnectedUdpSocketPair(sockets.mLeftSock, sockets.mRightSock, local)
490 SocketPair<NativeTcpSocket> sockets = local
501 SocketPair<NativeUdpSocket> sockets = local
512 SocketPair<NativeUdpSocket> sockets = local
[all...] |
| IpSecManagerTest.java | 151 SocketPair<JavaUdpSocket> sockets = getJavaUdpSocketPair(local, mISM, transform, false); local
152 sockLeft = sockets.mLeftSock;
153 sockRight = sockets.mRightSock;
155 SocketPair<NativeUdpSocket> sockets = local
157 sockLeft = sockets.mLeftSock;
158 sockRight = sockets.mRightSock;
181 SocketPair<JavaTcpSocket> sockets = getJavaTcpSocketPair(local, mISM, transform); local
182 client = sockets.mLeftSock;
183 accepted = sockets.mRightSock;
185 SocketPair<NativeTcpSocket> sockets = getNativeTcpSocketPair(local, mISM, transform) local
[all...] |
| /external/conscrypt/openjdk-integ-tests/src/test/java/org/conscrypt/javax/net/ssl/ |
| SSLSocketTest.java | 2242 final Socket[] sockets = new Socket[2]; local
[all...] |
| /external/curl/lib/ |
| urldata.h | 1725 curl_socket_t sockets[MAX_SOCKSPEREASYHANDLE]; member in struct:Curl_easy
[all...] |
