Home
last modified time | relevance | path

Searched refs:LoadBalancingPolicy (Results 1 – 25 of 33) sorted by relevance

12

/external/rust/crates/grpcio-sys/grpc/src/core/ext/filters/client_channel/
Dlb_policy.cc34 LoadBalancingPolicy::LoadBalancingPolicy(Args args, intptr_t initial_refcount) in LoadBalancingPolicy() function in grpc_core::LoadBalancingPolicy
44 LoadBalancingPolicy::~LoadBalancingPolicy() { in ~LoadBalancingPolicy()
48 void LoadBalancingPolicy::Orphan() { in Orphan()
57 LoadBalancingPolicy::UpdateArgs::UpdateArgs(const UpdateArgs& other) { in UpdateArgs()
63 LoadBalancingPolicy::UpdateArgs::UpdateArgs(UpdateArgs&& other) noexcept { in UpdateArgs()
71 LoadBalancingPolicy::UpdateArgs& LoadBalancingPolicy::UpdateArgs::operator=( in operator =()
80 LoadBalancingPolicy::UpdateArgs& LoadBalancingPolicy::UpdateArgs::operator=( in operator =()
95 LoadBalancingPolicy::PickResult LoadBalancingPolicy::QueuePicker::Pick( in Pick()
114 auto* parent = static_cast<LoadBalancingPolicy*>(arg); in Pick()
134 LoadBalancingPolicy::PickResult
[all …]
Dlb_policy.h82 class LoadBalancingPolicy : public InternallyRefCounted<LoadBalancingPolicy> {
342 explicit LoadBalancingPolicy(Args args, intptr_t initial_refcount = 1);
343 ~LoadBalancingPolicy() override;
346 LoadBalancingPolicy(const LoadBalancingPolicy&) = delete;
347 LoadBalancingPolicy& operator=(const LoadBalancingPolicy&) = delete;
375 explicit QueuePicker(RefCountedPtr<LoadBalancingPolicy> parent) in QueuePicker()
383 RefCountedPtr<LoadBalancingPolicy> parent_;
Dlb_policy_factory.h34 virtual OrphanablePtr<LoadBalancingPolicy> CreateLoadBalancingPolicy(
35 LoadBalancingPolicy::Args) const = 0;
41 virtual RefCountedPtr<LoadBalancingPolicy::Config> ParseLoadBalancingConfig(
Dlb_policy_registry.h48 static OrphanablePtr<LoadBalancingPolicy> CreateLoadBalancingPolicy(
49 const char* name, LoadBalancingPolicy::Args args);
59 static RefCountedPtr<LoadBalancingPolicy::Config> ParseLoadBalancingConfig(
Dbackend_metric.cc52 const LoadBalancingPolicy::BackendMetricData* ParseBackendMetricData( in ParseBackendMetricData()
61 LoadBalancingPolicy::BackendMetricData* backend_metric_data = in ParseBackendMetricData()
62 arena->New<LoadBalancingPolicy::BackendMetricData>(); in ParseBackendMetricData()
Dresolver_result_parsing.h49 RefCountedPtr<LoadBalancingPolicy::Config> parsed_lb_config, in ClientChannelGlobalParsedConfig()
58 RefCountedPtr<LoadBalancingPolicy::Config> parsed_lb_config() const { in parsed_lb_config()
75 RefCountedPtr<LoadBalancingPolicy::Config> parsed_lb_config_;
Dlb_policy_registry.cc92 OrphanablePtr<LoadBalancingPolicy>
94 const char* name, LoadBalancingPolicy::Args args) { in CreateLoadBalancingPolicy()
165 RefCountedPtr<LoadBalancingPolicy::Config>
/external/rust/crates/grpcio-sys/grpc/src/core/ext/filters/client_channel/lb_policy/
Dchild_policy_handler.h34 class ChildPolicyHandler : public LoadBalancingPolicy {
37 : LoadBalancingPolicy(std::move(args)), tracer_(tracer) {} in ChildPolicyHandler()
48 LoadBalancingPolicy::Config* old_config,
49 LoadBalancingPolicy::Config* new_config) const;
54 virtual OrphanablePtr<LoadBalancingPolicy> CreateLoadBalancingPolicy(
55 const char* name, LoadBalancingPolicy::Args args) const;
62 OrphanablePtr<LoadBalancingPolicy> CreateChildPolicy(
73 RefCountedPtr<LoadBalancingPolicy::Config> current_config_;
76 OrphanablePtr<LoadBalancingPolicy> child_policy_;
77 OrphanablePtr<LoadBalancingPolicy> pending_child_policy_;
Dchild_policy_handler.cc34 : public LoadBalancingPolicy::ChannelControlHelper {
81 const LoadBalancingPolicy* latest_child_policy = in RequestReresolution()
100 void set_child(LoadBalancingPolicy* child) { child_ = child; } in set_child()
114 LoadBalancingPolicy* child_ = nullptr;
204 LoadBalancingPolicy* policy_to_update = nullptr; in UpdateLocked()
259 OrphanablePtr<LoadBalancingPolicy> ChildPolicyHandler::CreateChildPolicy( in CreateChildPolicy()
262 LoadBalancingPolicy::Args lb_policy_args; in CreateChildPolicy()
267 OrphanablePtr<LoadBalancingPolicy> lb_policy = in CreateChildPolicy()
288 LoadBalancingPolicy::Config* old_config, in ConfigChangeRequiresNewPolicyInstance()
289 LoadBalancingPolicy::Config* new_config) const { in ConfigChangeRequiresNewPolicyInstance()
[all …]
Dsubchannel_list.h190 LoadBalancingPolicy* policy() const { return policy_; } in policy()
204 SubchannelList(LoadBalancingPolicy* policy, TraceFlag* tracer,
206 LoadBalancingPolicy::ChannelControlHelper* helper,
218 LoadBalancingPolicy* policy_;
355 LoadBalancingPolicy* policy, TraceFlag* tracer, ServerAddressList addresses, in SubchannelList()
356 LoadBalancingPolicy::ChannelControlHelper* helper, in SubchannelList()
/external/grpc-grpc/src/core/ext/filters/client_channel/
Dlb_policy.h45 class LoadBalancingPolicy
46 : public InternallyRefCountedWithTracing<LoadBalancingPolicy> {
92 LoadBalancingPolicy(const LoadBalancingPolicy&) = delete;
93 LoadBalancingPolicy& operator=(const LoadBalancingPolicy&) = delete;
139 virtual void HandOffPendingPicksLocked(LoadBalancingPolicy* new_policy)
161 GRPC_CLOSURE_CREATE(&LoadBalancingPolicy::ShutdownAndUnrefLocked, this, in Orphan()
179 explicit LoadBalancingPolicy(const Args& args);
180 virtual ~LoadBalancingPolicy();
198 LoadBalancingPolicy* policy = static_cast<LoadBalancingPolicy*>(arg); in ShutdownAndUnrefLocked()
Dlb_policy.cc29 LoadBalancingPolicy::LoadBalancingPolicy(const Args& args) in LoadBalancingPolicy() function in grpc_core::LoadBalancingPolicy
36 LoadBalancingPolicy::~LoadBalancingPolicy() { in ~LoadBalancingPolicy()
41 void LoadBalancingPolicy::TryReresolutionLocked( in TryReresolutionLocked()
Dlb_policy_registry.h48 static OrphanablePtr<LoadBalancingPolicy> CreateLoadBalancingPolicy(
49 const char* name, const LoadBalancingPolicy::Args& args);
Dlb_policy_factory.h117 virtual OrphanablePtr<LoadBalancingPolicy> CreateLoadBalancingPolicy(
118 const LoadBalancingPolicy::Args& args) const GRPC_ABSTRACT;
Dlb_policy_registry.cc85 OrphanablePtr<LoadBalancingPolicy>
87 const char* name, const LoadBalancingPolicy::Args& args) { in CreateLoadBalancingPolicy()
/external/rust/crates/grpcio-sys/grpc/src/core/ext/filters/client_channel/lb_policy/xds/
Dxds_cluster_manager.cc53 class XdsClusterManagerLbConfig : public LoadBalancingPolicy::Config {
56 std::map<std::string, RefCountedPtr<LoadBalancingPolicy::Config>>;
70 class XdsClusterManagerLb : public LoadBalancingPolicy {
124 void UpdateLocked(RefCountedPtr<LoadBalancingPolicy::Config> config,
162 OrphanablePtr<LoadBalancingPolicy> CreateChildPolicyLocked(
174 OrphanablePtr<LoadBalancingPolicy> child_policy_;
231 : LoadBalancingPolicy(std::move(args)) {} in XdsClusterManagerLb()
276 const RefCountedPtr<LoadBalancingPolicy::Config>& config = p.second; in UpdateLocked()
434 OrphanablePtr<LoadBalancingPolicy>
437 LoadBalancingPolicy::Args lb_policy_args; in CreateChildPolicyLocked()
[all …]
Dxds_cluster_impl.cc122 class XdsClusterImplLbConfig : public LoadBalancingPolicy::Config {
125 RefCountedPtr<LoadBalancingPolicy::Config> child_policy, in XdsClusterImplLbConfig()
140 RefCountedPtr<LoadBalancingPolicy::Config> child_policy() const { in child_policy()
156 RefCountedPtr<LoadBalancingPolicy::Config> child_policy_;
165 class XdsClusterImplLb : public LoadBalancingPolicy {
245 OrphanablePtr<LoadBalancingPolicy> CreateChildPolicyLocked(
267 OrphanablePtr<LoadBalancingPolicy> child_policy_;
294 LoadBalancingPolicy::PickResult XdsClusterImplLb::Picker::Pick( in Pick()
295 LoadBalancingPolicy::PickArgs args) { in Pick()
381 : LoadBalancingPolicy(std::move(args)), xds_client_(std::move(xds_client)) { in XdsClusterImplLb()
[all …]
Dxds_cluster_resolver.cc60 class XdsClusterResolverLbConfig : public LoadBalancingPolicy::Config {
108 class XdsClusterResolverLb : public LoadBalancingPolicy {
306 OrphanablePtr<LoadBalancingPolicy> CreateChildPolicyLocked(
335 OrphanablePtr<LoadBalancingPolicy> child_policy_;
530 : LoadBalancingPolicy(std::move(args)), xds_client_(std::move(xds_client)) { in XdsClusterResolverLb()
823 RefCountedPtr<LoadBalancingPolicy::Config>
938 RefCountedPtr<LoadBalancingPolicy::Config> config = in CreateChildPolicyConfigLocked()
987 OrphanablePtr<LoadBalancingPolicy>
989 LoadBalancingPolicy::Args lb_policy_args; in CreateChildPolicyLocked()
994 OrphanablePtr<LoadBalancingPolicy> lb_policy = in CreateChildPolicyLocked()
[all …]
Dcds.cc47 class CdsLbConfig : public LoadBalancingPolicy::Config {
58 class CdsLb : public LoadBalancingPolicy {
147 OrphanablePtr<LoadBalancingPolicy> child_policy_;
244 : LoadBalancingPolicy(std::move(args)), xds_client_(std::move(xds_client)) { in CdsLb()
376 RefCountedPtr<LoadBalancingPolicy::Config> config = in OnClusterChanged()
384 LoadBalancingPolicy::Args args; in OnClusterChanged()
576 OrphanablePtr<LoadBalancingPolicy> CreateLoadBalancingPolicy( in CreateLoadBalancingPolicy()
577 LoadBalancingPolicy::Args args) const override { in CreateLoadBalancingPolicy()
592 RefCountedPtr<LoadBalancingPolicy::Config> ParseLoadBalancingConfig( in ParseLoadBalancingConfig()
/external/rust/crates/grpcio-sys/grpc/src/core/ext/filters/client_channel/lb_policy/weighted_target/
Dweighted_target.cc54 class WeightedTargetLbConfig : public LoadBalancingPolicy::Config {
58 RefCountedPtr<LoadBalancingPolicy::Config> config;
75 class WeightedTargetLb : public LoadBalancingPolicy {
161 OrphanablePtr<LoadBalancingPolicy> CreateChildPolicyLocked(
178 OrphanablePtr<LoadBalancingPolicy> child_policy_;
242 : LoadBalancingPolicy(std::move(args)) { in WeightedTargetLb()
449 OrphanablePtr<LoadBalancingPolicy>
452 LoadBalancingPolicy::Args lb_policy_args; in CreateChildPolicyLocked()
457 OrphanablePtr<LoadBalancingPolicy> lb_policy = in CreateChildPolicyLocked()
626 OrphanablePtr<LoadBalancingPolicy> CreateLoadBalancingPolicy( in CreateLoadBalancingPolicy()
[all …]
/external/rust/crates/grpcio-sys/grpc/src/core/ext/filters/client_channel/lb_policy/priority/
Dpriority.cc57 class PriorityLbConfig : public LoadBalancingPolicy::Config {
60 RefCountedPtr<LoadBalancingPolicy::Config> config;
81 class PriorityLb : public LoadBalancingPolicy {
103 void UpdateLocked(RefCountedPtr<LoadBalancingPolicy::Config> config,
173 OrphanablePtr<LoadBalancingPolicy> CreateChildPolicyLocked(
191 OrphanablePtr<LoadBalancingPolicy> child_policy_;
245 : LoadBalancingPolicy(std::move(args)), in PriorityLb()
544 RefCountedPtr<LoadBalancingPolicy::Config> config, in UpdateLocked()
570 OrphanablePtr<LoadBalancingPolicy>
573 LoadBalancingPolicy::Args lb_policy_args; in CreateChildPolicyLocked()
[all …]
/external/rust/crates/grpcio-sys/grpc/src/core/ext/filters/client_channel/lb_policy/round_robin/
Dround_robin.cc58 class RoundRobin : public LoadBalancingPolicy {
226 RoundRobin::RoundRobin(Args args) : LoadBalancingPolicy(std::move(args)) { in RoundRobin()
471 class RoundRobinConfig : public LoadBalancingPolicy::Config {
482 OrphanablePtr<LoadBalancingPolicy> CreateLoadBalancingPolicy( in CreateLoadBalancingPolicy()
483 LoadBalancingPolicy::Args args) const override { in CreateLoadBalancingPolicy()
489 RefCountedPtr<LoadBalancingPolicy::Config> ParseLoadBalancingConfig( in ParseLoadBalancingConfig()
/external/rust/crates/grpcio-sys/grpc/src/core/ext/filters/client_channel/lb_policy/pick_first/
Dpick_first.cc47 class PickFirst : public LoadBalancingPolicy {
145 PickFirst::PickFirst(Args args) : LoadBalancingPolicy(std::move(args)) { in PickFirst()
481 class PickFirstConfig : public LoadBalancingPolicy::Config {
492 OrphanablePtr<LoadBalancingPolicy> CreateLoadBalancingPolicy( in CreateLoadBalancingPolicy()
493 LoadBalancingPolicy::Args args) const override { in CreateLoadBalancingPolicy()
499 RefCountedPtr<LoadBalancingPolicy::Config> ParseLoadBalancingConfig( in ParseLoadBalancingConfig()
/external/grpc-grpc/src/core/ext/filters/client_channel/lb_policy/pick_first/
Dpick_first.cc45 class PickFirst : public LoadBalancingPolicy {
59 void HandOffPendingPicksLocked(LoadBalancingPolicy* new_policy) override;
154 PickFirst::PickFirst(const Args& args) : LoadBalancingPolicy(args) { in PickFirst()
178 void PickFirst::HandOffPendingPicksLocked(LoadBalancingPolicy* new_policy) { in HandOffPendingPicksLocked()
619 OrphanablePtr<LoadBalancingPolicy> CreateLoadBalancingPolicy( in CreateLoadBalancingPolicy()
620 const LoadBalancingPolicy::Args& args) const override { in CreateLoadBalancingPolicy()
621 return OrphanablePtr<LoadBalancingPolicy>(New<PickFirst>(args)); in CreateLoadBalancingPolicy()
/external/rust/crates/grpcio-sys/grpc/src/core/ext/filters/client_channel/lb_policy/grpclb/
Dgrpclb.cc134 class GrpcLbConfig : public LoadBalancingPolicy::Config {
136 GrpcLbConfig(RefCountedPtr<LoadBalancingPolicy::Config> child_policy, in GrpcLbConfig()
142 RefCountedPtr<LoadBalancingPolicy::Config> child_policy() const { in child_policy()
149 RefCountedPtr<LoadBalancingPolicy::Config> child_policy_;
153 class GrpcLb : public LoadBalancingPolicy {
167 RefCountedPtr<LoadBalancingPolicy> parent_grpclb_policy);
202 RefCountedPtr<LoadBalancingPolicy> grpclb_policy_;
425 OrphanablePtr<LoadBalancingPolicy> CreateChildPolicyLocked(
479 OrphanablePtr<LoadBalancingPolicy> child_policy_;
750 RefCountedPtr<LoadBalancingPolicy> parent_grpclb_policy) in BalancerCallState()
[all …]

12