Searched refs:backends_ (Results 1 – 7 of 7) sorted by relevance
364 backends_.emplace_back(new BackendServiceImpl()); in SetUp()366 "backend", server_host_, backends_.back().get())); in SetUp()379 for (size_t i = 0; i < backends_.size(); ++i) { in TearDown()380 if (backends_[i]->Shutdown()) backend_servers_[i].Shutdown(); in TearDown()422 for (const auto& backend : backends_) backend->ResetCounters(); in ResetBackendCounters()434 for (const auto& backend : backends_) { in SeenAllBackends()479 } while (backends_[backend_idx]->request_count() == 0); in WaitForBackend()623 std::vector<std::unique_ptr<BackendServiceImpl>> backends_; member in grpc::testing::__anon8b08f2880111::GrpclbEnd2endTest652 for (size_t i = 0; i < backends_.size(); ++i) { in TEST_F()681 for (size_t i = 0; i < backends_.size(); ++i) { in TEST_F()[all …]
104 backends_.resize(num_backends); in ConfigureProxy()107 backends_[i].port = grpc_pick_unused_port_or_die(); in ConfigureProxy()110 "localhost:" + to_string(backends_[i].port); in ConfigureProxy()113 backends_[i].service.reset(new TestServiceImpl); in ConfigureProxy()116 backend_builder.RegisterService(backends_[i].service.get()); in ConfigureProxy()117 backends_[i].server = backend_builder.BuildAndStart(); in ConfigureProxy()201 std::vector<BackendData> backends_; member in grpc::testing::ChannelzServerTest
719 TracingBackendId backend_id = backends_.size(); in Initialize()720 backends_.emplace_back(); in Initialize()721 RegisteredBackend& rb = backends_.back(); in Initialize()1031 PERFETTO_CHECK(backend_id < backends_.size()); in StopDataSource_AsyncEnd()1032 ProducerImpl* producer = backends_[backend_id].producer.get(); in StopDataSource_AsyncEnd()1079 countdown = backends_.size(); in SyncProducersForTesting()1081 for (auto& backend : backends_) { in SyncProducersForTesting()1101 for (auto& backend : backends_) in SyncProducersForTesting()1160 for (RegisteredBackend& backend : backends_) { in UpdateDataSourcesOnAllBackends()1299 for (RegisteredBackend& backend : backends_) { in DestroyTracingSession()[all …]
401 std::vector<RegisteredBackend> backends_; variable
129 auto result = registry.backends_.emplace(compilation_device_name, Backend()); in RegisterBackend()141 return registry.backends_.find(device_name) != registry.backends_.end(); in IsCompilationDevice()247 for (auto& backend : registry.backends_) { in RegisterCompilationKernels()347 auto it = registry.backends_.find(compilation_device_name); in DeviceKernels()348 CHECK(it != registry.backends_.end()) in DeviceKernels()464 for (const auto& backend_pair : registry.backends_) { in BackendNames()473 return registry.backends_.find(name) != registry.backends_.end(); in IsBackendRegistered()
241 std::unordered_map<string, Backend> backends_ TF_GUARDED_BY(mutex_);
271 backends_.emplace_back(new BackendServiceImpl()); in Start()273 "backend", server_host_, backends_.back().get())); in Start()299 for (size_t i = 0; i < backends_.size(); ++i) { in Shutdown()309 std::vector<std::unique_ptr<BackendServiceImpl>> backends_; member in grpc::testing::__anonec6241e80111::ClientChannelStressTest