120   // Since we shutdown servers and clients at the same time, they both can  in IsSuccess()
125   // Since we shutdown servers and clients at the same time, server can close  in IsSuccess()
145   // all clients  in postprocess_scenario_result()
237 static void FinishClients(const std::vector<ClientData>& clients,  in FinishClients()  argument
239   gpr_log(GPR_INFO, "Finishing clients");  in FinishClients()
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
254   gpr_log(GPR_INFO, "Receiving final status from clients");  in ReceiveFinalStatusFromClients()
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
284   gpr_log(GPR_INFO, "Shutdown clients");  in ShutdownClients()
285   for (size_t i = 0, i_end = clients.size(); i < i_end; i++) {  in ShutdownClients()
286     auto client = &clients[i];  in ShutdownClients()
288     // Since we shutdown servers and clients at the same time, clients can  in ShutdownClients()
340     // Since we shutdown servers and clients at the same time, servers can  in ShutdownServers()
413   // except for servers are clients  in RunScenario()
484   // Start clients  in RunScenario()
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()
507     // of the number of clients available  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()
533   // Send an initial mark: clients can use this to know that everything is ready  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()
607   // For the case where clients lead the test such as UNARY and  in RunScenario()
608   // STREAMING_FROM_CLIENT, clients need to finish completely while a server  in RunScenario()
609   // is running to prevent the clients from being stuck while waiting for  in RunScenario()
616   FinishClients(clients, client_mark);  in RunScenario()
622   ReceiveFinalStatusFromClients(clients, merged_latencies, merged_statuses,  in RunScenario()
624   ShutdownClients(clients, *result);  in RunScenario()