Home
last modified time | relevance | path

Searched refs:chand_ (Results 1 – 5 of 5) sorted by relevance

/external/rust/crates/grpcio-sys/grpc/src/core/ext/filters/client_channel/
Dclient_channel.cc250 ChannelData* chand_; member in grpc_core::__anon5e2240680111::ChannelData::ExternalConnectivityWatcher
261 explicit ResolverResultHandler(ChannelData* chand) : chand_(chand) { in ResolverResultHandler()
262 GRPC_CHANNEL_STACK_REF(chand_->owning_stack_, "ResolverResultHandler"); in ResolverResultHandler()
267 gpr_log(GPR_INFO, "chand=%p: resolver shutdown complete", chand_); in ~ResolverResultHandler()
269 GRPC_CHANNEL_STACK_UNREF(chand_->owning_stack_, "ResolverResultHandler"); in ~ResolverResultHandler()
273 chand_->OnResolverResultChangedLocked(std::move(result)); in ReturnResult()
277 chand_->OnResolverErrorLocked(error); in ReturnError()
281 ChannelData* chand_; member in grpc_core::__anon5e2240680111::ChannelData::ResolverResultHandler
827 ChannelData* chand_; member in grpc_core::__anon5e2240680111::RetryingCall
999 ChannelData* chand_; member in grpc_core::__anon5e2240680111::LoadBalancedCall
[all …]
/external/rust/crates/grpcio-sys/grpc/src/core/ext/filters/max_age/
Dmax_age_filter.cc223 explicit ConnectivityWatcher(channel_data* chand) : chand_(chand) { in ConnectivityWatcher()
224 GRPC_CHANNEL_STACK_REF(chand_->channel_stack, "max_age conn_watch"); in ConnectivityWatcher()
228 GRPC_CHANNEL_STACK_UNREF(chand_->channel_stack, "max_age conn_watch"); in ~ConnectivityWatcher()
236 MutexLock lock(&chand_->max_age_timer_mu); in OnConnectivityStateChange()
237 if (chand_->max_age_timer_pending) { in OnConnectivityStateChange()
238 grpc_timer_cancel(&chand_->max_age_timer); in OnConnectivityStateChange()
239 chand_->max_age_timer_pending = false; in OnConnectivityStateChange()
241 if (chand_->max_age_grace_timer_pending) { in OnConnectivityStateChange()
242 grpc_timer_cancel(&chand_->max_age_grace_timer); in OnConnectivityStateChange()
243 chand_->max_age_grace_timer_pending = false; in OnConnectivityStateChange()
[all …]
/external/rust/crates/grpcio-sys/grpc/src/core/ext/xds/
Dxds_client.cc95 ChannelState* chand() const { return chand_.get(); } in chand()
109 RefCountedPtr<ChannelState> chand_; member in grpc_core::XdsClient::ChannelState::RetryableCall
570 : chand_(std::move(chand)), in RetryableCall()
610 GPR_ASSERT(chand_->channel_ != nullptr); in StartNewCallLocked()
643 MutexLock lock(&calld->chand_->xds_client()->mu_); in OnRetryTimer()
1760 chand_ = MakeOrphanable<ChannelState>( in XdsClient()
1774 grpc_channel_get_channelz_node(chand_->channel()); in AddChannelzLinkage()
1783 grpc_channel_get_channelz_node(chand_->channel()); in RemoveChannelzLinkage()
1801 chand_.reset(); in Orphan()
1832 chand_->Subscribe(XdsApi::kLdsTypeUrl, listener_name_str); in WatchListenerData()
[all …]
Dxds_client.h305 OrphanablePtr<ChannelState> chand_; variable
/external/rust/crates/grpcio-sys/grpc/src/core/lib/surface/
Dserver.cc959 explicit ConnectivityWatcher(ChannelData* chand) : chand_(chand) { in ConnectivityWatcher()
960 GRPC_CHANNEL_INTERNAL_REF(chand_->channel_, "connectivity"); in ConnectivityWatcher()
964 GRPC_CHANNEL_INTERNAL_UNREF(chand_->channel_, "connectivity"); in ~ConnectivityWatcher()
973 MutexLock lock(&chand_->server_->mu_global_); in OnConnectivityStateChange()
974 chand_->Destroy(); in OnConnectivityStateChange()
977 ChannelData* chand_; member in grpc_core::Server::ChannelData::ConnectivityWatcher