84             "servers. E.g. export "  in get_workers()
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()
157   // servers  in postprocess_scenario_result()
288     // Since we shutdown servers and clients at the same time, clients can  in ShutdownClients()
300 static void FinishServers(const std::vector<ServerData>& servers,  in FinishServers()  argument
302   gpr_log(GPR_INFO, "Finishing servers");  in FinishServers()
303   for (size_t i = 0, i_end = servers.size(); i < i_end; i++) {  in FinishServers()
304     auto server = &servers[i];  in FinishServers()
314 static void ReceiveFinalStatusFromServer(const std::vector<ServerData>& servers,  in ReceiveFinalStatusFromServer()  argument
316   gpr_log(GPR_INFO, "Receiving final status from servers");  in ReceiveFinalStatusFromServer()
318   for (size_t i = 0, i_end = servers.size(); i < i_end; i++) {  in ReceiveFinalStatusFromServer()
319     auto server = &servers[i];  in ReceiveFinalStatusFromServer()
334 static void ShutdownServers(const std::vector<ServerData>& servers,  in ShutdownServers()  argument
336   gpr_log(GPR_INFO, "Shutdown servers");  in ShutdownServers()
337   for (size_t i = 0, i_end = servers.size(); i < i_end; i++) {  in ShutdownServers()
338     auto server = &servers[i];  in ShutdownServers()
340     // Since we shutdown servers and clients at the same time, servers can  in ShutdownServers()
413   // except for servers are clients  in RunScenario()
426   // Start servers  in RunScenario()
427   std::vector<ServerData> servers(num_servers);  in RunScenario()  local
435       servers[i].stub = WorkerService::NewStub(grpc::CreateTestChannel(  in RunScenario()
440       servers[i].stub = WorkerService::NewStub(  in RunScenario()
451     servers[i].stream = servers[i].stub->RunServer(alloc_context(&contexts));  in RunScenario()
452     if (!servers[i].stream->Write(args)) {  in RunScenario()
457     if (!servers[i].stream->Read(&init_status)) {  in RunScenario()
474     // servers  in RunScenario()
568     auto server = &servers[i];  in RunScenario()
580     auto server = &servers[i];  in RunScenario()
619     FinishServers(servers, server_mark);  in RunScenario()
627     FinishServers(servers, server_mark);  in RunScenario()
630   ReceiveFinalStatusFromServer(servers, *result);  in RunScenario()
631   ShutdownServers(servers, *result);  in RunScenario()