| /third_party/node/test/parallel/ |
| D | test-http2-connect.js | 26 const clients = new Set(); constant
28 clients.add(connect(authority));
29 clients.add(connect(authority, options));
30 clients.add(connect(authority, options, listener()));
31 clients.add(connect(authority, listener()));
33 for (const client of clients) {
36 clients.delete(client);
37 if (clients.size === 0) {
136 const clients = new Set(); constant
138 clients.add(connect(`http://[::1]:${port}`));
[all …]
|
| D | test-timers-socket-timeout-removes-other-socket-unref-timer.js | 9 const clients = []; variable
12 clients.push(client);
14 if (clients.length === 2) {
19 clients[0].setTimeout(1, () => {
20 clients[1].setTimeout(0);
21 clients[0].end();
22 clients[1].end();
27 clients[1].setTimeout(50);
|
| D | test-tls-server-verify.js | 52 clients: property
64 clients: property
76 clients: property
88 clients: property
100 clients: property
114 clients: [ property
307 const options = tcase.clients[clientIndex];
327 for (let i = 0; i < tcase.clients.length; i++) {
328 runClient(`${prefix}${i} `, port, tcase.clients[i], function() {
330 if (clientsCompleted === tcase.clients.length) {
|
| D | test-tls-connect-hwm-option.js | 13 let clients = 0; variable
19 if (--clients === 0)
24 clients++;
34 clients++;
44 clients++;
|
| D | test-process-getactiveresources-track-active-handles.js | 8 const clients = []; variable
26 clients.push(client);
35 clients.length + connections.length);
37 clients.forEach((item) => item.destroy());
|
| D | test-tls-getcipher.js | 39 let clients = 0; variable
41 if (--clients === 0)
46 clients++;
61 clients++;
|
| D | test-process-getactivehandles.js | 8 const clients = []; variable
26 clients.push(client);
35 clients.forEach(function(item) {
|
| /third_party/libwebsockets/minimal-examples/ws-client/minimal-ws-client-spam/ |
| D | minimal-ws-client-spam.c | 37 static struct client clients[200]; variable
68 i.pwsi = &clients[idx].wsi; in connect_client()
70 clients[idx].state = CLIENT_CONNECTING; in connect_client()
75 clients[idx].wsi = NULL; in connect_client()
76 clients[idx].state = CLIENT_IDLE; in connect_client()
96 clients[n].index = n; in callback_minimal_spam()
106 if (clients[n].wsi == wsi) { in callback_minimal_spam()
107 clients[n].wsi = NULL; in callback_minimal_spam()
108 clients[n].state = CLIENT_IDLE; in callback_minimal_spam()
142 if (clients[n].wsi == wsi) { in callback_minimal_spam()
[all …]
|
| /third_party/curl/tests/http/ |
| D | Makefile.am | 25 SUBDIRS = clients subdir
31 check: clients
33 clients: target
34 @(cd clients; $(MAKE) check)
37 cd clients && $(MAKE) checksrc
|
| /third_party/gstreamer/gstplugins_base/gst/tcp/ |
| D | gstmultifdsink.c | 884 GList *clients, *next; in gst_multi_fd_sink_handle_clients() local
915 for (clients = mhsink->clients; clients; clients = next) { in gst_multi_fd_sink_handle_clients()
919 client = (GstTCPClient *) clients->data; in gst_multi_fd_sink_handle_clients()
921 next = g_list_next (clients); in gst_multi_fd_sink_handle_clients()
925 gst_multi_handle_sink_remove_client_link (mhsink, clients); in gst_multi_fd_sink_handle_clients()
939 for (clients = mhsink->clients; clients; clients = next) { in gst_multi_fd_sink_handle_clients()
950 client = (GstTCPClient *) clients->data; in gst_multi_fd_sink_handle_clients()
952 next = g_list_next (clients); in gst_multi_fd_sink_handle_clients()
963 gst_multi_handle_sink_remove_client_link (mhsink, clients); in gst_multi_fd_sink_handle_clients()
997 for (clients = mhsink->clients; clients; clients = next) { in gst_multi_fd_sink_handle_clients()
[all …]
|
| D | gstmultihandlesink.c | 423 this->clients = NULL; in gst_multi_handle_sink_init()
557 GList *clients; in gst_multi_handle_sink_setup_dscp() local
560 for (clients = mhsink->clients; clients; clients = clients->next) { in gst_multi_handle_sink_setup_dscp()
563 client = clients->data; in gst_multi_handle_sink_setup_dscp()
615 clink = mhsink->clients = g_list_prepend (mhsink->clients, mhclient); in gst_multi_handle_sink_add_full()
751 GList *clients, *next; in gst_multi_handle_sink_clear() local
761 for (clients = mhsink->clients; clients; clients = next) { in gst_multi_handle_sink_clear()
769 mhclient = (GstMultiHandleClient *) clients->data; in gst_multi_handle_sink_clear()
770 next = g_list_next (clients); in gst_multi_handle_sink_clear()
775 gst_multi_handle_sink_remove_client_link (mhsink, clients); in gst_multi_handle_sink_clear()
[all …]
|
| D | gstmultisocketsink.c | 1117 GList *clients; in gst_multi_socket_sink_timeout() local
1123 for (clients = mhsink->clients; clients; clients = clients->next) { in gst_multi_socket_sink_timeout()
1127 client = clients->data; in gst_multi_socket_sink_timeout()
1132 gst_multi_handle_sink_remove_client_link (mhsink, clients); in gst_multi_socket_sink_timeout()
1217 GList *clients; in gst_multi_socket_sink_start_pre() local
1224 for (clients = mhsink->clients; clients; clients = clients->next) { in gst_multi_socket_sink_start_pre()
1225 GstSocketClient *client = clients->data; in gst_multi_socket_sink_start_pre()
|
| /third_party/gstreamer/gstplugins_good/gst/udp/ |
| D | gstmultiudpsink.c | 402 sink->clients = NULL; in gst_multiudpsink_init()
530 g_list_foreach (sink->clients, (GFunc) gst_udp_client_unref, NULL); in gst_multiudpsink_finalize()
531 g_list_free (sink->clients); in gst_multiudpsink_finalize()
723 GstUDPClient **clients; in gst_multiudpsink_render_buffers() local
749 clients = g_newa (GstUDPClient *, num_addr); in gst_multiudpsink_render_buffers()
750 for (l = sink->clients, i = 0; l != NULL; l = l->next) { in gst_multiudpsink_render_buffers()
753 clients[i++] = gst_udp_client_ref (client); in gst_multiudpsink_render_buffers()
755 clients[i++] = gst_udp_client_ref (client); in gst_multiudpsink_render_buffers()
795 msgs[i].address = clients[0]->addr; in gst_multiudpsink_render_buffers()
807 msgs[i * num_buffers + j].address = clients[i]->addr; in gst_multiudpsink_render_buffers()
[all …]
|
| /third_party/node/benchmark/http2/ |
| D | simple.js | 11 clients: [2], property
16 function main({ requests, streams, clients, duration }) { property
31 clients, property
33 threads: clients,
|
| D | respond-with-fd.js | 12 clients: [2], property
17 function main({ requests, streams, clients, duration }) { property
34 clients, property
36 threads: clients,
|
| D | compat.js | 11 clients: [2], property
16 function main({ requests, streams, clients, duration }) { property
33 clients, property
34 threads: clients,
|
| /third_party/ltp/testcases/network/nfsv4/locks/ |
| D | README | 26 ./locktests -n <number of concurent processes> -f <test file> -c <number of clients>
28 Test clients:
32 Multiple clients options
36 clients try to use the same file. It uses a test server and several test
37 clients.
61 -c <num> : Number of clients to connect before starting the tests.
75 Multiple clients:
78 (Server waiting for 3 clients to be connected)
80 -test clients:
132 Note that the testing locks with thread on multiple clients is disabled
[all …]
|
| D | locktests.py | 126 for i in clients:
141 nbreClients=len(clients)
148 for i in clients:
153 for i in clients:
170 clients=[] variable
197 clients.append(args[i])
|
| D | deploy_info | 2 clients accessing the same server.
11 -c <machine> [...] : Setup test on these clients
26 -c <machine> [...] : Clients. run tests from this clients
|
| /third_party/node/deps/undici/src/docs/api/ |
| D | PoolStats.md | 23 Number of pending requests across all clients in this pool.
27 Number of queued requests across all clients in this pool.
31 Number of currently active requests across all clients in this pool.
35 Number of active, pending, or queued requests across all clients in this pool.
|
| /third_party/libuv/test/ |
| D | test-pipe-connect-multiple.c | 40 static client_t clients[NUM_CLIENTS]; variable
92 r = uv_pipe_init(loop, &clients[i].pipe_handle, 0); in TEST_IMPL()
94 uv_pipe_connect(&clients[i].conn_req, in TEST_IMPL()
95 &clients[i].pipe_handle, in TEST_IMPL()
|
| /third_party/gstreamer/gstplugins_bad/sys/shm/ |
| D | shmpipe.c | 123 int clients[0]; member
141 ShmClient *clients; member
445 while (self->clients) in sp_writer_close()
446 sp_writer_close_client (self, self->clients, callback, user_data); in sp_writer_close()
510 for (client = self->clients; client; client = client->next) { in sp_writer_resize()
607 memset (sb->clients, -1, sizeof (int) * self->num_clients); in sp_writer_send_buf()
615 for (client = self->clients; client; client = client->next) { in sp_writer_send_buf()
621 sb->clients[i++] = client->fd; in sp_writer_send_buf()
840 client->next = self->clients; in sp_writer_accept_client()
841 self->clients = client; in sp_writer_accept_client()
[all …]
|
| /third_party/node/benchmark/process/ |
| D | getActiveResourcesInfo.js | 18 const clients = [];
20 clients.push(connect({ port: server.address().port }));
41 for (const client of clients) {
|
| /third_party/pulseaudio/src/pulsecore/ |
| D | x11wrap.c | 58 PA_LLIST_HEAD(pa_x11_client, clients);
84 for (c = w->clients; c; c = n) { in work()
222 PA_LLIST_HEAD_INIT(pa_x11_client, w->clients); in x11_wrapper_new()
249 pa_assert(!w->clients); in x11_wrapper_free()
328 for (c = w->clients; c; c = n) { in x11_wrapper_kill()
350 PA_LLIST_PREPEND(pa_x11_client, w->clients, c); in pa_x11_client_new()
360 PA_LLIST_REMOVE(pa_x11_client, c->wrapper->clients, c); in pa_x11_client_free()
|
| /third_party/node/deps/v8/src/heap/ |
| D | safepoint.cc | 352 std::vector<PerClientSafepointData> clients; in EnterGlobalSafepointScope() local
356 IterateClientIsolates([&clients, initiator](Isolate* client) { in EnterGlobalSafepointScope()
357 clients.emplace_back(client); in EnterGlobalSafepointScope()
359 initiator, &clients.back()); in EnterGlobalSafepointScope()
370 for (PerClientSafepointData& client : clients) { in EnterGlobalSafepointScope()
376 for (const PerClientSafepointData& client : clients) { in EnterGlobalSafepointScope()
384 for (const PerClientSafepointData& client : clients) { in EnterGlobalSafepointScope()
|