xds_cluster_impl.cc File Reference

#include <grpc/support/port_platform.h>
#include <stddef.h>
#include <stdint.h>
#include <algorithm>
#include <atomic>
#include <map>
#include <memory>
#include <string>
#include <utility>
#include <vector>
#include "absl/base/thread_annotations.h"
#include "absl/memory/memory.h"
#include "absl/status/status.h"
#include "absl/status/statusor.h"
#include "absl/strings/str_cat.h"
#include "absl/strings/string_view.h"
#include "absl/types/optional.h"
#include "absl/types/variant.h"
#include <grpc/impl/codegen/connectivity_state.h>
#include <grpc/impl/codegen/grpc_types.h>
#include <grpc/support/log.h>
#include "src/core/ext/filters/client_channel/lb_policy.h"
#include "src/core/ext/filters/client_channel/lb_policy/child_policy_handler.h"
#include "src/core/ext/filters/client_channel/lb_policy/xds/xds.h"
#include "src/core/ext/filters/client_channel/lb_policy/xds/xds_channel_args.h"
#include "src/core/ext/filters/client_channel/lb_policy_factory.h"
#include "src/core/ext/filters/client_channel/lb_policy_registry.h"
#include "src/core/ext/filters/client_channel/subchannel_interface.h"
#include "src/core/ext/xds/xds_bootstrap.h"
#include "src/core/ext/xds/xds_client.h"
#include "src/core/ext/xds/xds_client_stats.h"
#include "src/core/ext/xds/xds_endpoint.h"
#include "src/core/lib/channel/channel_args.h"
#include "src/core/lib/debug/trace.h"
#include "src/core/lib/gpr/string.h"
#include "src/core/lib/gprpp/debug_location.h"
#include "src/core/lib/gprpp/orphanable.h"
#include "src/core/lib/gprpp/ref_counted.h"
#include "src/core/lib/gprpp/ref_counted_ptr.h"
#include "src/core/lib/gprpp/sync.h"
#include "src/core/lib/iomgr/error.h"
#include "src/core/lib/iomgr/pollset_set.h"
#include "src/core/lib/json/json.h"
#include "src/core/lib/resolver/server_address.h"
#include "src/core/lib/transport/connectivity_state.h"

Include dependency graph for xds_cluster_impl.cc:

Go to the source code of this file.

Namespaces
	grpc_core

Functions
void	grpc_lb_policy_xds_cluster_impl_init ()
void	grpc_lb_policy_xds_cluster_impl_shutdown ()

Variables
TraceFlag	grpc_core::grpc_xds_cluster_impl_lb_trace (false, "xds_cluster_impl_lb")

Function Documentation

grpc_lb_policy_xds_cluster_impl_init()

void grpc_lb_policy_xds_cluster_impl_init

(

)

Definition at line 887 of file xds_cluster_impl.cc.

grpc_lb_policy_xds_cluster_impl_shutdown()

void grpc_lb_policy_xds_cluster_impl_shutdown

(

)

Definition at line 894 of file xds_cluster_impl.cc.

Variable Documentation

call_counter_

RefCountedPtr<CircuitBreakerCallCounterMap::CallCounter> call_counter_

private

Definition at line 231 of file xds_cluster_impl.cc.

child_policy_

OrphanablePtr<LoadBalancingPolicy> child_policy_

private

Definition at line 175 of file xds_cluster_impl.cc.

cluster_name_

std::string cluster_name_

private

Definition at line 176 of file xds_cluster_impl.cc.

concurrent_requests_

std::atomic<uint32_t> concurrent_requests_ {0}

private

Definition at line 96 of file xds_cluster_impl.cc.

config_

RefCountedPtr<XdsClusterImplLbConfig> config_

private

Definition at line 274 of file xds_cluster_impl.cc.

drop_config_

RefCountedPtr<XdsEndpointResource::DropConfig> drop_config_

private

Definition at line 180 of file xds_cluster_impl.cc.

drop_stats_

RefCountedPtr<XdsClusterDropStats> drop_stats_

private

Definition at line 236 of file xds_cluster_impl.cc.

eds_service_name_

std::string eds_service_name_

private

Definition at line 177 of file xds_cluster_impl.cc.

key_

Key key_

private

Definition at line 95 of file xds_cluster_impl.cc.

locality_stats_

RefCountedPtr<XdsClusterLocalityStats> locality_stats_

private

Definition at line 208 of file xds_cluster_impl.cc.

lrs_load_reporting_server_

absl::optional<XdsBootstrap::XdsServer> lrs_load_reporting_server_

private

Definition at line 178 of file xds_cluster_impl.cc.

max_concurrent_requests_

uint32_t max_concurrent_requests_

private

Definition at line 179 of file xds_cluster_impl.cc.

mu_

Mutex mu_

private

Definition at line 103 of file xds_cluster_impl.cc.

original_subchannel_call_tracker_

std::unique_ptr<LoadBalancingPolicy::SubchannelCallTrackerInterface> original_subchannel_call_tracker_

private

Definition at line 353 of file xds_cluster_impl.cc.

picker_

RefCountedPtr<RefCountedPicker> picker_

private

Definition at line 219 of file xds_cluster_impl.cc.

shutting_down_

bool shutting_down_ = false

private

Definition at line 280 of file xds_cluster_impl.cc.

started_

bool started_ = false

private

Definition at line 357 of file xds_cluster_impl.cc.

state_

grpc_connectivity_state state_ = GRPC_CHANNEL_IDLE

private

Definition at line 291 of file xds_cluster_impl.cc.

status_

absl::Status status_

private

Definition at line 292 of file xds_cluster_impl.cc.

xds_client_

RefCountedPtr<XdsClient> xds_client_

private

Definition at line 283 of file xds_cluster_impl.cc.

xds_cluster_impl_policy_

RefCountedPtr<XdsClusterImplLb> xds_cluster_impl_policy_

private

Definition at line 259 of file xds_cluster_impl.cc.