Home
last modified time | relevance | path

Searched refs:num_servers (Results 1 – 16 of 16) sorted by relevance

/external/grpc-grpc/test/cpp/qps/
Djson_run_localhost_scenarios.bzl3num_servers": 1, "server_config": {"security_params": null, "server_type": "ASYNC_SERVER", "async_…
Dqps_json_driver_scenarios.bzl3num_servers": 1, "server_config": {"security_params": null, "server_type": "SYNC_SERVER", "async_s…
Ddriver.cc198 const ServerConfig& initial_server_config, size_t num_servers, in RunScenario() argument
255 num_clients = workers.size() - num_servers; in RunScenario()
261 GPR_ASSERT(workers.size() >= num_clients + num_servers); in RunScenario()
264 workers.resize(num_clients + num_servers); in RunScenario()
271 std::vector<ServerData> servers(num_servers); in RunScenario()
275 for (size_t i = 0; i < num_servers; i++) { in RunScenario()
305 GPR_ASSERT(num_servers == 1); in RunScenario()
334 const auto& worker = workers[i + num_servers]; in RunScenario()
336 worker.c_str(), i + num_servers); in RunScenario()
343 local_workers[i + num_servers]->InProcessChannel(channel_args)); in RunScenario()
[all …]
Ddriver.h32 const grpc::testing::ServerConfig& server_config, size_t num_servers,
Dqps_json_driver.cc83 scenario.server_config(), scenario.num_servers(), in RunAndReport()
/external/grpc-grpc/src/core/ext/filters/client_channel/lb_policy/grpclb/
Dload_balancer_api.cc36 ++sl->num_servers; in count_serverlist()
52 GPR_ASSERT(dec_arg->serverlist->num_servers >= dec_arg->decoding_idx); in decode_serverlist()
207 if (sl->num_servers > 0) { in grpc_grpclb_response_parse_serverlist()
209 gpr_zalloc(sizeof(grpc_grpclb_server*) * sl->num_servers)); in grpc_grpclb_response_parse_serverlist()
230 for (size_t i = 0; i < serverlist->num_servers; i++) { in grpc_grpclb_destroy_serverlist()
241 copy->num_servers = sl->num_servers; in grpc_grpclb_serverlist_copy()
243 gpr_malloc(sizeof(grpc_grpclb_server*) * sl->num_servers)); in grpc_grpclb_serverlist_copy()
244 for (size_t i = 0; i < sl->num_servers; i++) { in grpc_grpclb_serverlist_copy()
257 if (lhs->num_servers != rhs->num_servers) { in grpc_grpclb_serverlist_equals()
260 for (size_t i = 0; i < lhs->num_servers; i++) { in grpc_grpclb_serverlist_equals()
Dload_balancer_api.h41 size_t num_servers; member
Dgrpclb.cc446 for (size_t i = 0; i < serverlist->num_servers; ++i) { in ProcessServerlist()
457 for (size_t sl_idx = 0; sl_idx < serverlist->num_servers; ++sl_idx) { in ProcessServerlist()
793 grpclb_policy, serverlist->num_servers); in OnBalancerMessageReceivedLocked()
794 for (size_t i = 0; i < serverlist->num_servers; ++i) { in OnBalancerMessageReceivedLocked()
805 if (serverlist->num_servers > 0) { in OnBalancerMessageReceivedLocked()
1587 if (serverlist_index_ == serverlist_->num_servers) { in PickFromRoundRobinPolicyLocked()
1682 GPR_ASSERT(serverlist_->num_servers > 0); in CreateRoundRobinPolicyArgsLocked()
/external/grpc-grpc/src/php/tests/qps/generated_code/Grpc/Testing/
DScenario.php47 private $num_servers = 0; variable in Grpc\\Testing\\Scenario
184 return $this->num_servers;
197 $this->num_servers = $var;
/external/grpc-grpc/test/cpp/end2end/
Dclient_lb_end2end_test.cc134 void CreateServers(size_t num_servers, in CreateServers() argument
137 for (size_t i = 0; i < num_servers; ++i) { in CreateServers()
139 if (ports.size() == num_servers) port = ports[i]; in CreateServers()
146 void StartServers(size_t num_servers, in StartServers() argument
148 CreateServers(num_servers, ports); in StartServers()
149 for (size_t i = 0; i < num_servers; ++i) { in StartServers()
/external/grpc-grpc/test/cpp/grpclb/
Dgrpclb_api_test.cc108 ASSERT_EQ(c_serverlist->num_servers, 2ul); in TEST_F()
/external/wpa_supplicant_8/src/radius/
Dradius_client.c375 int num_servers; in radius_client_retransmit() local
379 num_servers = conf->num_acct_servers; in radius_client_retransmit()
396 num_servers = conf->num_auth_servers; in radius_client_retransmit()
461 RADIUS_CLIENT_NUM_FAILOVER * num_servers) { in radius_client_retransmit()
/external/grpc-grpc/tools/run_tests/performance/
DREADME.md131 of servers, `num_servers`, and the driver will start
/external/wpa_supplicant_8/src/ap/
Dap_config.c439 int num_servers) in hostapd_config_free_radius() argument
443 for (i = 0; i < num_servers; i++) { in hostapd_config_free_radius()
/external/grpc-grpc-java/benchmarks/src/main/proto/grpc/testing/
Dcontrol.proto190 int32 num_servers = 5; field
/external/grpc-grpc/src/proto/grpc/testing/
Dcontrol.proto203 int32 num_servers = 5; field