Lines Matching refs:clients

237 static void FinishClients(const std::vector<ClientData>& clients,  in FinishClients()  argument
240 for (size_t i = 0, i_end = clients.size(); i < i_end; i++) { in FinishClients()
241 auto client = &clients[i]; in FinishClients()
252 const std::vector<ClientData>& clients, Histogram& merged_latencies, in ReceiveFinalStatusFromClients() argument
256 for (size_t i = 0, i_end = clients.size(); i < i_end; i++) { in ReceiveFinalStatusFromClients()
257 auto client = &clients[i]; in ReceiveFinalStatusFromClients()
282 static void ShutdownClients(const std::vector<ClientData>& clients, in ShutdownClients() argument
285 for (size_t i = 0, i_end = clients.size(); i < i_end; i++) { in ShutdownClients()
286 auto client = &clients[i]; in ShutdownClients()
485 std::vector<ClientData> clients(num_clients); in RunScenario() local
492 clients[i].stub = WorkerService::NewStub(grpc::CreateTestChannel( in RunScenario()
497 clients[i].stub = WorkerService::NewStub( in RunScenario()
518 clients[i].stream = clients[i].stub->RunClient(alloc_context(&contexts)); in RunScenario()
519 if (!clients[i].stream->Write(args)) { in RunScenario()
527 if (!clients[i].stream->Read(&init_status)) { in RunScenario()
543 auto client = &clients[i]; in RunScenario()
549 auto client = &clients[i]; in RunScenario()
574 auto client = &clients[i]; in RunScenario()
587 auto client = &clients[i]; in RunScenario()
616 FinishClients(clients, client_mark); in RunScenario()
622 ReceiveFinalStatusFromClients(clients, merged_latencies, merged_statuses, in RunScenario()
624 ShutdownClients(clients, *result); in RunScenario()