| /external/grpc-grpc/src/cpp/server/load_reporter/ |
| D | load_reporter_async_service_impl.cc | 49 shutdown_ = true; in ~LoadReporterAsyncServiceImpl()
66 if (shutdown_) return; in ScheduleNextFetchAndSample()
101 GPR_ASSERT(service->shutdown_); in Work()
123 if (service->shutdown_) return; in CreateAndStart()
158 if (!ok || shutdown_) { in OnRequestDelivered()
168 if (service_->shutdown_) { in OnRequestDelivered()
189 if (!ok || shutdown_) { in OnReadDone()
226 if (service_->shutdown_) { in OnReadDone()
249 if (!ok || shutdown_) { in ScheduleNextReport()
258 if (service_->shutdown_) { in ScheduleNextReport()
[all …]
|
| D | load_reporter_async_service_impl.h | 162 bool shutdown_{false};
185 std::atomic_bool shutdown_{false};
|
| /external/grpc-grpc/src/cpp/server/ |
| D | dynamic_thread_pool.cc | 48 if ((pool_->shutdown_) && (pool_->nthreads_ == 0)) { in ThreadFunc()
57 if (!shutdown_ && callbacks_.empty()) { in ThreadFunc()
73 } else if (shutdown_) { in ThreadFunc()
80 : shutdown_(false), in DynamicThreadPool()
99 shutdown_ = true; in ~DynamicThreadPool()
|
| D | dynamic_thread_pool.h | 56 bool shutdown_; variable
|
| D | server_cc.cc | 397 shutdown_(false), in Server()
450 if (started_ && !shutdown_) { in ~Server()
602 if (!shutdown_) { in ShutdownInternal()
603 shutdown_ = true; in ShutdownInternal()
|
| /external/grpc-grpc/src/cpp/thread_manager/ |
| D | thread_manager.cc | 54 : shutdown_(false), in ThreadManager()
83 shutdown_ = true; in Shutdown()
88 return shutdown_; in IsShutdown()
160 if (shutdown_ || num_pollers_ > max_pollers_) done = true; in MainWorkLoop()
170 if (!shutdown_ && num_pollers_ < min_pollers_) { in MainWorkLoop()
204 if (shutdown_) done = true; in MainWorkLoop()
|
| D | thread_manager.h | 145 bool shutdown_; variable
|
| /external/grpc-grpc/test/cpp/qps/ |
| D | client_sync.cc | 152 shutdown_(num_threads_), in SynchronousStreamingClient()
174 std::vector<Bool> shutdown_; member in grpc::testing::SynchronousStreamingClient
184 if (!shutdown_[thread_idx].val) { in FinishStream()
200 shutdown_[i].val = true; in CleanupAllStreams()
234 if (!shutdown_[thread_idx].val) { in InitThreadFuncImpl()
266 if (!shutdown_[thread_idx].val) { in ThreadFuncImpl()
293 if (!shutdown_[thread_idx].val) { in InitThreadFuncImpl()
319 if (!shutdown_[thread_idx].val) { in ThreadFuncImpl()
343 if (!shutdown_[thread_idx].val) { in InitThreadFuncImpl()
364 if (!shutdown_[thread_idx].val) { in ThreadFuncImpl()
[all …]
|
| /external/grpc-grpc/test/cpp/end2end/ |
| D | shutdown_test.cc | 63 ShutdownTest() : shutdown_(false), service_(&ev_) { gpr_event_init(&ev_); } in ShutdownTest()
82 void TearDown() override { GPR_ASSERT(shutdown_); } in TearDown()
104 GPR_ASSERT(!shutdown_); in SendRequest()
106 GPR_ASSERT(shutdown_); in SendRequest()
113 bool shutdown_; member in grpc::testing::ShutdownTest
152 shutdown_ = true; in TEST_P()
|
| D | grpclb_end2end_test.cc | 152 const bool prev = !shutdown_; in Shutdown()
153 shutdown_ = true; in Shutdown()
160 bool shutdown_ = false; member in grpc::testing::__anonf0b0436a0111::BackendServiceImpl
198 shutdown_(false) {} in BalancerServiceImpl()
231 if (shutdown_) goto done; in BalanceLoad()
237 if (shutdown_) goto done; in BalanceLoad()
283 const bool prev = !shutdown_; in Shutdown()
284 shutdown_ = true; in Shutdown()
342 bool shutdown_; member in grpc::testing::__anonf0b0436a0111::BalancerServiceImpl
|
| /external/grpc-grpc/test/cpp/interop/ |
| D | reconnect_interop_server.cc | 68 shutdown_(false) { in ReconnectServiceImpl()
84 while (serving_ && !shutdown_) { in Start()
87 if (shutdown_) { in Start()
148 shutdown_ = true; in Shutdown()
157 bool shutdown_; member in ReconnectServiceImpl
|
| /external/grpc-grpc/test/cpp/client/ |
| D | client_channel_stress_test.cc | 77 while (!shutdown_) { in BalanceLoad()
86 void Shutdown() { shutdown_ = true; } in Shutdown()
126 std::atomic_bool shutdown_{false}; member in grpc::testing::__anondb2f344a0111::BalancerServiceImpl
240 while (!shutdown_) { in KeepSendingRequests()
291 shutdown_ = true; in Shutdown()
304 std::atomic_bool shutdown_{false}; member in grpc::testing::__anondb2f344a0111::ClientChannelStressTest
|
| /external/parameter-framework/asio-1.10.6/include/asio/detail/impl/ |
| D | select_reactor.ipp | 35 shutdown_(false)
47 shutdown_ = true;
102 if (shutdown_)
|
| D | select_reactor.hpp | 44 if (shutdown_) in schedule_timer()
|
| D | task_io_service.ipp | 91 shutdown_(false)
99 shutdown_ = true;
118 if (!shutdown_ && !task_)
|
| /external/grpc-grpc/src/core/ext/filters/client_channel/lb_policy/round_robin/ |
| D | round_robin.cc | 218 bool shutdown_ = false; member in grpc_core::__anon085e1c5c0111::RoundRobin
273 shutdown_ = true; in ShutdownLocked()
384 gpr_log(GPR_INFO, "[RR %p] Trying to pick (shutdown: %d)", this, shutdown_); in PickLocked()
386 GPR_ASSERT(!shutdown_); in PickLocked()
|
| /external/libchrome/base/synchronization/ |
| D | condition_variable_unittest.cc | 146 bool shutdown_; // Set when threads need to terminate. member in base::__anon16d4e8c80111::WorkQueue
516 shutdown_(false) { in WorkQueue()
581 return shutdown_; in shutdown()
678 shutdown_ = true; in SetShutdown()
|
| /external/tensorflow/tensorflow/core/distributed_runtime/ |
| D | master.h | 83 bool shutdown_ GUARDED_BY(mu_) = false;
|
| D | master.cc | 85 shutdown_ = true; in ~Master()
97 if (shutdown_) { in GC()
|
| /external/parameter-framework/asio-1.10.6/include/asio/detail/ |
| D | task_io_service.hpp | 179 bool shutdown_; member in asio::detail::task_io_service
|
| D | select_reactor.hpp | 171 bool shutdown_; member in asio::detail::select_reactor
|
| /external/grpc-grpc/include/grpcpp/ |
| D | server.h | 209 bool shutdown_; variable
|
| /external/grpc-grpc/src/core/ext/filters/client_channel/lb_policy/pick_first/ |
| D | pick_first.cc | 141 bool shutdown_ = false; member in grpc_core::__anon2093fdd60111::PickFirst
196 shutdown_ = true; in ShutdownLocked()
|
| /external/protobuf/src/google/protobuf/ |
| D | message.cc | 481 } shutdown_; variable
|