Home
last modified time | relevance | path

Searched refs:sockets (Results 1 – 25 of 330) sorted by relevance

12345678910>>...14

/third_party/curl/tests/libtest/
Dlib582.c36 curl_socket_t *sockets; member
49 static void removeFd(struct Sockets *sockets, curl_socket_t fd, int mention) in removeFd() argument
56 for(i = 0; i < sockets->count; ++i) { in removeFd()
57 if(sockets->sockets[i] == fd) { in removeFd()
58 if(i < sockets->count - 1) in removeFd()
59 memmove(&sockets->sockets[i], &sockets->sockets[i + 1], in removeFd()
60 sizeof(curl_socket_t) * (sockets->count - (i + 1))); in removeFd()
61 --sockets->count; in removeFd()
69 static void addFd(struct Sockets *sockets, curl_socket_t fd, const char *what) in addFd() argument
76 removeFd(sockets, fd, 0); in addFd()
[all …]
Dlib530.c43 curl_socket_t *sockets; member
56 static void removeFd(struct Sockets *sockets, curl_socket_t fd, int mention) in removeFd() argument
63 for(i = 0; i < sockets->count; ++i) { in removeFd()
64 if(sockets->sockets[i] == fd) { in removeFd()
65 if(i < sockets->count - 1) in removeFd()
66 memmove(&sockets->sockets[i], &sockets->sockets[i + 1], in removeFd()
67 sizeof(curl_socket_t) * (sockets->count - (i + 1))); in removeFd()
68 --sockets->count; in removeFd()
77 static int addFd(struct Sockets *sockets, curl_socket_t fd, const char *what) in addFd() argument
84 removeFd(sockets, fd, 0); in addFd()
[all …]
/third_party/libuv/test/
Dtest-watcher-cross-stop.c32 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/node/lib/
D_http_agent.js107 this.sockets = ObjectCreate(null);
170 if (this.sockets[name])
171 count += this.sockets[name].length;
205 const sockets = ObjectValues(this.sockets);
206 for (let i = 0; i < sockets.length; i++) {
207 sockets[i].on('keylog', this[kOnKeylog]);
259 if (!this.sockets[name]) {
260 this.sockets[name] = []; property
277 const sockLen = freeLen + this.sockets[name].length;
283 ArrayPrototypePush(this.sockets[name], socket);
[all …]
/third_party/gstreamer/gstplugins_base/tests/check/pipelines/
Dtcp.c161 GSocket *sockets[2] = { NULL, NULL }; in setup_multisocketsink_and_socketsrc() local
168 G_SOCKET_TYPE_STREAM, G_SOCKET_PROTOCOL_DEFAULT, sockets, &err)); in setup_multisocketsink_and_socketsrc()
170 g_object_set (st->src, "socket", sockets[0], NULL); in setup_multisocketsink_and_socketsrc()
171 g_object_unref (sockets[0]); in setup_multisocketsink_and_socketsrc()
172 sockets[0] = NULL; in setup_multisocketsink_and_socketsrc()
176 g_signal_emit_by_name (st->sink, "add", sockets[1], NULL); in setup_multisocketsink_and_socketsrc()
177 g_object_unref (sockets[1]); in setup_multisocketsink_and_socketsrc()
178 sockets[1] = NULL; in setup_multisocketsink_and_socketsrc()
253 GSocket *sockets[4] = { NULL, NULL }; in GST_START_TEST() local
263 G_SOCKET_TYPE_STREAM, G_SOCKET_PROTOCOL_DEFAULT, &sockets[0], NULL)); in GST_START_TEST()
[all …]
/third_party/lwip/
D0003-fix-the-occasional-coredump-when-the-lwip-exits.patch8 src/api/sockets.c | 37 +++++++++----------------------------
11 diff --git a/src/api/sockets.c b/src/api/sockets.c
13 --- a/src/api/sockets.c
14 +++ b/src/api/sockets.c
30 - sock = &sockets[i];
46 - free(sockets);
47 - sockets = NULL;
54 + * 1. a sockets table of the process.
D0033-alloc-socket-fail-clean-sock.patch7 src/api/sockets.c | 3 +++
11 diff --git a/src/api/sockets.c b/src/api/sockets.c
13 --- a/src/api/sockets.c
14 +++ b/src/api/sockets.c
16 … sockets[i].sendevent = (NETCONNTYPE_GROUP(newconn->type) == NETCONN_TCP ? (accepted != 0) : 1);
17 sockets[i].errevent = 0;
D0008-gazelle-fix-lwip_accept-memcpy-sockaddr-large.patch7 src/api/sockets.c | 2 ++
10 diff --git a/src/api/sockets.c b/src/api/sockets.c
12 --- a/src/api/sockets.c
13 +++ b/src/api/sockets.c
D0052-lwip_fnctl-only-support-F_SETFL-F_GETFL.patch8 src/api/sockets.c | 5 +++++
11 diff --git a/src/api/sockets.c b/src/api/sockets.c
13 --- a/src/api/sockets.c
14 +++ b/src/api/sockets.c
D0009-fix-stack-buffer-overflow-when-memcpy-addr.patch8 src/api/sockets.c | 4 ++++
11 diff --git a/src/api/sockets.c b/src/api/sockets.c
13 --- a/src/api/sockets.c
14 +++ b/src/api/sockets.c
D0018-exec-gazelle_init_sock-before-read-event.patch7 src/api/sockets.c | 1 +
11 diff --git a/src/api/sockets.c b/src/api/sockets.c
13 --- a/src/api/sockets.c
14 +++ b/src/api/sockets.c
D0012-fix-incomplete-resource-release-in-lwip-close.patch8 src/api/sockets.c | 10 ++++++----
11 diff --git a/src/api/sockets.c b/src/api/sockets.c
13 --- a/src/api/sockets.c
14 +++ b/src/api/sockets.c
D0076-fix-recvmsg-return-EINVAL.patch7 src/api/sockets.c | 12 ++++++++++++
10 diff --git a/src/api/sockets.c b/src/api/sockets.c
12 --- a/src/api/sockets.c
13 +++ b/src/api/sockets.c
D0034-add-accept4-and-epoll_create1.patch8 src/api/sockets.c | 34 ++++++++++++++++++++++++++++++----
9 src/include/lwip/sockets.h | 21 +++++++++++++++++++++
25 diff --git a/src/api/sockets.c b/src/api/sockets.c
27 --- a/src/api/sockets.c
28 +++ b/src/api/sockets.c
121 diff --git a/src/include/lwip/sockets.h b/src/include/lwip/sockets.h
123 --- a/src/include/lwip/sockets.h
124 +++ b/src/include/lwip/sockets.h
D0017-support-REUSEPOR-option.patch8 src/api/sockets.c | 4 ++++
12 diff --git a/src/api/sockets.c b/src/api/sockets.c
14 --- a/src/api/sockets.c
15 +++ b/src/api/sockets.c
/third_party/node/test/parallel/
Dtest-child-process-fork-getconnections.js30 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) {
Dtest-http-agent-keepalive.js60 assert.strictEqual(agent.sockets[name].length, 1);
72 assert.strictEqual(agent.sockets[name].length, 1);
75 assert.strictEqual(agent.sockets[name], undefined);
91 assert.strictEqual(agent.sockets[name].length, 1);
94 assert.strictEqual(agent.sockets[name], undefined);
99 assert.strictEqual(agent.sockets[name], undefined);
115 assert.strictEqual(agent.sockets[name].length, 1);
120 assert.strictEqual(agent.sockets[name], undefined);
136 assert.strictEqual(agent.sockets[name].length, 1);
139 assert.strictEqual(agent.sockets[name], undefined);
Dtest-net-server-close.js27 const sockets = []; variable
32 sockets.push(c);
34 if (sockets.length === 2) {
36 sockets.forEach((c) => c.destroy());
Dtest-http-abort-queued.js44 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);
Dtest-net-server-reset.js6 const sockets = []; variable
11 sockets.push(c);
13 if (sockets.length === 2) {
15 sockets.forEach((c) => c.resetAndDestroy());
Dtest-http-agent-maxsockets-respected.js49 const sockets = agent.sockets[Object.keys(agent.sockets)[0]]; constant
50 assert(sockets.length <= MAX_SOCKETS);
Dtest-http-client-timeout-option-listeners.js38 const sockets = agent.sockets[`${options.host}:${options.port}:`];
39 assert.strictEqual(sockets.length, 1);
40 const socket = sockets[0];
/third_party/gstreamer/gstplugins_bad/tests/examples/ipcpipeline/
Dipcpipeline1.c163 int sockets[2]; in main() local
166 if (socketpair (AF_UNIX, SOCK_STREAM, 0, sockets)) { in main()
170 if (fcntl (sockets[0], F_SETFL, O_NONBLOCK) < 0 || in main()
171 fcntl (sockets[1], F_SETFL, O_NONBLOCK) < 0) { in main()
184 start_source (sockets[0], sockets[0]); in main()
188 start_sink (sockets[1], sockets[1]); in main()
/third_party/ltp/testcases/network/stress/multicast/grp-operation/
D00_Descriptions.txt7 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/
Dtest-http-keepalive-maxsockets.js47 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;

12345678910>>...14