Home
last modified time | relevance | path

Searched refs:health_check_client_ (Results 1 – 3 of 3) sorted by relevance

/external/rust/crates/grpcio-sys/grpc/src/core/ext/filters/client_channel/health/
Dhealth_check_client.cc253 : health_check_client_(std::move(health_check_client)), in CallState()
255 arena_(Arena::Create(health_check_client_->connected_subchannel_ in CallState()
262 health_check_client_.get(), this); in ~CallState()
287 health_check_client_->connected_subchannel_, in StartCall()
307 health_check_client_.get(), this, grpc_error_string(error)); in StartCall()
334 EncodeRequest(health_check_client_->service_name_, &send_message_); in StartCall()
473 health_check_client_->SetHealthStatus(state, reason); in DoneReadingRecvMessage()
567 self->health_check_client_.get(), self, status); in RecvTrailingMetadataReady()
578 if (self->health_check_client_->channelz_node_ != nullptr) { in RecvTrailingMetadataReady()
579 self->health_check_client_->channelz_node_->AddTraceEvent( in RecvTrailingMetadataReady()
[all …]
Dhealth_check_client.h92 RefCountedPtr<HealthCheckClient> health_check_client_; variable
/external/rust/crates/grpcio-sys/grpc/src/core/ext/filters/client_channel/
Dsubchannel.cc482 health_check_client_.reset(); in NotifyLocked()
488 health_check_client_.reset(); in Orphan()
496 if (new_state != GRPC_CHANNEL_SHUTDOWN && health_check_client_ != nullptr) { in OnConnectivityStateChange()
504 GPR_ASSERT(health_check_client_ == nullptr); in StartHealthCheckingLocked()
505 health_check_client_ = MakeOrphanable<HealthCheckClient>( in StartHealthCheckingLocked()
512 OrphanablePtr<HealthCheckClient> health_check_client_; member in grpc_core::Subchannel::HealthWatcherMap::HealthWatcher