Searched refs:servers_ (Results 1 – 8 of 8) sorted by relevance
128 for (size_t i = 0; i < servers_.size(); ++i) { in TearDown()129 servers_[i]->Shutdown(); in TearDown()136 servers_.clear(); in CreateServers()140 servers_.emplace_back(new ServerData(port)); in CreateServers()144 void StartServer(size_t index) { servers_[index]->Start(server_host_); } in StartServer()192 for (const auto& server : servers_) ports.push_back(server->port_); in GetServersPorts()293 for (const auto& server : servers_) server->service_.ResetCounters(); in ResetCounters()306 } while (servers_[server_idx]->service_.request_count() == 0); in WaitForServer()322 for (const auto& server : servers_) { in SeenAllServers()348 std::vector<std::unique_ptr<ServerData>> servers_; member in grpc::testing::__anon6ce5f15c0111::ClientLbEnd2endTest[all …]
19 servers_ = java.util.Collections.emptyList(); in ServerList()55 servers_ = new java.util.ArrayList<io.grpc.lb.v1.Server>(); in ServerList()58 servers_.add( in ServerList()71 servers_ = java.util.Collections.unmodifiableList(servers_); in ServerList()90 private java.util.List<io.grpc.lb.v1.Server> servers_; field in ServerList102 return servers_; in getServersList()116 return servers_; in getServersOrBuilderList()129 return servers_.size(); in getServersCount()142 return servers_.get(index); in getServers()156 return servers_.get(index); in getServersOrBuilder()[all …]
220 assert(servers_.empty()); in ~FirewallManager()225 servers_.push_back(server); in AddServer()230 servers_.erase(std::remove(servers_.begin(), servers_.end(), server), in RemoveServer()231 servers_.end()); in RemoveServer()238 servers_.begin(); it != servers_.end(); ++it) { in AddRule()246 servers_.begin(); it != servers_.end(); ++it) { in ClearRules()
109 std::vector<FirewallSocketServer *> servers_; variable
62 servers_(servers), in Dataset()93 TF_RETURN_IF_ERROR(b->AddScalar(servers_, &servers)); in AsGraphDefInternal()265 result = conf->set("bootstrap.servers", dataset()->servers_, errstr); in SetupStreamsLocked()268 dataset()->servers_, ":", errstr); in SetupStreamsLocked()310 const std::string servers_; member in tensorflow::KafkaDatasetOp::Dataset
279 servers_ = servers; in Prepare()281 return ResolveServerName(servers_.back()); in Prepare()326 servers_.pop_back(); in OnServerResolved()328 if (servers_.size()) { in OnServerResolved()329 if (!ResolveServerName(servers_.back())) { in OnServerResolved()
221 std::vector<rtc::SocketAddress> servers_; variable
58 balancing configuration_ and _the list of servers_ to which the client