Home
last modified time | relevance | path

Searched refs:num_clients (Results 1 – 25 of 387) sorted by relevance

12345678910>>...16

/dports/devel/p5-POE-Test-Loops/POE-Test-Loops-1.360/lib/POE/Test/Loops/
H A Dz_rt53302_fh_watchers.pm34 my $num_clients = 5;
74 if ( $num_server_disconnects >= $num_clients ) {
81 for ( 1 .. $num_clients ) {
107 is( $num_server_connects, $num_clients, "Server got $num_clients client connections" );
108 is( $num_server_disconnects, $num_clients, "Server got $num_clients client disconnections" );
109 is( $num_server_inputs, $num_clients, "Client sent input $num_clients times" );
110 is( $num_server_flushes, $num_clients, "Server flushed $num_clients lines of data" );
112 is( $num_client_connects, $num_clients, "Client connected $num_clients times" );
113 is( $num_client_disconnects, $num_clients, "Client disconnected $num_clients times" );
114 is( $num_client_inputs, $num_clients, "Server sent input $num_clients times" );
[all …]
/dports/devel/libzookeeper/apache-zookeeper-3.7.0/zookeeper-recipes/zookeeper-recipes-queue/src/main/c/tests/
H A DTestClient.cc214 for(i=0; i< num_clients; i++){ in initializeQueuesAndHandles()
228 int num_clients = 1; in testInitDestroy() local
229 watchctx_t ctxs[num_clients]; in testInitDestroy()
247 int num_clients = 1; in testOffer1() local
248 watchctx_t ctxs[num_clients]; in testOffer1()
273 int num_clients = 2; in create_n_remove_m() local
274 watchctx_t ctxs[num_clients]; in create_n_remove_m()
334 int num_clients = 2; in create_n_take_m() local
335 watchctx_t ctxs[num_clients]; in create_n_take_m()
394 int num_clients = 1; in testTakeThreaded() local
[all …]
/dports/games/gl-117/gl-117-1.3.2-src/src/
H A Dnet.cpp106 num_clients = 0; in Server()
168 if(i<0 && i>=num_clients) in removeClient()
174 num_clients--; in removeClient()
175 if(num_clients>i) in removeClient()
198 for(int i=0;i<num_clients;i++) in createSocketSet()
221 clients[num_clients].id = id; in getClient()
230 num_clients++; in getClient()
251 for (int i = 0; i < num_clients; i++) in getClientFromID()
303 for (i = 0; i < num_clients; i++) in checkStart()
311 bool *ok = new bool [num_clients]; in checkStart()
[all …]
/dports/net/kea/kea-2.0.1/src/lib/config/tests/
H A Dcmd_http_listener_unittests.cc371 ASSERT_TRUE(num_clients); in threadListenAndRespond()
372 ASSERT_TRUE((num_clients < num_threads) || (num_clients % num_threads == 0)); in threadListenAndRespond()
375 num_clients_ = num_clients; in threadListenAndRespond()
528 ASSERT_TRUE(num_clients); in workPauseAndResume()
897 size_t num_clients = 1; in TEST_F() local
904 size_t num_clients = 4; in TEST_F() local
911 size_t num_clients = 1; in TEST_F() local
918 size_t num_clients = 4; in TEST_F() local
925 size_t num_clients = 8; in TEST_F() local
932 size_t num_clients = 18; in TEST_F() local
[all …]
/dports/games/SRB2/SRB2-SRB2_release_2.2.9/tools/masterserver/
H A Dipcs.cpp238 num_clients = 0; in CServerSocket()
310 if (num_clients != 0) in deleteClient()
311 num_clients--; in deleteClient()
313 memmove(&client_addr[id], &client_addr[num_clients], sizeof (client_addr[num_clients])); in deleteClient()
315 memset(&client_addr[num_clients], 0 , sizeof (client_addr[num_clients])); in deleteClient()
515 if (num_clients < MAX_CLIENT-1) in accept()
520 client_fd[num_clients], num_clients+1, inet_ntoa(addr.sin_addr), htons(addr.sin_port)); in accept()
522 FD_SET(client_fd[num_clients], &rset); in accept()
523 num_clients++; in accept()
528 close(client_fd[num_clients]); in accept()
[all …]
/dports/devel/grpc130/grpc-1.30.2/test/cpp/qps/
H A Djson_run_localhost_scenarios.bzl3 …num_clients": 0}]}\'', "cpp_protobuf_sync_streaming_from_client_qps_unconstrained_secure": '\'{\'s…
H A Dqps_json_driver_scenarios.bzl3 …num_clients": 0}]}\'', "cpp_protobuf_sync_streaming_qps_unconstrained_1mps_insecure": '\'{\'scenar…
H A Ddriver.cc291 if (num_clients <= 0) { in RunScenario()
301 workers.resize(num_clients + num_servers); in RunScenario()
372 for (size_t i = 0; i < num_clients; i++) { in RunScenario()
396 (num_clients - i); in RunScenario()
411 for (size_t i = 0; i < num_clients; i++) { in RunScenario()
428 for (size_t i = 0; i < num_clients; i++) { in RunScenario()
435 for (size_t i = 0; i < num_clients; i++) { in RunScenario()
458 for (size_t i = 0; i < num_clients; i++) { in RunScenario()
472 for (size_t i = 0; i < num_clients; i++) { in RunScenario()
496 for (size_t i = 0; i < num_clients; i++) { in RunScenario()
[all …]
/dports/devel/grpc134/grpc-1.34.1/test/cpp/qps/
H A Djson_run_localhost_scenarios.bzl3 …num_clients": 0}]}\'', "cpp_protobuf_sync_streaming_from_client_qps_unconstrained_secure": '\'{\'s…
H A Dqps_json_driver_scenarios.bzl3 …num_clients": 0}]}\'', "cpp_protobuf_sync_streaming_qps_unconstrained_1mps_insecure": '\'{\'scenar…
/dports/www/chromium-legacy/chromium-88.0.4324.182/third_party/grpc/src/test/cpp/qps/
H A Djson_run_localhost_scenarios.bzl3 …num_clients": 0}]}\'', 'cpp_protobuf_sync_streaming_from_client_qps_unconstrained_secure': '\'{\'s…
H A Dqps_json_driver_scenarios.bzl3 …num_clients": 0}]}\'', 'cpp_protobuf_sync_streaming_qps_unconstrained_1mps_insecure': '\'{\'scenar…
H A Ddriver.cc261 if (num_clients <= 0) { in RunScenario()
271 workers.resize(num_clients + num_servers); in RunScenario()
341 for (size_t i = 0; i < num_clients; i++) { in RunScenario()
365 (num_clients - i); in RunScenario()
379 for (size_t i = 0; i < num_clients; i++) { in RunScenario()
395 for (size_t i = 0; i < num_clients; i++) { in RunScenario()
401 for (size_t i = 0; i < num_clients; i++) { in RunScenario()
422 for (size_t i = 0; i < num_clients; i++) { in RunScenario()
434 for (size_t i = 0; i < num_clients; i++) { in RunScenario()
457 for (size_t i = 0; i < num_clients; i++) { in RunScenario()
[all …]
/dports/devel/grpc/grpc-1.42.0/test/cpp/qps/
H A Djson_run_localhost_scenarios.bzl17 …c_unary_75Kqps_600channel_60Krpcs_300Breq_50Bresp", "num_servers": 1, "num_clients": 0, "client_co…
28 …"name": "cpp_protobuf_sync_unary_ping_pong_secure", "num_servers": 1, "num_clients": 1, "client_co…
30 …name": "cpp_protobuf_async_unary_ping_pong_secure", "num_servers": 1, "num_clients": 1, "client_co…
45 …: "cpp_generic_async_streaming_ping_pong_insecure", "num_servers": 1, "num_clients": 1, "client_co…
50 …uf_async_streaming_qps_unconstrained_1cq_insecure", "num_servers": 1, "num_clients": 0, "client_co…
51 …otobuf_async_unary_qps_unconstrained_1cq_insecure", "num_servers": 1, "num_clients": 0, "client_co…
55 …ame": "cpp_protobuf_sync_unary_ping_pong_insecure", "num_servers": 1, "num_clients": 1, "client_co…
56 …pp_protobuf_sync_unary_qps_unconstrained_insecure", "num_servers": 1, "num_clients": 0, "client_co…
57 …me": "cpp_protobuf_async_unary_ping_pong_insecure", "num_servers": 1, "num_clients": 1, "client_co…
59 …: "cpp_protobuf_sync_streaming_ping_pong_insecure", "num_servers": 1, "num_clients": 1, "client_co…
[all …]
H A Dqps_json_driver_scenarios.bzl17 …: "cpp_generic_async_streaming_ping_pong_insecure", "num_servers": 1, "num_clients": 1, "client_co…
22 …uf_async_streaming_qps_unconstrained_1cq_insecure", "num_servers": 1, "num_clients": 0, "client_co…
23 …otobuf_async_unary_qps_unconstrained_1cq_insecure", "num_servers": 1, "num_clients": 0, "client_co…
24 …ient_sync_server_unary_qps_unconstrained_insecure", "num_servers": 1, "num_clients": 0, "client_co…
25 …nt_unary_1channel_64wide_128Breq_8MBresp_insecure", "num_servers": 1, "num_clients": 1, "client_co…
26 … "cpp_protobuf_async_unary_ping_pong_insecure_1MB", "num_servers": 1, "num_clients": 1, "client_co…
27 …pp_protobuf_sync_unary_qps_unconstrained_insecure", "num_servers": 1, "num_clients": 0, "client_co…
28 …p_protobuf_async_unary_qps_unconstrained_insecure", "num_servers": 1, "num_clients": 0, "client_co…
29 …rotobuf_sync_streaming_qps_unconstrained_insecure", "num_servers": 1, "num_clients": 0, "client_co…
31 …otobuf_async_streaming_qps_unconstrained_insecure", "num_servers": 1, "num_clients": 0, "client_co…
[all …]
/dports/games/vitetris/vitetris-0.59.1/src/netw/
H A Dgameserver.c90 for (i=0; i < num_clients; i++) { in fd_set_clients()
180 for (i=0; i < num_clients; i++) in send_playerlist()
219 for (j=0; j < num_clients; j++) in first_available_opponent()
271 if (i+1 == num_clients) in remove_client_elem()
272 num_clients--; in remove_client_elem()
305 while (num_clients > 0 && clients[num_clients-1].sock < 0) in remove_client()
306 num_clients--; in remove_client()
539 while (num_clients > 0) { in sighandler()
540 num_clients--; in sighandler()
601 if (!num_clients) in main()
[all …]
/dports/www/chromium-legacy/chromium-88.0.4324.182/chrome/browser/sync/test/integration/
H A Dtwo_client_dictionary_sync_test.cc43 ASSERT_EQ(num_clients(), static_cast<int>(words.size())); in IN_PROC_BROWSER_TEST_F()
45 for (int i = 0; i < num_clients(); ++i) { in IN_PROC_BROWSER_TEST_F()
50 for (int i = 0; i < num_clients(); ++i) { in IN_PROC_BROWSER_TEST_F()
55 for (int i = 0; i < num_clients(); ++i) { in IN_PROC_BROWSER_TEST_F()
69 for (int i = 0; i < num_clients(); ++i) { in IN_PROC_BROWSER_TEST_F()
83 for (int i = 0; i < num_clients(); ++i) { in IN_PROC_BROWSER_TEST_F()
88 for (int i = 0; i < num_clients(); ++i) { in IN_PROC_BROWSER_TEST_F()
/dports/audio/festival/festival/src/arch/festival/
H A Dserver.cc81 int max_clients, num_clients, pid; in festival_start_server() local
89 num_clients = 0; in festival_start_server()
168 num_clients++; in festival_start_server()
171 if (num_clients > max_clients) in festival_start_server()
174 num_clients--; in festival_start_server()
186 num_clients--; in festival_start_server()
189 while ((num_clients > 0) && (waitpid(0,&statusp,WNOHANG) != 0)) in festival_start_server()
190 num_clients--; in festival_start_server()
/dports/multimedia/harvid/harvid-0.8.2/src/
H A Dsocket_server.c236 c->d->num_clients--; in socket_handler()
240 debugmsg(DEBUG_SRV, "SRV: now %i connections active\n", c->d->num_clients); in socket_handler()
250 d->num_clients++; in start_child()
251 if (d->num_clients > d->max_clients) d->max_clients = d->num_clients; in start_child()
274 d->num_clients--; in start_child()
280 debugmsg(DEBUG_SRV, "SRV: Connection started: now %i connections active\n", d->num_clients); in start_child()
305 if (d->num_clients >= MAXCONNECTIONS) { in accept_connection()
411 if (d->num_clients > 0) in main_loop()
417 while (d->num_clients> 0 && --timeout > 0) { in main_loop()
427 if (d->num_clients > 0) { in main_loop()
[all …]
/dports/net/samba412/samba-4.12.15/ctdb/tests/src/
H A Dcomm_server_test.c137 int num_clients;
158 state->num_clients = 0;
181 state->num_clients++;
194 if (state->num_clients == state->max_clients) {
222 if (state->num_clients == state->max_clients) {
268 int num_clients;
282 num_clients = atoi(argv[2]);
283 assert(num_clients > 0);
285 req = socket_process_send(mem_ctx, ev, fd, num_clients);
/dports/net/openmpi3/openmpi-3.1.6/orte/test/mpi/
H A Dsingleton_client_server.c52 int num_clients ; in main() local
70 num_clients = atoi(argv[1]) ; in main()
73 if (num_clients <= 0 || (role != 0 && role != 1)) in main()
113 for(i = 0 ; i < num_clients ; i++ ) in main()
165 for (i = rank ; i < num_clients ; i++) in main()
192 msg_count = num_clients ; in main()
/dports/net/openmpi/openmpi-4.1.1/orte/test/mpi/
H A Dsingleton_client_server.c52 int num_clients ; in main() local
70 num_clients = atoi(argv[1]) ; in main()
73 if (num_clients <= 0 || (role != 0 && role != 1)) in main()
113 for(i = 0 ; i < num_clients ; i++ ) in main()
165 for (i = rank ; i < num_clients ; i++) in main()
192 msg_count = num_clients ; in main()
/dports/www/webstone-ssl/WebStone2.5/bin/
H A Dwscollect59 local ($timestamp, $num_clients, $conn_rate,
68 $timestamp, $num_clients, $conn_rate, $load, $latency, $error, $tput
107 local ($timestamp, $num_clients, $conn_rate,
111 $timestamp, $num_clients, $conn_rate, $load, $latency, $error, $tput;
/dports/www/webstone/WebStone2.5/bin/
H A Dwscollect59 local ($timestamp, $num_clients, $conn_rate,
68 $timestamp, $num_clients, $conn_rate, $load, $latency, $error, $tput
107 local ($timestamp, $num_clients, $conn_rate,
111 $timestamp, $num_clients, $conn_rate, $load, $latency, $error, $tput;
/dports/devel/dee/dee-1.2.7/tests/
H A Dserver-helper-client.c82 int num_clients, i; in main() local
89 num_clients = i = atoi (argv[2]); in main()
103 if (finished_children == num_clients) break; in main()
110 g_assert_cmpint (num_clients, ==, finished_children); in main()

12345678910>>...16