/third_party/node/test/parallel/ |
H A D | test-http2-connect.js | 26 const clients = new Set(); 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(); 138 clients [all...] |
H A D | test-tls-server-verify.js | 34 // parameters given to the server, the various clients are 52 clients: 64 clients: 76 clients: 88 clients: 100 clients: 114 clients: [ 307 const options = tcase.clients[clientIndex]; 327 for (let i = 0; i < tcase.clients.length; i++) { 328 runClient(`${prefix}${i} `, port, tcase.clients[ [all...] |
H A D | test-process-getactiveresources-track-active-handles.js | 8 const clients = []; 26 clients.push(client); 35 clients.length + connections.length); 37 clients.forEach((item) => item.destroy());
|
H A D | test-tls-getcipher.js | 39 let clients = 0; 41 if (--clients === 0) 46 clients++; 61 clients++;
|
H A D | test-process-getactivehandles.js | 8 const clients = []; 26 clients.push(client); 35 clients.forEach(function(item) {
|
/third_party/libwebsockets/minimal-examples/ws-client/minimal-ws-client-spam/ |
H A 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[ in callback_minimal_spam() [all...] |
/third_party/libuv/test/ |
H A 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() 158 r = uv_pipe_init(loop, &clients[i].pipe_handle, 0); in TEST_IMPL() 160 uv_pipe_connect(&clients[i].conn_req, in TEST_IMPL() 161 &clients[i].pipe_handle, in TEST_IMPL() 167 uv_close((uv_handle_t*)&clients[i].pipe_handle, NULL); in TEST_IMPL()
|
H A D | benchmark-multi-accept.c | 364 struct client_ctx* clients; in test_tcp() local 374 clients = calloc(num_clients, sizeof(clients[0])); in test_tcp() 376 ASSERT_NOT_NULL(clients); in test_tcp() 391 struct client_ctx* ctx = clients + i; in test_tcp() 431 free(clients); in test_tcp()
|
/third_party/node/benchmark/http2/ |
H A D | compat.js | 11 clients: [2], 16 function main({ requests, streams, clients, duration }) { 33 clients, 34 threads: clients,
|
H A D | respond-with-fd.js | 12 clients: [2], 17 function main({ requests, streams, clients, duration }) { 34 clients, 36 threads: clients,
|
H A D | simple.js | 11 clients: [2], 16 function main({ requests, streams, clients, duration }) { 31 clients, 33 threads: clients,
|
/third_party/ltp/testcases/network/nfsv4/locks/ |
H A D | locktests.py | 2 # This script aims to help to run locktests with several clients. 126 for i in clients: 141 nbreClients=len(clients) 148 for i in clients: 153 for i in clients: 170 clients=[] variable 183 if args[i] in ("--clients", "-c"): 184 a="clients" 196 if a=="clients": 197 clients [all...] |
H A D | locktests.c | 20 * -c <num> : Number of clients to connect before starting the tests. 288 ("\n%s number : %d - Remote clients: %d local client 1 - Total client %d - Total concurent tests: %d\n", in report() 365 * the network, especially when multiples clients do not use the same hardware architecture. 678 /* Start to send sections to lock to remote process (network clients) */ in master() 716 /* Ask the clients to stop testing ... */ in master() 961 int clients; in main() local 969 clients = 0; in main() 990 if (!(clients = atoi(nextArg(argc, argv, &i)))) in main() 1007 if (clients > 0) { in main() 1008 configureServer(clients); in main() [all...] |
/third_party/node/benchmark/process/ |
H A 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/ |
H A 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()
|
H A D | client.c | 72 pa_assert_se(pa_idxset_put(core->clients, c, &c->index) >= 0); in pa_client_new() 94 pa_idxset_remove_by_data(c->core->clients, c, NULL); in pa_client_free()
|
H A D | core.c | 140 c->clients = pa_idxset_new(NULL, NULL); in pa_core_new() 228 pa_assert(pa_idxset_isempty(c->clients)); in core_free() 229 pa_idxset_free(c->clients, NULL); in core_free() 512 pa_idxset_size(c->clients) == 0) { in pa_core_check_idle() 516 } else if (c->exit_event && pa_idxset_size(c->clients) > 0) { in pa_core_check_idle()
|
/third_party/node/deps/v8/src/heap/ |
H A D | safepoint.cc | 352 std::vector<PerClientSafepointData> clients; in EnterGlobalSafepointScope() local 354 // Try to initiate safepoint for all clients. Fail immediately when the in EnterGlobalSafepointScope() 356 IterateClientIsolates([&clients, initiator](Isolate* client) { in EnterGlobalSafepointScope() 357 clients.emplace_back(client); in EnterGlobalSafepointScope() 359 initiator, &clients.back()); in EnterGlobalSafepointScope() 368 // Iterate all clients again to initiate the safepoint for all of them - even in EnterGlobalSafepointScope() 370 for (PerClientSafepointData& client : clients) { in EnterGlobalSafepointScope() 376 for (const PerClientSafepointData& client : clients) { in EnterGlobalSafepointScope() 382 // Now that safepoints were initiated for all clients, wait until all threads in EnterGlobalSafepointScope() 383 // of all clients reache in EnterGlobalSafepointScope() [all...] |
/third_party/pulseaudio/src/modules/dbus/ |
H A D | iface-core.c | 106 pa_hashmap *clients; member 975 const char **clients; in get_clients() local 983 *n = pa_hashmap_size(c->clients); in get_clients() 988 clients = pa_xnew(const char *, *n); in get_clients() 990 PA_HASHMAP_FOREACH(client, c->clients, state) in get_clients() 991 clients[i++] = pa_dbusiface_client_get_path(client); in get_clients() 993 return clients; in get_clients() 998 const char **clients; in handle_get_clients() local 1005 clients = get_clients(c, &n); in handle_get_clients() 1007 pa_dbus_send_basic_array_variant_reply(conn, msg, DBUS_TYPE_OBJECT_PATH, clients, in handle_get_clients() 1084 const char **clients; handle_get_all() local [all...] |
/third_party/vk-gl-cts/external/vulkancts/vkscserver/ |
H A D | vksIPC.cpp | 113 vector<std::future<void>> clients; in ParentLoop() local 126 remove_erase_if(clients, [](const std::future<void>& c) { return is_ready(c); }); in ParentLoop() 128 clients.push_back(CreateClientThread(std::move(client))); in ParentLoop()
|
H A D | server.cpp | 120 vector<std::future<void>> clients; in main() local 127 remove_erase_if(clients, [](const std::future<void>& c) { return is_ready(c); }); in main() 138 clients.push_back(CreateClientThread(std::move(client))); in main()
|
/third_party/python/Lib/test/test_asyncio/ |
H A D | test_windows_events.py | 120 clients = [] 129 clients.append((stream_reader, trans)) 131 for i, (r, w) in enumerate(clients): 134 for i, (r, w) in enumerate(clients):
|
/third_party/libwebsockets/plugins/ |
H A D | protocol_lws_openmetrics_export.c | 29 * to locally to proxy through to connected remote clients at 3) 31 * 3) "lws-openmetrics-prox-server" metrics proxy server that remote clients can 33 * clients connected us 37 * clients that have no reachable way to serve. 46 * reachable, we must provide a reachable server that the clients can attach to 93 * (the side the clients connect to) 98 lws_dll2_owner_t clients; member 552 * Search through our partner's clients list looking for one with the in omc_lws_om_get_other_side_pss_client() 556 vhd->bind_partner_vhd->clients.head) { in omc_lws_om_get_other_side_pss_client() 567 /* 2) "lws-openmetrics-prox-agg": http server export via proxy to connected clients */ [all...] |
/third_party/wpa_supplicant/wpa_supplicant-2.9/src/radius/ |
H A D | radius_server.c | 143 * clients - List of authorized RADIUS clients 145 struct radius_client *clients; member 316 * These counters are the sum over all clients. 478 struct radius_client *client = data->clients; in radius_server_get_client() 2169 struct radius_client *clients) in radius_server_free_clients() 2173 client = clients; in radius_server_free_clients() 2193 struct radius_client *clients, *tail, *entry; in radius_server_read_clients() local 2213 clients = tail = NULL; in radius_server_read_clients() 2321 clients in radius_server_read_clients() 2168 radius_server_free_clients(struct radius_server_data *data, struct radius_client *clients) radius_server_free_clients() argument [all...] |
/third_party/wpa_supplicant/wpa_supplicant-2.9_standard/src/radius/ |
H A D | radius_server.c | 138 * clients - List of authorized RADIUS clients 140 struct radius_client *clients; member 176 * These counters are the sum over all clients. 335 struct radius_client *client = data->clients; in radius_server_get_client() 2002 struct radius_client *clients) in radius_server_free_clients() 2006 client = clients; in radius_server_free_clients() 2026 struct radius_client *clients, *tail, *entry; in radius_server_read_clients() local 2046 clients = tail = NULL; in radius_server_read_clients() 2154 clients in radius_server_read_clients() 2001 radius_server_free_clients(struct radius_server_data *data, struct radius_client *clients) radius_server_free_clients() argument [all...] |