| /external/curl/tests/libtest/ |
| D | lib582.c | 34 curl_socket_t *sockets; member
47 static void removeFd(struct Sockets *sockets, curl_socket_t fd, int mention) in removeFd() argument
54 for(i = 0; i < sockets->count; ++i) { in removeFd()
55 if(sockets->sockets[i] == fd) { in removeFd()
56 if(i < sockets->count - 1) in removeFd()
57 memmove(&sockets->sockets[i], &sockets->sockets[i + 1], in removeFd()
58 sizeof(curl_socket_t) * (sockets->count - (i + 1))); in removeFd()
59 --sockets->count; in removeFd()
67 static void addFd(struct Sockets *sockets, curl_socket_t fd, const char *what) in addFd() argument
74 removeFd(sockets, fd, 0); in addFd()
[all …]
|
| D | libntlmconnect.c | 36 static curl_socket_t sockets[MAX_EASY_HANDLES]; variable
66 if(sockets[idx] == CURL_SOCKET_BAD) { in callback()
68 sockets[idx] = sock; in callback()
70 else if(sock != sockets[idx]) { in callback()
74 curlx_sztosi(idx), (int)sockets[idx], (int)sock); in callback()
107 sockets[i] = CURL_SOCKET_BAD; in test()
|
| /external/webrtc/examples/peerconnection/server/ |
| D | main.cc | 100 SocketArray sockets; in main() local
108 for (SocketArray::iterator i = sockets.begin(); i != sockets.end(); ++i) in main()
117 for (SocketArray::iterator i = sockets.begin(); i != sockets.end(); ++i) { in main()
168 i = sockets.erase(i); in main()
169 if (i == sockets.end()) in main()
178 if (sockets.size() >= kMaxConnections) { in main()
182 sockets.push_back(s); in main()
188 for (SocketArray::iterator i = sockets.begin(); i != sockets.end(); ++i) in main()
190 sockets.clear(); in main()
|
| /external/autotest/client/site_tests/network_FirewallHolePunch/src/tcpserver/ |
| D | tcp-server.js | 24 var socket = chrome.sockets.tcpServer;
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);
273 chrome.sockets.tcp.onReceiveError.removeListener(this._onReceiveError);
[all …]
|
| /external/openssh/ |
| D | ssh-agent.c | 119 SocketEntry *sockets = NULL; variable
785 e = &sockets[socknum]; in process_message()
883 if (sockets[i].type == AUTH_UNUSED) { in new_socket()
884 sockets[i].fd = fd; in new_socket()
885 if ((sockets[i].input = sshbuf_new()) == NULL) in new_socket()
887 if ((sockets[i].output = sshbuf_new()) == NULL) in new_socket()
889 if ((sockets[i].request = sshbuf_new()) == NULL) in new_socket()
891 sockets[i].type = type; in new_socket()
896 sockets = xreallocarray(sockets, new_alloc, sizeof(sockets[0])); in new_socket()
898 sockets[i].type = AUTH_UNUSED; in new_socket()
[all …]
|
| /external/grpc-grpc/test/cpp/naming/ |
| D | resolver_component_test.cc | 264 std::vector<int> sockets; in OpenAndCloseSocketsStressLoop() local
285 sockets.push_back(s); in OpenAndCloseSocketsStressLoop()
289 for (size_t i = 0; i < sockets.size(); i++) { in OpenAndCloseSocketsStressLoop()
290 gpr_log(GPR_DEBUG, "non-blocking accept then close on %d", sockets[i]); in OpenAndCloseSocketsStressLoop()
291 ASSERT_TRUE(accept(sockets[i], nullptr, nullptr) == INVALID_SOCKET) in OpenAndCloseSocketsStressLoop()
295 std::to_string(sockets[i]) + in OpenAndCloseSocketsStressLoop()
301 ASSERT_TRUE(closesocket(sockets[i]) != SOCKET_ERROR) in OpenAndCloseSocketsStressLoop()
302 << "Failed to close socket: " + std::to_string(sockets[i]) + in OpenAndCloseSocketsStressLoop()
330 std::vector<int> sockets; in OpenAndCloseSocketsStressLoop() local
355 sockets.push_back(s); in OpenAndCloseSocketsStressLoop()
[all …]
|
| /external/ltp/testcases/network/stress/multicast/grp-operation/ |
| D | 00_Descriptions.txt | 7 multicast groups on lots of sockets
11 IPv4 multicast group on multiple sockets lots of times
16 sockets lots of times
24 multicast groups on lots of sockets
28 IPv6 multicast group on multiple sockets lots of times
33 sockets lots of times
|
| /external/swiftshader/src/System/ |
| D | Socket.cpp | 73 fd_set sockets; in select() local
74 FD_ZERO(&sockets); in select()
75 FD_SET(socket, &sockets); in select()
79 return ::select(FD_SETSIZE, &sockets, 0, 0, &timeout) >= 1; in select()
|
| /external/swiftshader/src/Common/ |
| D | Socket.cpp | 72 fd_set sockets; in select() local
73 FD_ZERO(&sockets); in select()
74 FD_SET(socket, &sockets); in select()
78 return ::select(FD_SETSIZE, &sockets, 0, 0, &timeout) >= 1; in select()
|
| /external/python/cpython2/Doc/howto/ |
| D | sockets.rst | 13 misunderstood technologies around. This is a 10,000 foot overview of sockets.
22 I'm only going to talk about INET sockets, but they account for at least 99% of
23 the sockets in use. And I'll only talk about STREAM sockets - unless you really
27 work with blocking and non-blocking sockets. But I'll start by talking about
28 blocking sockets. You'll need to know how they work before dealing with
29 non-blocking sockets.
35 application (your browser, for example) uses "client" sockets exclusively; the
36 web server it's talking to uses both "server" sockets and "client" sockets.
43 sockets are by far the most popular. On any given platform, there are
45 cross-platform communication, sockets are about the only game in town.
[all …]
|
| /external/python/cpython3/Doc/howto/ |
| D | sockets.rst | 13 misunderstood technologies around. This is a 10,000 foot overview of sockets.
22 I'm only going to talk about INET (i.e. IPv4) sockets, but they account for at least 99% of
23 the sockets in use. And I'll only talk about STREAM (i.e. TCP) sockets - unless you really
27 work with blocking and non-blocking sockets. But I'll start by talking about
28 blocking sockets. You'll need to know how they work before dealing with
29 non-blocking sockets.
35 application (your browser, for example) uses "client" sockets exclusively; the
36 web server it's talking to uses both "server" sockets and "client" sockets.
43 sockets are by far the most popular. On any given platform, there are
45 cross-platform communication, sockets are about the only game in town.
[all …]
|
| /external/llvm-project/lldb/tools/debugserver/source/ |
| D | RNBSocket.cpp | 89 std::map<int, lldb_private::SocketAddress> sockets; in Listen() local
130 sockets[sock_fd] = address; in Listen()
133 if (sockets.size() == 0) { in Listen()
143 events.resize(sockets.size()); in Listen()
145 for (auto socket : sockets) { in Listen()
165 auto socket_pair = sockets.find(sock_fd); in Listen()
166 if (socket_pair == sockets.end()) in Listen()
202 for (auto socket : sockets) { in Listen()
|
| /external/conscrypt/testing/src/main/java/org/conscrypt/tlswire/ |
| D | TlsTester.java | 78 final Socket[] sockets = new Socket[2]; in captureTlsHandshakeFirstTransmittedChunkBytes() local
89 sockets[1] = socket; in captureTlsHandshakeFirstTransmittedChunkBytes()
108 sockets[0] = client; in captureTlsHandshakeFirstTransmittedChunkBytes()
133 closeQuietly(sockets[0]); in captureTlsHandshakeFirstTransmittedChunkBytes()
134 closeQuietly(sockets[1]); in captureTlsHandshakeFirstTransmittedChunkBytes()
|
| /external/openscreen/osp/impl/discovery/mdns/ |
| D | mdns_demo.cc | 131 std::vector<std::unique_ptr<UdpSocket>> sockets; in SetUpMulticastSockets() local
147 sockets.emplace_back(std::move(socket)); in SetUpMulticastSockets()
149 return sockets; in SetUpMulticastSockets()
280 auto sockets = SetUpMulticastSockets(task_runner, index_list, &client); in BrowseDemo() local
284 OSP_CHECK_EQ(sockets.size(), index_list.size()); in BrowseDemo()
287 auto socket_it = sockets.begin(); in BrowseDemo()
306 for (const std::unique_ptr<UdpSocket>& socket : sockets) { in BrowseDemo()
330 for (const std::unique_ptr<UdpSocket>& socket : sockets) { in BrowseDemo()
|
| /external/conscrypt/repackaged/testing/src/main/java/com/android/org/conscrypt/tlswire/ |
| D | TlsTester.java | 82 final Socket[] sockets = new Socket[2]; in captureTlsHandshakeFirstTransmittedChunkBytes() local
93 sockets[1] = socket; in captureTlsHandshakeFirstTransmittedChunkBytes()
112 sockets[0] = client; in captureTlsHandshakeFirstTransmittedChunkBytes()
137 closeQuietly(sockets[0]); in captureTlsHandshakeFirstTransmittedChunkBytes()
138 closeQuietly(sockets[1]); in captureTlsHandshakeFirstTransmittedChunkBytes()
|
| /external/libcap/doc/values/ |
| D | 12.txt | 6 - setting debug options on sockets
9 ownership on sockets
17 - activation of ATM control sockets
|
| D | 13.txt | 2 - RAW sockets
3 - PACKET sockets
|
| /external/grpc-grpc-java/core/src/main/java/io/grpc/ |
| D | InternalChannelz.java | 275 public final List<InternalWithLogId> sockets; field in InternalChannelz.ServerSocketsList
279 public ServerSocketsList(List<InternalWithLogId> sockets, boolean end) { in ServerSocketsList() argument
280 this.sockets = sockets; in ServerSocketsList()
371 public final List<InternalWithLogId> sockets; field in InternalChannelz.ChannelStats
385 List<InternalWithLogId> sockets) { in ChannelStats() argument
387 subchannels.isEmpty() || sockets.isEmpty(), in ChannelStats()
398 this.sockets = checkNotNull(sockets); in ChannelStats()
410 private List<InternalWithLogId> sockets = Collections.emptyList(); field in InternalChannelz.ChannelStats.Builder
449 checkState(sockets.isEmpty()); in setSubchannels()
455 public Builder setSockets(List<InternalWithLogId> sockets) { in setSockets() argument
[all …]
|
| /external/iptables/extensions/ |
| D | libxt_socket.man | 8 Ignore non-transparent sockets.
11 Do not ignore sockets bound to 'any' address.
26 \fB\-\-transparent\fP and \fB\-\-nowildcard\fP options to restrict the sockets
29 Example: An application opens 2 transparent (\fBIP_TRANSPARENT\fP) sockets and
|
| /external/testng/src/main/java/org/testng/remote/adapter/ |
| D | DefaultMastertAdapter.java | 45 Socket[] sockets = new Socket[m_hosts.length]; in init() local
50 sockets[i] = new Socket(s[0], Integer.parseInt(s[1])); in init()
63 m_slavePool.addSlaves(sockets); in init()
|
| /external/libwebsockets/minimal-examples/raw/minimal-raw-vhost/ |
| D | README.md | 3 This demonstrates setting up a vhost to listen and accept raw sockets.
4 Raw sockets are just sockets... lws does not send anything on them or
|
| /external/curl/tests/ |
| D | memanalyze.pl | 38 my $sockets=0;
264 $sockets++; # number of socket() calls
420 "Sockets: $sockets\n",
422 …tions: ".($mallocs + $callocs + $reallocs + $strdups + $wcsdups + $sends + $recvs + $sockets)."\n";
|
| /external/scapy/test/ |
| D | sendsniff.uts | 7 + Test bridge_and_sniff() using tap sockets
34 = Run a bridge_and_sniff thread between the taps **sockets**
59 = Run a bridge_and_sniff thread between the taps **sockets**
89 + Test bridge_and_sniff() using tun sockets
116 = Run a bridge_and_sniff thread between the tuns **sockets**
143 = Run a bridge_and_sniff thread between the tuns **sockets**
|
| /external/curl/tests/data/ |
| D | test1435 | 6 unix sockets
22 unix-sockets
|
| /external/conscrypt/common/src/test/java/org/conscrypt/javax/net/ssl/ |
| D | SSLSessionContextTest.java | 250 TestSSLSocketPair.create(c).connect(new String[] {cipherSuite1}, null).sockets()); in test_SSLSessionContext_setSessionCacheSize_dynamic()
257 TestSSLSocketPair.create(c).connect(new String[] {cipherSuite2}, null).sockets()); in test_SSLSessionContext_setSessionCacheSize_dynamic()
264 TestSSLSocketPair.create(c).connect(new String[] {cipherSuite3}, null).sockets()); in test_SSLSessionContext_setSessionCacheSize_dynamic()
277 TestSSLSocketPair.create(c).connect(new String[] {cipherSuite1}, null).sockets()); in test_SSLSessionContext_setSessionCacheSize_dynamic()
283 TestSSLSocketPair.create(c).connect(new String[] {cipherSuite2}, null).sockets()); in test_SSLSessionContext_setSessionCacheSize_dynamic()
286 TestSSLSocketPair.create(c).connect(new String[] {cipherSuite3}, null).sockets()); in test_SSLSessionContext_setSessionCacheSize_dynamic()
|