Home
last modified time | relevance | path

Searched refs:child_policy_ (Results 1 – 9 of 9) sorted by relevance

/external/rust/crates/grpcio-sys/grpc/src/core/ext/filters/client_channel/lb_policy/
Dchild_policy_handler.cc65 parent_->child_policy_->interested_parties(), in UpdateState()
67 parent_->child_policy_ = std::move(parent_->pending_child_policy_); in UpdateState()
84 : parent_->child_policy_.get(); in RequestReresolution()
110 return child_ == parent_->child_policy_.get(); in CalledByCurrentChild()
126 if (child_policy_ != nullptr) { in ShutdownLocked()
129 this, child_policy_.get()); in ShutdownLocked()
131 grpc_pollset_set_del_pollset_set(child_policy_->interested_parties(), in ShutdownLocked()
133 child_policy_.reset(); in ShutdownLocked()
199 child_policy_ == nullptr || in UpdateLocked()
216 child_policy_ == nullptr ? "" : "pending ", args.config->name()); in UpdateLocked()
[all …]
Dchild_policy_handler.h76 OrphanablePtr<LoadBalancingPolicy> child_policy_; variable
/external/rust/crates/grpcio-sys/grpc/src/core/ext/filters/client_channel/lb_policy/xds/
Dcds.cc147 OrphanablePtr<LoadBalancingPolicy> child_policy_; member in grpc_core::__anoncf5894350111::CdsLb
214 if (parent_->shutting_down_ || parent_->child_policy_ == nullptr) return; in UpdateState()
278 if (child_policy_ != nullptr) { in MaybeDestroyChildPolicyLocked()
279 grpc_pollset_set_del_pollset_set(child_policy_->interested_parties(), in MaybeDestroyChildPolicyLocked()
281 child_policy_.reset(); in MaybeDestroyChildPolicyLocked()
286 if (child_policy_ != nullptr) child_policy_->ResetBackoffLocked(); in ResetBackoffLocked()
383 if (child_policy_ == nullptr) { in OnClusterChanged()
388 child_policy_ = LoadBalancingPolicyRegistry::CreateLoadBalancingPolicy( in OnClusterChanged()
390 if (child_policy_ == nullptr) { in OnClusterChanged()
395 grpc_pollset_set_add_pollset_set(child_policy_->interested_parties(), in OnClusterChanged()
[all …]
Dxds_cluster_impl.cc130 : child_policy_(std::move(child_policy)), in XdsClusterImplLbConfig()
141 return child_policy_; in child_policy()
156 RefCountedPtr<LoadBalancingPolicy::Config> child_policy_; member in grpc_core::__anonc021a63c0111::XdsClusterImplLbConfig
267 OrphanablePtr<LoadBalancingPolicy> child_policy_; member in grpc_core::__anonc021a63c0111::XdsClusterImplLb
403 if (child_policy_ != nullptr) { in ShutdownLocked()
404 grpc_pollset_set_del_pollset_set(child_policy_->interested_parties(), in ShutdownLocked()
406 child_policy_.reset(); in ShutdownLocked()
416 if (child_policy_ != nullptr) child_policy_->ExitIdleLocked(); in ExitIdleLocked()
422 if (child_policy_ != nullptr) child_policy_->ResetBackoffLocked(); in ResetBackoffLocked()
518 if (child_policy_ == nullptr) { in UpdateChildPolicyLocked()
[all …]
Dxds_cluster_manager.cc174 OrphanablePtr<LoadBalancingPolicy> child_policy_; member in grpc_core::__anon2bdcc6850111::XdsClusterManagerLb::ClusterChild
421 child_policy_->interested_parties(), in Orphan()
423 child_policy_.reset(); in Orphan()
474 if (child_policy_ == nullptr) { in UpdateLocked()
475 child_policy_ = CreateChildPolicyLocked(args); in UpdateLocked()
489 child_policy_.get()); in UpdateLocked()
491 child_policy_->UpdateLocked(std::move(update_args)); in UpdateLocked()
495 child_policy_->ExitIdleLocked(); in ExitIdleLocked()
499 child_policy_->ResetBackoffLocked(); in ResetBackoffLocked()
Dxds_cluster_resolver.cc335 OrphanablePtr<LoadBalancingPolicy> child_policy_; member in grpc_core::__anon2c3b4bdc0111::XdsClusterResolverLb
354 xds_cluster_resolver_policy_->child_policy_ == nullptr) { in UpdateState()
600 if (child_policy_ != nullptr) { in MaybeDestroyChildPolicyLocked()
601 grpc_pollset_set_del_pollset_set(child_policy_->interested_parties(), in MaybeDestroyChildPolicyLocked()
603 child_policy_.reset(); in MaybeDestroyChildPolicyLocked()
620 if (child_policy_ != nullptr) UpdateChildPolicyLocked(); in UpdateLocked()
653 if (child_policy_ != nullptr) { in ResetBackoffLocked()
654 child_policy_->ResetBackoffLocked(); in ResetBackoffLocked()
969 if (child_policy_ == nullptr) { in UpdateChildPolicyLocked()
970 child_policy_ = CreateChildPolicyLocked(update_args.args); in UpdateChildPolicyLocked()
[all …]
/external/rust/crates/grpcio-sys/grpc/src/core/ext/filters/client_channel/lb_policy/weighted_target/
Dweighted_target.cc178 OrphanablePtr<LoadBalancingPolicy> child_policy_; member in grpc_core::__anon33b6bffa0111::WeightedTargetLb::WeightedChild
435 child_policy_->interested_parties(), in Orphan()
437 child_policy_.reset(); in Orphan()
493 if (child_policy_ == nullptr) { in UpdateLocked()
494 child_policy_ = CreateChildPolicyLocked(args); in UpdateLocked()
507 child_policy_.get()); in UpdateLocked()
509 child_policy_->UpdateLocked(std::move(update_args)); in UpdateLocked()
513 child_policy_->ResetBackoffLocked(); in ResetBackoffLocked()
530 if (state == GRPC_CHANNEL_IDLE) child_policy_->ExitIdleLocked(); in OnConnectivityStateUpdateLocked()
/external/rust/crates/grpcio-sys/grpc/src/core/ext/filters/client_channel/lb_policy/priority/
Dpriority.cc191 OrphanablePtr<LoadBalancingPolicy> child_policy_; member in grpc_core::__anon47a44ab00111::PriorityLb::ChildPriority
531 grpc_pollset_set_del_pollset_set(child_policy_->interested_parties(), in Orphan()
533 child_policy_.reset(); in Orphan()
553 if (child_policy_ == nullptr) { in UpdateLocked()
554 child_policy_ = CreateChildPolicyLocked(priority_policy_->args_); in UpdateLocked()
565 priority_policy_.get(), name_.c_str(), this, child_policy_.get()); in UpdateLocked()
567 child_policy_->UpdateLocked(std::move(update_args)); in UpdateLocked()
600 child_policy_->ExitIdleLocked(); in ExitIdleLocked()
604 child_policy_->ResetBackoffLocked(); in ResetBackoffLocked()
/external/rust/crates/grpcio-sys/grpc/src/core/ext/filters/client_channel/lb_policy/grpclb/
Dgrpclb.cc138 : child_policy_(std::move(child_policy)), in GrpcLbConfig()
143 return child_policy_; in child_policy()
149 RefCountedPtr<LoadBalancingPolicy::Config> child_policy_; member in grpc_core::__anon524789e00111::GrpcLbConfig
479 OrphanablePtr<LoadBalancingPolicy> child_policy_; member in grpc_core::__anon524789e00111::GrpcLb
1373 if (child_policy_ != nullptr) { in ShutdownLocked()
1374 grpc_pollset_set_del_pollset_set(child_policy_->interested_parties(), in ShutdownLocked()
1376 child_policy_.reset(); in ShutdownLocked()
1402 if (child_policy_ != nullptr) { in ResetBackoffLocked()
1403 child_policy_->ResetBackoffLocked(); in ResetBackoffLocked()
1413 if (child_policy_ != nullptr) CreateOrUpdateChildPolicyLocked(); in UpdateLocked()
[all …]