|
|
|
|
@ -228,7 +228,7 @@ class ChannelData { |
|
|
|
|
|
|
|
|
|
void UpdateStateAndPickerLocked( |
|
|
|
|
grpc_connectivity_state state, const char* reason, |
|
|
|
|
UniquePtr<LoadBalancingPolicy::SubchannelPicker> picker); |
|
|
|
|
std::unique_ptr<LoadBalancingPolicy::SubchannelPicker> picker); |
|
|
|
|
|
|
|
|
|
void UpdateServiceConfigLocked( |
|
|
|
|
RefCountedPtr<ServerRetryThrottleData> retry_throttle_data, |
|
|
|
|
@ -252,7 +252,7 @@ class ChannelData { |
|
|
|
|
void ProcessLbPolicy( |
|
|
|
|
const Resolver::Result& resolver_result, |
|
|
|
|
const internal::ClientChannelGlobalParsedConfig* parsed_service_config, |
|
|
|
|
UniquePtr<char>* lb_policy_name, |
|
|
|
|
std::unique_ptr<char>* lb_policy_name, |
|
|
|
|
RefCountedPtr<LoadBalancingPolicy::Config>* lb_policy_config); |
|
|
|
|
|
|
|
|
|
//
|
|
|
|
|
@ -265,15 +265,15 @@ class ChannelData { |
|
|
|
|
ClientChannelFactory* client_channel_factory_; |
|
|
|
|
const grpc_channel_args* channel_args_; |
|
|
|
|
RefCountedPtr<ServiceConfig> default_service_config_; |
|
|
|
|
UniquePtr<char> server_name_; |
|
|
|
|
UniquePtr<char> target_uri_; |
|
|
|
|
std::unique_ptr<char> server_name_; |
|
|
|
|
std::unique_ptr<char> target_uri_; |
|
|
|
|
channelz::ChannelNode* channelz_node_; |
|
|
|
|
|
|
|
|
|
//
|
|
|
|
|
// Fields used in the data plane. Guarded by data_plane_mu.
|
|
|
|
|
//
|
|
|
|
|
mutable Mutex data_plane_mu_; |
|
|
|
|
UniquePtr<LoadBalancingPolicy::SubchannelPicker> picker_; |
|
|
|
|
std::unique_ptr<LoadBalancingPolicy::SubchannelPicker> picker_; |
|
|
|
|
QueuedPick* queued_picks_ = nullptr; // Linked list of queued picks.
|
|
|
|
|
// Data from service config.
|
|
|
|
|
bool received_service_config_data_ = false; |
|
|
|
|
@ -288,7 +288,7 @@ class ChannelData { |
|
|
|
|
RefCountedPtr<SubchannelPoolInterface> subchannel_pool_; |
|
|
|
|
OrphanablePtr<ResolvingLoadBalancingPolicy> resolving_lb_policy_; |
|
|
|
|
ConnectivityStateTracker state_tracker_; |
|
|
|
|
UniquePtr<char> health_check_service_name_; |
|
|
|
|
std::unique_ptr<char> health_check_service_name_; |
|
|
|
|
RefCountedPtr<ServiceConfig> saved_service_config_; |
|
|
|
|
bool received_first_resolver_result_ = false; |
|
|
|
|
// The number of SubchannelWrapper instances referencing a given Subchannel.
|
|
|
|
|
@ -314,8 +314,8 @@ class ChannelData { |
|
|
|
|
// synchronously via get_channel_info().
|
|
|
|
|
//
|
|
|
|
|
gpr_mu info_mu_; |
|
|
|
|
UniquePtr<char> info_lb_policy_name_; |
|
|
|
|
UniquePtr<char> info_service_config_json_; |
|
|
|
|
std::unique_ptr<char> info_lb_policy_name_; |
|
|
|
|
std::unique_ptr<char> info_service_config_json_; |
|
|
|
|
|
|
|
|
|
//
|
|
|
|
|
// Fields guarded by a mutex, since they need to be accessed
|
|
|
|
|
@ -843,7 +843,7 @@ class CallData { |
|
|
|
|
class ChannelData::SubchannelWrapper : public SubchannelInterface { |
|
|
|
|
public: |
|
|
|
|
SubchannelWrapper(ChannelData* chand, Subchannel* subchannel, |
|
|
|
|
UniquePtr<char> health_check_service_name) |
|
|
|
|
std::unique_ptr<char> health_check_service_name) |
|
|
|
|
: SubchannelInterface(&grpc_client_channel_routing_trace), |
|
|
|
|
chand_(chand), |
|
|
|
|
subchannel_(subchannel), |
|
|
|
|
@ -898,7 +898,7 @@ class ChannelData::SubchannelWrapper : public SubchannelInterface { |
|
|
|
|
|
|
|
|
|
void WatchConnectivityState( |
|
|
|
|
grpc_connectivity_state initial_state, |
|
|
|
|
UniquePtr<ConnectivityStateWatcherInterface> watcher) override { |
|
|
|
|
std::unique_ptr<ConnectivityStateWatcherInterface> watcher) override { |
|
|
|
|
auto& watcher_wrapper = watcher_map_[watcher.get()]; |
|
|
|
|
GPR_ASSERT(watcher_wrapper == nullptr); |
|
|
|
|
watcher_wrapper = new WatcherWrapper(std::move(watcher), |
|
|
|
|
@ -906,7 +906,7 @@ class ChannelData::SubchannelWrapper : public SubchannelInterface { |
|
|
|
|
initial_state); |
|
|
|
|
subchannel_->WatchConnectivityState( |
|
|
|
|
initial_state, |
|
|
|
|
UniquePtr<char>(gpr_strdup(health_check_service_name_.get())), |
|
|
|
|
std::unique_ptr<char>(gpr_strdup(health_check_service_name_.get())), |
|
|
|
|
OrphanablePtr<Subchannel::ConnectivityStateWatcherInterface>( |
|
|
|
|
watcher_wrapper)); |
|
|
|
|
} |
|
|
|
|
@ -928,7 +928,8 @@ class ChannelData::SubchannelWrapper : public SubchannelInterface { |
|
|
|
|
return subchannel_->channel_args(); |
|
|
|
|
} |
|
|
|
|
|
|
|
|
|
void UpdateHealthCheckServiceName(UniquePtr<char> health_check_service_name) { |
|
|
|
|
void UpdateHealthCheckServiceName( |
|
|
|
|
std::unique_ptr<char> health_check_service_name) { |
|
|
|
|
if (GRPC_TRACE_FLAG_ENABLED(grpc_client_channel_routing_trace)) { |
|
|
|
|
gpr_log(GPR_INFO, |
|
|
|
|
"chand=%p: subchannel wrapper %p: updating health check service " |
|
|
|
|
@ -954,7 +955,7 @@ class ChannelData::SubchannelWrapper : public SubchannelInterface { |
|
|
|
|
watcher_wrapper = replacement; |
|
|
|
|
subchannel_->WatchConnectivityState( |
|
|
|
|
replacement->last_seen_state(), |
|
|
|
|
UniquePtr<char>(gpr_strdup(health_check_service_name.get())), |
|
|
|
|
std::unique_ptr<char>(gpr_strdup(health_check_service_name.get())), |
|
|
|
|
OrphanablePtr<Subchannel::ConnectivityStateWatcherInterface>( |
|
|
|
|
replacement)); |
|
|
|
|
} |
|
|
|
|
@ -994,7 +995,7 @@ class ChannelData::SubchannelWrapper : public SubchannelInterface { |
|
|
|
|
class WatcherWrapper : public Subchannel::ConnectivityStateWatcherInterface { |
|
|
|
|
public: |
|
|
|
|
WatcherWrapper( |
|
|
|
|
UniquePtr<SubchannelInterface::ConnectivityStateWatcherInterface> |
|
|
|
|
std::unique_ptr<SubchannelInterface::ConnectivityStateWatcherInterface> |
|
|
|
|
watcher, |
|
|
|
|
RefCountedPtr<SubchannelWrapper> parent, |
|
|
|
|
grpc_connectivity_state initial_state) |
|
|
|
|
@ -1083,7 +1084,8 @@ class ChannelData::SubchannelWrapper : public SubchannelInterface { |
|
|
|
|
grpc_closure closure_; |
|
|
|
|
}; |
|
|
|
|
|
|
|
|
|
UniquePtr<SubchannelInterface::ConnectivityStateWatcherInterface> watcher_; |
|
|
|
|
std::unique_ptr<SubchannelInterface::ConnectivityStateWatcherInterface> |
|
|
|
|
watcher_; |
|
|
|
|
RefCountedPtr<SubchannelWrapper> parent_; |
|
|
|
|
grpc_connectivity_state last_seen_state_; |
|
|
|
|
WatcherWrapper* replacement_ = nullptr; |
|
|
|
|
@ -1112,7 +1114,7 @@ class ChannelData::SubchannelWrapper : public SubchannelInterface { |
|
|
|
|
|
|
|
|
|
ChannelData* chand_; |
|
|
|
|
Subchannel* subchannel_; |
|
|
|
|
UniquePtr<char> health_check_service_name_; |
|
|
|
|
std::unique_ptr<char> health_check_service_name_; |
|
|
|
|
// Maps from the address of the watcher passed to us by the LB policy
|
|
|
|
|
// to the address of the WrapperWatcher that we passed to the underlying
|
|
|
|
|
// subchannel. This is needed so that when the LB policy calls
|
|
|
|
|
@ -1298,7 +1300,7 @@ class ChannelData::ClientChannelControlHelper |
|
|
|
|
const grpc_channel_args& args) override { |
|
|
|
|
bool inhibit_health_checking = grpc_channel_arg_get_bool( |
|
|
|
|
grpc_channel_args_find(&args, GRPC_ARG_INHIBIT_HEALTH_CHECKING), false); |
|
|
|
|
UniquePtr<char> health_check_service_name; |
|
|
|
|
std::unique_ptr<char> health_check_service_name; |
|
|
|
|
if (!inhibit_health_checking) { |
|
|
|
|
health_check_service_name.reset( |
|
|
|
|
gpr_strdup(chand_->health_check_service_name_.get())); |
|
|
|
|
@ -1321,7 +1323,7 @@ class ChannelData::ClientChannelControlHelper |
|
|
|
|
|
|
|
|
|
void UpdateState( |
|
|
|
|
grpc_connectivity_state state, |
|
|
|
|
UniquePtr<LoadBalancingPolicy::SubchannelPicker> picker) override { |
|
|
|
|
std::unique_ptr<LoadBalancingPolicy::SubchannelPicker> picker) override { |
|
|
|
|
grpc_error* disconnect_error = chand_->disconnect_error(); |
|
|
|
|
if (GRPC_TRACE_FLAG_ENABLED(grpc_client_channel_routing_trace)) { |
|
|
|
|
const char* extra = disconnect_error == GRPC_ERROR_NONE |
|
|
|
|
@ -1494,7 +1496,7 @@ ChannelData::~ChannelData() { |
|
|
|
|
|
|
|
|
|
void ChannelData::UpdateStateAndPickerLocked( |
|
|
|
|
grpc_connectivity_state state, const char* reason, |
|
|
|
|
UniquePtr<LoadBalancingPolicy::SubchannelPicker> picker) { |
|
|
|
|
std::unique_ptr<LoadBalancingPolicy::SubchannelPicker> picker) { |
|
|
|
|
// Clean the control plane when entering IDLE.
|
|
|
|
|
if (picker_ == nullptr) { |
|
|
|
|
health_check_service_name_.reset(); |
|
|
|
|
@ -1594,7 +1596,7 @@ void ChannelData::CreateResolvingLoadBalancingPolicyLocked() { |
|
|
|
|
lb_args.combiner = combiner_; |
|
|
|
|
lb_args.channel_control_helper = MakeUnique<ClientChannelControlHelper>(this); |
|
|
|
|
lb_args.args = channel_args_; |
|
|
|
|
UniquePtr<char> target_uri(gpr_strdup(target_uri_.get())); |
|
|
|
|
std::unique_ptr<char> target_uri(gpr_strdup(target_uri_.get())); |
|
|
|
|
resolving_lb_policy_.reset(new ResolvingLoadBalancingPolicy( |
|
|
|
|
std::move(lb_args), &grpc_client_channel_routing_trace, |
|
|
|
|
std::move(target_uri), ProcessResolverResultLocked, this)); |
|
|
|
|
@ -1617,7 +1619,7 @@ void ChannelData::DestroyResolvingLoadBalancingPolicyLocked() { |
|
|
|
|
void ChannelData::ProcessLbPolicy( |
|
|
|
|
const Resolver::Result& resolver_result, |
|
|
|
|
const internal::ClientChannelGlobalParsedConfig* parsed_service_config, |
|
|
|
|
UniquePtr<char>* lb_policy_name, |
|
|
|
|
std::unique_ptr<char>* lb_policy_name, |
|
|
|
|
RefCountedPtr<LoadBalancingPolicy::Config>* lb_policy_config) { |
|
|
|
|
// Prefer the LB policy name found in the service config.
|
|
|
|
|
if (parsed_service_config != nullptr && |
|
|
|
|
@ -1712,7 +1714,7 @@ bool ChannelData::ProcessResolverResultLocked( |
|
|
|
|
return false; |
|
|
|
|
} |
|
|
|
|
// Process service config.
|
|
|
|
|
UniquePtr<char> service_config_json; |
|
|
|
|
std::unique_ptr<char> service_config_json; |
|
|
|
|
const internal::ClientChannelGlobalParsedConfig* parsed_service_config = |
|
|
|
|
nullptr; |
|
|
|
|
if (service_config != nullptr) { |
|
|
|
|
@ -1746,8 +1748,8 @@ bool ChannelData::ProcessResolverResultLocked( |
|
|
|
|
} |
|
|
|
|
// Update health check service name used by existing subchannel wrappers.
|
|
|
|
|
for (auto* subchannel_wrapper : chand->subchannel_wrappers_) { |
|
|
|
|
subchannel_wrapper->UpdateHealthCheckServiceName( |
|
|
|
|
UniquePtr<char>(gpr_strdup(chand->health_check_service_name_.get()))); |
|
|
|
|
subchannel_wrapper->UpdateHealthCheckServiceName(std::unique_ptr<char>( |
|
|
|
|
gpr_strdup(chand->health_check_service_name_.get()))); |
|
|
|
|
} |
|
|
|
|
// Save service config.
|
|
|
|
|
chand->saved_service_config_ = std::move(service_config); |
|
|
|
|
@ -1772,7 +1774,7 @@ bool ChannelData::ProcessResolverResultLocked( |
|
|
|
|
chand->UpdateServiceConfigLocked(std::move(retry_throttle_data), |
|
|
|
|
chand->saved_service_config_); |
|
|
|
|
} |
|
|
|
|
UniquePtr<char> processed_lb_policy_name; |
|
|
|
|
std::unique_ptr<char> processed_lb_policy_name; |
|
|
|
|
chand->ProcessLbPolicy(result, parsed_service_config, |
|
|
|
|
&processed_lb_policy_name, lb_policy_config); |
|
|
|
|
// Swap out the data used by GetChannelInfo().
|
|
|
|
|
|
Esun Kim
5 years ago