| /third_party/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()
|
| /third_party/libuv/test/ |
| D | test-watcher-cross-stop.c | 32 static uv_udp_t sockets[1250]; variable
34 static uv_udp_t sockets[2500]; variable
36 static uv_udp_send_t reqs[ARRAY_SIZE(sockets)];
77 TEST_FILE_LIMIT(ARRAY_SIZE(sockets) + 32); in TEST_IMPL()
83 for (i = 0; i < ARRAY_SIZE(sockets); i++) { in TEST_IMPL()
84 ASSERT(0 == uv_udp_init(loop, &sockets[i])); in TEST_IMPL()
85 ASSERT(0 == uv_udp_bind(&sockets[i], in TEST_IMPL()
88 ASSERT(0 == uv_udp_recv_start(&sockets[i], alloc_cb, recv_cb)); in TEST_IMPL()
90 &sockets[i], in TEST_IMPL()
100 for (i = 0; i < ARRAY_SIZE(sockets); i++) in TEST_IMPL()
[all …]
|
| /third_party/libsoup/tests/ |
| D | connection-test.c | 218 SoupSocket **sockets = user_data; in request_started_socket_collector() local
223 if (!sockets[i]) { in request_started_socket_collector()
230 sockets[i] = g_object_ref (socket); in request_started_socket_collector()
242 SoupSocket *sockets[4] = { NULL, NULL, NULL, NULL }; in do_timeout_test_for_session() local
248 &sockets); in do_timeout_test_for_session()
257 if (sockets[1]) { in do_timeout_test_for_session()
258 soup_test_assert (sockets[1] == NULL, "Message was retried"); in do_timeout_test_for_session()
259 sockets[1] = sockets[2] = sockets[3] = NULL; in do_timeout_test_for_session()
274 soup_test_assert (sockets[1] == sockets[0], in do_timeout_test_for_session()
276 soup_test_assert (sockets[2] != NULL, in do_timeout_test_for_session()
[all …]
|
| /third_party/node/lib/ |
| D | _http_agent.js | 91 this.sockets = {};
157 if (this.sockets[name])
158 count += this.sockets[name].length;
192 for (const socket of ObjectValues(this.sockets)) {
244 if (!this.sockets[name]) {
245 this.sockets[name] = []; property
262 const sockLen = freeLen + this.sockets[name].length;
268 this.sockets[name].push(socket);
313 if (!this.sockets[name]) {
314 this.sockets[name] = []; property
[all …]
|
| /third_party/node/deps/npm/node_modules/agentkeepalive/lib/ |
| D | _http_agent.js | 59 self.sockets = {};
100 if (self.sockets[name])
101 count += self.sockets[name].length;
203 if (!this.sockets[name]) {
204 this.sockets[name] = []; property
208 var sockLen = freeLen + this.sockets[name].length;
234 this.sockets[name].push(socket);
277 if (!self.sockets[name]) {
278 self.sockets[name] = [];
280 self.sockets[name].push(s);
[all …]
|
| /third_party/gstreamer/gstplugins_base/tests/check/pipelines/ |
| D | tcp.c | 155 GSocket *sockets[2] = { NULL, NULL }; in setup_multisocketsink_and_socketsrc() local
162 G_SOCKET_TYPE_STREAM, G_SOCKET_PROTOCOL_DEFAULT, sockets, &err)); in setup_multisocketsink_and_socketsrc()
164 g_object_set (st->src, "socket", sockets[0], NULL); in setup_multisocketsink_and_socketsrc()
165 g_object_unref (sockets[0]); in setup_multisocketsink_and_socketsrc()
166 sockets[0] = NULL; in setup_multisocketsink_and_socketsrc()
170 g_signal_emit_by_name (st->sink, "add", sockets[1], NULL); in setup_multisocketsink_and_socketsrc()
171 g_object_unref (sockets[1]); in setup_multisocketsink_and_socketsrc()
172 sockets[1] = NULL; in setup_multisocketsink_and_socketsrc()
247 GSocket *sockets[4] = { NULL, NULL }; in GST_START_TEST() local
257 G_SOCKET_TYPE_STREAM, G_SOCKET_PROTOCOL_DEFAULT, &sockets[0], NULL)); in GST_START_TEST()
[all …]
|
| /third_party/glib/glib/tests/ |
| D | gpoll.c | 39 prepare_fds (SOCKET sockets[], in prepare_fds() argument
48 g_assert (WSAEventSelect (sockets[i], (HANDLE) fds[i].fd, FD_READ | FD_CLOSE) == 0); in prepare_fds()
76 check_fds (SOCKET sockets[], in check_fds() argument
87 g_assert (WSAEnumNetworkEvents (sockets[i], 0, &events) == 0); in check_fds()
115 prepare_sockets (SOCKET sockets[], in prepare_sockets() argument
150 sockets[i] = accept (server, NULL, NULL); in prepare_sockets()
151 g_assert (sockets[i] != INVALID_SOCKET); in prepare_sockets()
152 g_assert (ioctlsocket (sockets[i], FIONBIO, &ul) == 0); in prepare_sockets()
159 cleanup_sockets (SOCKET sockets[], in cleanup_sockets() argument
167 closesocket (sockets[i]); in cleanup_sockets()
[all …]
|
| /third_party/node/test/parallel/ |
| D | test-child-process-fork-getconnections.js | 30 const sockets = []; variable
40 sockets.push(socket);
45 if (sockets[m.id].destroyed) {
51 sockets[m.id].once('close', sendClosed.bind(null, m.id));
52 sockets[m.id].destroy();
68 const sockets = []; variable
72 sockets.push(socket);
74 if (sockets.length === count) {
|
| D | test-http-agent-keepalive.js | 60 assert.strictEqual(agent.sockets[name].length, 1);
71 assert.strictEqual(agent.sockets[name].length, 1);
74 assert.strictEqual(agent.sockets[name], undefined);
89 assert.strictEqual(agent.sockets[name].length, 1);
92 assert.strictEqual(agent.sockets[name], undefined);
96 assert.strictEqual(agent.sockets[name], undefined);
111 assert.strictEqual(agent.sockets[name].length, 1);
115 assert.strictEqual(agent.sockets[name], undefined);
130 assert.strictEqual(agent.sockets[name].length, 1);
133 assert.strictEqual(agent.sockets[name], undefined);
|
| D | test-net-server-close.js | 28 const sockets = []; variable
44 sockets.push(c);
46 if (sockets.length === 2) {
48 sockets.forEach(function(c) { c.destroy(); });
|
| D | test-http-abort-queued.js | 44 assert.strictEqual(Object.keys(agent.sockets).length, 0);
56 assert.strictEqual(Object.keys(agent.sockets).length, 1);
66 assert.strictEqual(Object.keys(agent.sockets).length, 1);
79 assert.strictEqual(Object.keys(agent.sockets).length, 1);
86 assert.strictEqual(Object.keys(agent.sockets).length, 0);
|
| D | test-http-agent-maxsockets-respected.js | 49 const sockets = agent.sockets[Object.keys(agent.sockets)[0]]; constant
50 assert(sockets.length <= MAX_SOCKETS);
|
| D | test-http-client-timeout-option-listeners.js | 38 const sockets = agent.sockets[`${options.host}:${options.port}:`];
39 assert.strictEqual(sockets.length, 1);
40 const socket = sockets[0];
|
| D | test-http-keep-alive.js | 44 assert.strictEqual(agent.sockets[name].length, 1);
52 assert.strictEqual(agent.sockets[name].length, 1);
61 assert.strictEqual(agent.sockets[name].length, 1);
70 assert(!agent.sockets.hasOwnProperty(name));
|
| /third_party/gstreamer/gstplugins_bad/tests/examples/ipcpipeline/ |
| D | ipcpipeline1.c | 159 int sockets[2]; in main() local
162 if (socketpair (AF_UNIX, SOCK_STREAM, 0, sockets)) { in main()
166 if (fcntl (sockets[0], F_SETFL, O_NONBLOCK) < 0 || in main()
167 fcntl (sockets[1], F_SETFL, O_NONBLOCK) < 0) { in main()
180 start_source (sockets[0], sockets[0]); in main()
184 start_sink (sockets[1], sockets[1]); in main()
|
| /third_party/node/deps/npm/node_modules/forever-agent/ |
| D | index.js | 25 self.sockets = {}
34 } else if (self.sockets[name].length < self.minSockets) {
82 if (this.sockets[name]) {
83 var index = this.sockets[name].indexOf(s)
85 this.sockets[name].splice(index, 1)
87 } else if (this.sockets[name] && this.sockets[name].length === 0) {
89 delete this.sockets[name]
|
| /third_party/glib/gio/tests/ |
| D | unix-fd.c | 48 GSocket *sockets[2]; in test_fds() local
148 sockets[0] = g_socket_new_from_fd (sv[0], &err); in test_fds()
150 g_assert (G_IS_SOCKET (sockets[0])); in test_fds()
151 sockets[1] = g_socket_new_from_fd (sv[1], &err); in test_fds()
153 g_assert (G_IS_SOCKET (sockets[1])); in test_fds()
155 addr = g_socket_get_local_address (sockets[0], &err); in test_fds()
183 s = g_socket_send_message (sockets[0], NULL, &ov, 1, in test_fds()
195 s = g_socket_receive_message (sockets[1], NULL, &iv, 1, in test_fds()
200 g_object_unref (sockets[0]); in test_fds()
201 g_object_unref (sockets[1]); in test_fds()
|
| /third_party/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
|
| /third_party/node/test/sequential/ |
| D | test-http-keepalive-maxsockets.js | 47 assert.strictEqual(count(agent.sockets), 0);
55 assert.strictEqual(count(agent.sockets), 0);
102 function count(sockets) { argument
103 return Object.keys(sockets).reduce(function(n, name) {
104 return n + sockets[name].length;
|
| /third_party/libcoap/src/ |
| D | coap_io.c | 1099 coap_socket_t *sockets[1];
1100 unsigned int max_sockets = sizeof(sockets)/sizeof(sockets[0]);
1105 timeout = coap_io_prepare_io(ctx, sockets, max_sockets, &num_sockets, now);
1141 coap_socket_t *sockets[], argument
1150 sockets[(*num_sockets)++] = &ep->sock;
1157 sockets[(*num_sockets)++] = &s->sock;
1167 sockets[(*num_sockets)++] = &s->sock;
1182 coap_socket_t *sockets[], argument
1194 (void)sockets;
1298 coap_update_ep_sockets(ctx, sockets, max_sockets, num_sockets);
[all …]
|
| /third_party/node/deps/npm/node_modules/tunnel-agent/ |
| D | index.js | 54 self.sockets = []
85 if (self.sockets.length >= this.maxSockets) {
120 self.sockets.push(placeholder)
162 self.sockets[self.sockets.indexOf(placeholder)] = socket
185 var pos = this.sockets.indexOf(socket)
188 this.sockets.splice(pos, 1)
207 self.sockets[self.sockets.indexOf(socket)] = secureSocket
|
| /third_party/grpc/test/cpp/naming/ |
| D | resolver_component_test.cc | 315 std::vector<int> sockets; in OpenAndCloseSocketsStressLoop() local
336 sockets.push_back(s); in OpenAndCloseSocketsStressLoop()
340 for (size_t i = 0; i < sockets.size(); i++) { in OpenAndCloseSocketsStressLoop()
341 gpr_log(GPR_DEBUG, "non-blocking accept then close on %d", sockets[i]); in OpenAndCloseSocketsStressLoop()
342 ASSERT_TRUE(accept(sockets[i], nullptr, nullptr) == INVALID_SOCKET) in OpenAndCloseSocketsStressLoop()
346 std::to_string(sockets[i]) + in OpenAndCloseSocketsStressLoop()
352 ASSERT_TRUE(closesocket(sockets[i]) != SOCKET_ERROR) in OpenAndCloseSocketsStressLoop()
353 << "Failed to close socket: " + std::to_string(sockets[i]) + in OpenAndCloseSocketsStressLoop()
381 std::vector<int> sockets; in OpenAndCloseSocketsStressLoop() local
406 sockets.push_back(s); in OpenAndCloseSocketsStressLoop()
[all …]
|
| /third_party/skia/third_party/externals/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()
|
| /third_party/skia/third_party/externals/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()
|