priority.cc File Reference

#include <grpc/support/port_platform.h>
#include <inttypes.h>
#include <limits.h>
#include <stddef.h>
#include <algorithm>
#include <map>
#include <memory>
#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/lb_policy.h"
#include "src/core/ext/filters/client_channel/lb_policy/address_filtering.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/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 priority.cc:

Go to the source code of this file.

Namespaces
	grpc_core

Functions
void	grpc_lb_policy_priority_init ()
void	grpc_lb_policy_priority_shutdown ()

Variables
TraceFlag	grpc_core::grpc_lb_priority_trace (false, "priority_lb")

Function Documentation

grpc_lb_policy_priority_init()

void grpc_lb_policy_priority_init

(

)

Definition at line 1052 of file priority.cc.

grpc_lb_policy_priority_shutdown()

void grpc_lb_policy_priority_shutdown

(

)

Definition at line 1058 of file priority.cc.

Variable Documentation

addresses_

absl::StatusOr<HierarchicalAddressMap> addresses_

private

Definition at line 287 of file priority.cc.

args_

const grpc_channel_args* args_ = nullptr

private

Definition at line 285 of file priority.cc.

child_failover_timeout_

const Duration child_failover_timeout_

private

Definition at line 282 of file priority.cc.

child_policy_

OrphanablePtr<LoadBalancingPolicy> child_policy_

private

Definition at line 236 of file priority.cc.

child_priority_

RefCountedPtr<ChildPriority> child_priority_

private

Definition at line 202 of file priority.cc.

children_

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

private

Definition at line 100 of file priority.cc.

config

RefCountedPtr<LoadBalancingPolicy::Config> config

Definition at line 84 of file priority.cc.

config_

RefCountedPtr<PriorityLbConfig> config_

private

Definition at line 286 of file priority.cc.

connectivity_state_

grpc_connectivity_state connectivity_state_ = GRPC_CHANNEL_CONNECTING

private

Definition at line 238 of file priority.cc.

connectivity_status_

absl::Status connectivity_status_

private

Definition at line 239 of file priority.cc.

current_child_from_before_update_

ChildPriority* current_child_from_before_update_ = nullptr

private

Definition at line 302 of file priority.cc.

current_priority_

uint32_t current_priority_ = UINT32_MAX

private

Definition at line 298 of file priority.cc.

deactivation_timer_

OrphanablePtr<DeactivationTimer> deactivation_timer_

private

Definition at line 244 of file priority.cc.

failover_timer_

OrphanablePtr<FailoverTimer> failover_timer_

private

Definition at line 245 of file priority.cc.

ignore_reresolution_requests

bool ignore_reresolution_requests = false

Definition at line 85 of file priority.cc.

ignore_reresolution_requests_

bool ignore_reresolution_requests_ = false

private

Definition at line 234 of file priority.cc.

name_

const std::string name_

private

Definition at line 233 of file priority.cc.

on_timer_

grpc_closure on_timer_

private

Definition at line 204 of file priority.cc.

picker_

RefCountedPtr<RefCountedPicker> picker_

private

Definition at line 157 of file priority.cc.

picker_wrapper_

RefCountedPtr<RefCountedPicker> picker_wrapper_

private

Definition at line 240 of file priority.cc.

priorities_

const std::vector<std::string> priorities_

private

Definition at line 101 of file priority.cc.

priority_

RefCountedPtr<ChildPriority> priority_

private

Definition at line 189 of file priority.cc.

priority_policy_

RefCountedPtr<PriorityLb> priority_policy_

private

Definition at line 232 of file priority.cc.

seen_ready_or_idle_since_transient_failure_

bool seen_ready_or_idle_since_transient_failure_ = true

private

Definition at line 242 of file priority.cc.

shutting_down_

bool shutting_down_ = false

private

Definition at line 290 of file priority.cc.

timer_

grpc_timer timer_

private

Definition at line 203 of file priority.cc.

timer_pending_

bool timer_pending_ = true

private

Definition at line 205 of file priority.cc.

update_in_progress_

bool update_in_progress_ = false

private

Definition at line 292 of file priority.cc.