Home
last modified time | relevance | path

Searched refs:shutting_down_ (Results 1 – 25 of 31) sorted by relevance

12

/external/cronet/net/dns/
Dcontext_host_resolver.cc65 DCHECK(!shutting_down_); in OnShutdown()
66 shutting_down_ = true; in OnShutdown()
77 if (shutting_down_) in CreateRequest()
94 if (shutting_down_) in CreateRequest()
106 if (shutting_down_) in CreateDohProbeRequest()
128 DCHECK(!shutting_down_); in SetRequestContext()
Dcontext_host_resolver.h101 bool shutting_down_ = false; variable
/external/rust/crates/grpcio-sys/grpc/src/core/ext/filters/client_channel/lb_policy/
Dchild_policy_handler.cc43 if (parent_->shutting_down_) return nullptr; in CreateSubchannel()
51 if (parent_->shutting_down_) return; in UpdateState()
77 if (parent_->shutting_down_) return; in RequestReresolution()
95 if (parent_->shutting_down_) return; in AddTraceEvent()
125 shutting_down_ = true; in ShutdownLocked()
Dsubchannel_list.h187 bool shutting_down() const { return shutting_down_; } in shutting_down()
228 bool shutting_down_ = false; variable
407 GPR_ASSERT(!shutting_down_); in ShutdownLocked()
408 shutting_down_ = true; in ShutdownLocked()
Dchild_policy_handler.h68 bool shutting_down_ = false; variable
/external/google-breakpad/src/client/windows/crash_generation/
Dcrash_generation_server.cc127 shutting_down_(false), in CrashGenerationServer()
146 shutting_down_ = true; in ~CrashGenerationServer()
275 if (shutting_down_) { in HandleErrorState()
580 if (shutting_down_) { in HandleDisconnectingState()
716 if (shutting_down_) { in HandleConnectionRequest()
801 if (shutting_down_) { in AddClient()
861 if (shutting_down_) { in HandleClientProcessExit()
Dcrash_generation_server.h281 bool shutting_down_; variable
/external/rust/crates/grpcio-sys/grpc/src/core/ext/filters/client_channel/lb_policy/weighted_target/
Dweighted_target.cc201 bool shutting_down_ = false; member in grpc_core::__anonb953f4580111::WeightedTargetLb
260 shutting_down_ = true; in ShutdownLocked()
269 if (shutting_down_) return; in UpdateLocked()
479 if (weighted_target_policy_->shutting_down_) return; in UpdateLocked()
594 if (weighted_child_->weighted_target_policy_->shutting_down_) return nullptr; in CreateSubchannel()
602 if (weighted_child_->weighted_target_policy_->shutting_down_) return; in UpdateState()
608 if (weighted_child_->weighted_target_policy_->shutting_down_) return; in RequestReresolution()
615 if (weighted_child_->weighted_target_policy_->shutting_down_) return; in AddTraceEvent()
/external/rust/crates/grpcio-sys/grpc/src/core/ext/filters/client_channel/lb_policy/xds/
Dxds_cluster_manager.cc197 bool shutting_down_ = false; member in grpc_core::__anonae727ce30111::XdsClusterManagerLb
246 shutting_down_ = true; in ShutdownLocked()
259 if (shutting_down_) return; in UpdateLocked()
451 if (xds_cluster_manager_policy_->shutting_down_) return; in UpdateLocked()
526 if (xds_cluster_manager_child_->xds_cluster_manager_policy_->shutting_down_) { in CreateSubchannel()
546 if (xds_cluster_manager_child_->xds_cluster_manager_policy_->shutting_down_) { in UpdateState()
572 if (xds_cluster_manager_child_->xds_cluster_manager_policy_->shutting_down_) { in RequestReresolution()
582 if (xds_cluster_manager_child_->xds_cluster_manager_policy_->shutting_down_) { in AddTraceEvent()
Dcds.cc174 bool shutting_down_ = false; member in grpc_core::__anon57b94e930111::CdsLb
237 if (parent_->shutting_down_) return nullptr; in CreateSubchannel()
245 if (parent_->shutting_down_ || parent_->child_policy_ == nullptr) return; in UpdateState()
256 if (parent_->shutting_down_) return; in RequestReresolution()
266 if (parent_->shutting_down_) return; in AddTraceEvent()
292 shutting_down_ = true; in ShutdownLocked()
Dxds_cluster_impl.cc247 bool shutting_down_ = false; member in grpc_core::__anon4ff5c95a0111::XdsClusterImplLb
385 shutting_down_ = true; in ShutdownLocked()
529 if (xds_cluster_impl_policy_->shutting_down_) return nullptr; in CreateSubchannel()
561 if (xds_cluster_impl_policy_->shutting_down_) return; in UpdateState()
580 if (xds_cluster_impl_policy_->shutting_down_) return; in RequestReresolution()
586 if (xds_cluster_impl_policy_->shutting_down_) return; in AddTraceEvent()
Dxds_cluster_resolver.cc333 bool shutting_down_ = false; member in grpc_core::__anon0187cdfa0111::XdsClusterResolverLb
353 if (xds_cluster_resolver_policy_->shutting_down_) return nullptr; in CreateSubchannel()
361 if (xds_cluster_resolver_policy_->shutting_down_ || in UpdateState()
378 if (xds_cluster_resolver_policy_->shutting_down_) return; in AddTraceEvent()
594 shutting_down_ = true; in ShutdownLocked()
680 if (shutting_down_) return; in OnEndpointChanged()
739 if (shutting_down_) return; in OnError()
752 if (shutting_down_) return; in OnResourceDoesNotExist()
1031 if (shutting_down_) return; in UpdateChildPolicyLocked()
/external/rust/crates/grpcio-sys/grpc/src/core/ext/filters/client_channel/lb_policy/priority/
Dpriority.cc229 bool shutting_down_ = false; member in grpc_core::__anon1bc0128e0111::PriorityLb
265 shutting_down_ = true; in ShutdownLocked()
548 if (priority_policy_->shutting_down_) return; in UpdateLocked()
668 !priority_policy_->shutting_down_) { in OnFailoverTimerLocked()
727 !priority_policy_->shutting_down_) { in OnDeactivationTimerLocked()
746 if (priority_->priority_policy_->shutting_down_) return; in RequestReresolution()
756 if (priority_->priority_policy_->shutting_down_) return nullptr; in CreateSubchannel()
764 if (priority_->priority_policy_->shutting_down_) return; in UpdateState()
771 if (priority_->priority_policy_->shutting_down_) return; in AddTraceEvent()
/external/tensorflow/tensorflow/core/distributed_runtime/eager/
Deager_service_impl.h47 if (shutting_down_) { in EagerServiceImpl()
68 shutting_down_ = true; in ~EagerServiceImpl()
230 bool shutting_down_ TF_GUARDED_BY(gc_thread_shutdown_mu_) = false;
/external/rust/crates/grpcio-sys/grpc/src/core/ext/filters/client_channel/lb_policy/grpclb/
Dgrpclb.cc438 bool shutting_down_ = false; member in grpc_core::__anonb6ae12be0111::GrpcLb
668 if (parent_->shutting_down_) return nullptr; in CreateSubchannel()
689 if (parent_->shutting_down_) return; in UpdateState()
728 if (parent_->shutting_down_) return; in RequestReresolution()
741 if (parent_->shutting_down_) return; in AddTraceEvent()
756 GPR_ASSERT(!grpclb_policy()->shutting_down_); in BalancerCallState()
1174 if (!grpclb_policy()->shutting_down_) { in OnBalancerMessageReceivedLocked()
1236 GPR_ASSERT(!grpclb_policy()->shutting_down_); in OnBalancerStatusReceivedLocked()
1366 shutting_down_ = true; in ShutdownLocked()
1508 if (shutting_down_) return; in StartBalancerCallLocked()
[all …]
/external/grpc-grpc/src/core/ext/filters/client_channel/lb_policy/grpclb/
Dgrpclb.cc290 bool shutting_down_ = false; member in grpc_core::__anonaeaaed6a0111::GrpcLb
503 GPR_ASSERT(!grpclb_policy()->shutting_down_); in BalancerCallState()
861 if (!grpclb_policy->shutting_down_) { in OnBalancerMessageReceivedLocked()
900 GPR_ASSERT(!grpclb_policy->shutting_down_); in OnBalancerStatusReceivedLocked()
1089 shutting_down_ = true; in ShutdownLocked()
1384 if (shutting_down_) return; in StartBalancerCallLocked()
1401 if (grpclb_policy->serverlist_ == nullptr && !grpclb_policy->shutting_down_ && in OnFallbackTimerLocked()
1441 if (!grpclb_policy->shutting_down_ && error == GRPC_ERROR_NONE && in OnBalancerCallRetryTimerLocked()
1458 if (grpclb_policy->shutting_down_) goto done; in OnBalancerChannelConnectivityChangedLocked()
1715 if (shutting_down_) return; in CreateOrUpdateRoundRobinPolicyLocked()
[all …]
/external/grpc-grpc/test/cpp/end2end/
Dthread_stress_test.cc176 shutting_down_ = false; in SetUp()
193 shutting_down_ = true; in TearDown()
233 if (!shutting_down_) { in RefreshContext()
255 bool shutting_down_; member in grpc::testing::CommonStressTestAsyncServer
/external/grpc-grpc/src/core/ext/filters/client_channel/lb_policy/
Dsubchannel_list.h201 bool shutting_down() const { return shutting_down_; } in shutting_down()
265 bool shutting_down_ = false; variable
562 GPR_ASSERT(!shutting_down_); in ShutdownLocked()
563 shutting_down_ = true; in ShutdownLocked()
/external/rust/crates/grpcio-sys/grpc/src/core/ext/filters/client_channel/health/
Dhealth_check_client.cc111 shutting_down_ = true; in Orphan()
127 if (shutting_down_) return; in StartCallLocked()
165 if (!self->shutting_down_ && error == GRPC_ERROR_NONE && in OnRetryTimer()
598 GPR_ASSERT(!health_check_client_->shutting_down_); in CallEndedLocked()
Dhealth_check_client.h161 bool shutting_down_ ABSL_GUARDED_BY(mu_) = false;
/external/rust/crates/grpcio-sys/grpc/src/core/ext/xds/
Dxds_client.cc119 bool shutting_down_ = false; member in grpc_core::XdsClient::ChannelState::RetryableCall
443 if (!parent_->shutting_down_ && in OnConnectivityStateChange()
503 shutting_down_ = true; in Orphan()
600 shutting_down_ = true; in Orphan()
623 if (shutting_down_) return; in StartNewCallLocked()
638 if (shutting_down_) return; in StartRetryTimerLocked()
667 if (!shutting_down_ && error == GRPC_ERROR_NONE) { in OnRetryTimerLocked()
1266 if (xds_client()->shutting_down_) return true; in OnResponseReceivedLocked()
1715 if (xds_client()->shutting_down_) return true; in OnResponseReceivedLocked()
1755 GPR_ASSERT(!xds_client()->shutting_down_); in OnStatusReceivedLocked()
[all …]
Dxds_client.h262 bool shutting_down_ = false; variable
366 bool shutting_down_ ABSL_GUARDED_BY(mu_) = false;
/external/leveldb/db/
Ddb_impl.cc137 shutting_down_(false), in DBImpl()
155 shutting_down_.store(true, std::memory_order_release); in ~DBImpl()
560 if (s.ok() && shutting_down_.load(std::memory_order_acquire)) { in CompactMemTable()
623 while (!manual.done && !shutting_down_.load(std::memory_order_acquire) && in TEST_CompactRange()
666 } else if (shutting_down_.load(std::memory_order_acquire)) { in MaybeScheduleCompaction()
686 if (shutting_down_.load(std::memory_order_acquire)) { in BackgroundCall()
762 } else if (shutting_down_.load(std::memory_order_acquire)) { in BackgroundCompaction()
921 while (input->Valid() && !shutting_down_.load(std::memory_order_acquire)) { in DoCompactionWork()
1016 if (status.ok() && shutting_down_.load(std::memory_order_acquire)) { in DoCompactionWork()
Ddb_impl.h175 std::atomic<bool> shutting_down_; variable
/external/tensorflow/tensorflow/core/distributed_runtime/coordination/
Dcoordination_service_agent.cc144 bool shutting_down_ TF_GUARDED_BY(heartbeat_thread_shutdown_mu_) = false;
228 shutting_down_ = true; in StopHeartbeat()
295 if (shutting_down_) { in Connect()
487 shutting_down_ = false; in Reset()

12