xds_cluster_manager.cc File Reference

#include <grpc/support/port_platform.h>
#include <stddef.h>
#include <algorithm>
#include <map>
#include <memory>
#include <set>
#include <string>
#include <utility>
#include <vector>
#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 <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/client_channel.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_factory.h"
#include "src/core/ext/filters/client_channel/lb_policy_registry.h"
#include "src/core/ext/filters/client_channel/resolver/xds/xds_resolver.h"
#include "src/core/ext/filters/client_channel/subchannel_interface.h"
#include "src/core/lib/channel/channel_args.h"
#include "src/core/lib/debug/trace.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/time.h"
#include "src/core/lib/iomgr/closure.h"
#include "src/core/lib/iomgr/error.h"
#include "src/core/lib/iomgr/exec_ctx.h"
#include "src/core/lib/iomgr/pollset_set.h"
#include "src/core/lib/iomgr/timer.h"
#include "src/core/lib/iomgr/work_serializer.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_manager.cc:

Go to the source code of this file.

Namespaces
	grpc_core

Macros
#define	GRPC_XDS_CLUSTER_MANAGER_CHILD_RETENTION_INTERVAL_MS   (15 * 60 * 1000)

Functions
void	grpc_lb_policy_xds_cluster_manager_init ()
void	grpc_lb_policy_xds_cluster_manager_shutdown ()

Variables
TraceFlag	grpc_core::grpc_xds_cluster_manager_lb_trace (false, "xds_cluster_manager_lb")

Macro Definition Documentation

GRPC_XDS_CLUSTER_MANAGER_CHILD_RETENTION_INTERVAL_MS

#define GRPC_XDS_CLUSTER_MANAGER_CHILD_RETENTION_INTERVAL_MS   (15 * 60 * 1000)

Definition at line 63 of file xds_cluster_manager.cc.

Function Documentation

grpc_lb_policy_xds_cluster_manager_init()

void grpc_lb_policy_xds_cluster_manager_init

(

)

Definition at line 720 of file xds_cluster_manager.cc.

grpc_lb_policy_xds_cluster_manager_shutdown()

void grpc_lb_policy_xds_cluster_manager_shutdown

(

)

Definition at line 726 of file xds_cluster_manager.cc.

Variable Documentation

child_policy_

OrphanablePtr<LoadBalancingPolicy> child_policy_

private

Definition at line 196 of file xds_cluster_manager.cc.

children_

std::map<std::string, OrphanablePtr<ClusterChild> > children_

private

Definition at line 222 of file xds_cluster_manager.cc.

cluster_map_

ClusterMap cluster_map_

private

Definition at line 87 of file xds_cluster_manager.cc.

config_

RefCountedPtr<XdsClusterManagerLbConfig> config_

private

Definition at line 215 of file xds_cluster_manager.cc.

connectivity_state_

grpc_connectivity_state connectivity_state_ = GRPC_CHANNEL_IDLE

private

Definition at line 199 of file xds_cluster_manager.cc.

delayed_removal_timer_

grpc_timer delayed_removal_timer_

private

Definition at line 202 of file xds_cluster_manager.cc.

delayed_removal_timer_callback_pending_

bool delayed_removal_timer_callback_pending_ = false

private

Definition at line 204 of file xds_cluster_manager.cc.

name_

const std::string name_

private

Definition at line 113 of file xds_cluster_manager.cc.

on_delayed_removal_timer_

grpc_closure on_delayed_removal_timer_

private

Definition at line 203 of file xds_cluster_manager.cc.

picker_

std::unique_ptr<SubchannelPicker> picker_

private

Definition at line 114 of file xds_cluster_manager.cc.

picker_wrapper_

RefCountedPtr<ChildPickerWrapper> picker_wrapper_

private

Definition at line 198 of file xds_cluster_manager.cc.

shutdown_

bool shutdown_ = false

private

Definition at line 205 of file xds_cluster_manager.cc.

shutting_down_

bool shutting_down_ = false

private

Definition at line 218 of file xds_cluster_manager.cc.

update_in_progress_

bool update_in_progress_ = false

private

Definition at line 219 of file xds_cluster_manager.cc.

xds_cluster_manager_child_

RefCountedPtr<ClusterChild> xds_cluster_manager_child_

private

Definition at line 180 of file xds_cluster_manager.cc.

xds_cluster_manager_policy_

RefCountedPtr<XdsClusterManagerLb> xds_cluster_manager_policy_

private

Definition at line 191 of file xds_cluster_manager.cc.