| /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;
|
| /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...] |
| /libcore/benchmarks/src/benchmarks/regression/ |
| SSLLoopbackBenchmark.java | 30 SSLSocket[] sockets = TestSSLSocketPair.connect(context, null, null); local
32 sockets[0].close();
33 sockets[1].close();
|
| /hardware/qcom/display/msm8909/sdm/libs/hwc/ |
| hwc_socket_handler.cpp | 30 #include <cutils/sockets.h>
|
| /hardware/qcom/display/msm8909w_3100/sdm/libs/hwc/ |
| hwc_socket_handler.cpp | 30 #include <cutils/sockets.h>
|
| /hardware/qcom/display/msm8998/sdm/libs/hwc2/ |
| hwc_socket_handler.cpp | 30 #include <cutils/sockets.h>
|
| /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...] |
| /system/core/libcutils/ |
| sockets.cpp | 32 #include <cutils/sockets.h>
|
| socket_inaddr_any_server_unix.cpp | 17 #include <cutils/sockets.h>
|
| socket_inaddr_any_server_windows.cpp | 29 #include <cutils/sockets.h>
|
| socket_network_client_windows.cpp | 29 #include <cutils/sockets.h>
|
| /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...] |
| /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...] |
| /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.
|
| /system/bt/osi/src/socket_utils/ |
| README | 18 implement some of the sources in libcutils / sockets to provide a short -
25 sockets,
27 .The developers who want to pull sockets sources other than the
34 osi / include / socket_utils / sockets.h -
|
| /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/autotest/client/site_tests/network_FirewallHolePunch/src/tcpserver/ |
| tcp-server.js | 24 var socket = chrome.sockets.tcpServer;
50 // Sockets open
174 chrome.sockets.tcp.send(socketId, arrayBuffer,
176 chrome.sockets.tcp.close(socketId);
212 chrome.sockets.tcp.getInfo(this.socketId,
227 chrome.sockets.tcp.onReceive.addListener(this._onReceive);
228 chrome.sockets.tcp.onReceiveError.addListener(this._onReceiveError);
230 chrome.sockets.tcp.setPaused(this.socketId, false);
257 chrome.sockets.tcp.send(this.socketId, arrayBuffer, this._onWriteComplete.bind(this));
272 chrome.sockets.tcp.onReceive.removeListener(this._onReceive)
[all...] |
| /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);
|
| /external/wpa_supplicant_8/hostapd/ |
| hostapd.android.rc | 12 mkdir /data/vendor/wifi/hostapd/sockets 0770 wifi wifi
|
| /prebuilts/go/darwin-x86/src/net/internal/socktest/ |
| switch.go | 22 sotab Sockets
28 sw.sotab = make(Sockets)
44 // Sockets returns mappings of socket descriptor to socket status.
45 func (sw *Switch) Sockets() Sockets {
47 tab := make(Sockets, len(sw.sotab))
89 Opened uint64 // number of sockets opened
90 Connected uint64 // number of sockets connected
91 Listened uint64 // number of sockets listened
92 Accepted uint64 // number of sockets accepte
[all...] |
| /prebuilts/go/linux-x86/src/net/internal/socktest/ |
| switch.go | 22 sotab Sockets
28 sw.sotab = make(Sockets)
44 // Sockets returns mappings of socket descriptor to socket status.
45 func (sw *Switch) Sockets() Sockets {
47 tab := make(Sockets, len(sw.sotab))
89 Opened uint64 // number of sockets opened
90 Connected uint64 // number of sockets connected
91 Listened uint64 // number of sockets listened
92 Accepted uint64 // number of sockets accepte
[all...] |
| /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...] |
| /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/ltp/testcases/network/ |
| Makefile | 39 FILTER_OUT_DIRS += lib6 rpc sockets
|
