|
|
@ -405,18 +405,22 @@ class Subchannel::ConnectedSubchannelStateWatcher |
|
|
|
static void OnHealthChanged(void* arg, grpc_error* error) { |
|
|
|
static void OnHealthChanged(void* arg, grpc_error* error) { |
|
|
|
auto* self = static_cast<ConnectedSubchannelStateWatcher*>(arg); |
|
|
|
auto* self = static_cast<ConnectedSubchannelStateWatcher*>(arg); |
|
|
|
Subchannel* c = self->subchannel_; |
|
|
|
Subchannel* c = self->subchannel_; |
|
|
|
|
|
|
|
{ |
|
|
|
MutexLock lock(&c->mu_); |
|
|
|
MutexLock lock(&c->mu_); |
|
|
|
if (self->health_state_ == GRPC_CHANNEL_SHUTDOWN) { |
|
|
|
if (self->health_state_ != GRPC_CHANNEL_SHUTDOWN) { |
|
|
|
self->Unref(); |
|
|
|
|
|
|
|
return; |
|
|
|
|
|
|
|
} |
|
|
|
|
|
|
|
if (self->last_connectivity_state_ == GRPC_CHANNEL_READY) { |
|
|
|
if (self->last_connectivity_state_ == GRPC_CHANNEL_READY) { |
|
|
|
grpc_connectivity_state_set(&c->state_and_health_tracker_, |
|
|
|
grpc_connectivity_state_set(&c->state_and_health_tracker_, |
|
|
|
self->health_state_, GRPC_ERROR_REF(error), |
|
|
|
self->health_state_, |
|
|
|
"health_changed"); |
|
|
|
GRPC_ERROR_REF(error), "health_changed"); |
|
|
|
|
|
|
|
} |
|
|
|
|
|
|
|
self->health_check_client_->NotifyOnHealthChange( |
|
|
|
|
|
|
|
&self->health_state_, &self->on_health_changed_); |
|
|
|
|
|
|
|
self = nullptr; // So we don't unref below.
|
|
|
|
} |
|
|
|
} |
|
|
|
self->health_check_client_->NotifyOnHealthChange(&self->health_state_, |
|
|
|
} |
|
|
|
&self->on_health_changed_); |
|
|
|
// Don't unref until we've released the lock, because this might
|
|
|
|
|
|
|
|
// cause the subchannel (which contains the lock) to be destroyed.
|
|
|
|
|
|
|
|
if (self != nullptr) self->Unref(); |
|
|
|
} |
|
|
|
} |
|
|
|
|
|
|
|
|
|
|
|
Subchannel* subchannel_; |
|
|
|
Subchannel* subchannel_; |
|
|
|