Lines Matching refs:servers
301 static void FinishServers(const std::vector<ServerData>& servers, in FinishServers() argument
304 for (size_t i = 0, i_end = servers.size(); i < i_end; i++) { in FinishServers()
305 auto server = &servers[i]; in FinishServers()
317 static void ReceiveFinalStatusFromServer(const std::vector<ServerData>& servers, in ReceiveFinalStatusFromServer() argument
321 for (size_t i = 0, i_end = servers.size(); i < i_end; i++) { in ReceiveFinalStatusFromServer()
322 auto server = &servers[i]; in ReceiveFinalStatusFromServer()
337 static void ShutdownServers(const std::vector<ServerData>& servers, in ShutdownServers() argument
340 for (size_t i = 0, i_end = servers.size(); i < i_end; i++) { in ShutdownServers()
341 auto server = &servers[i]; in ShutdownServers()
430 std::vector<ServerData> servers(num_servers); in RunScenario() local
438 servers[i].stub = WorkerService::NewStub(grpc::CreateTestChannel( in RunScenario()
443 servers[i].stub = WorkerService::NewStub( in RunScenario()
456 servers[i].stream = servers[i].stub->RunServer(alloc_context(&contexts)); in RunScenario()
457 if (!servers[i].stream->Write(args)) { in RunScenario()
462 if (!servers[i].stream->Read(&init_status)) { in RunScenario()
570 auto server = &servers[i]; in RunScenario()
584 auto server = &servers[i]; in RunScenario()
623 FinishServers(servers, server_mark); in RunScenario()
631 FinishServers(servers, server_mark); in RunScenario()
634 ReceiveFinalStatusFromServer(servers, *result); in RunScenario()
635 ShutdownServers(servers, *result); in RunScenario()