Home
last modified time | relevance | path

Searched refs:connected_subchannel_ (Results 1 – 6 of 6) sorted by relevance

/external/rust/crates/grpcio-sys/grpc/src/core/ext/filters/client_channel/
Dsubchannel.cc143 : connected_subchannel_(std::move(args.connected_subchannel)), in SubchannelCall()
156 *error = grpc_call_stack_init(connected_subchannel_->channel_stack(), 1, in SubchannelCall()
164 auto* channelz_node = connected_subchannel_->channelz_subchannel(); in SubchannelCall()
216 std::move(self->connected_subchannel_); in Destroy()
236 if (connected_subchannel_->channelz_subchannel() == nullptr) { in MaybeInterceptRecvTrailingMetadata()
278 call->connected_subchannel_->channelz_subchannel(); in RecvTrailingMetadataReady()
324 if (!c->disconnected_ && c->connected_subchannel_ != nullptr) { in OnConnectivityStateChange()
329 c->connected_subchannel_.get(), c, in OnConnectivityStateChange()
332 c->connected_subchannel_.reset(); in OnConnectivityStateChange()
374 connected_subchannel = subchannel->connected_subchannel_; in AsyncWatcherNotifierLocked()
[all …]
Dsubchannel.h155 RefCountedPtr<ConnectedSubchannel> connected_subchannel_; variable
400 RefCountedPtr<ConnectedSubchannel> connected_subchannel_; variable
Dclient_channel.cc1023 RefCountedPtr<ConnectedSubchannel> connected_subchannel_; member in grpc_core::__anon5e2240680111::LoadBalancedCall
1389 return connected_subchannel_.get(); in connected_subchannel()
1532 if (connected_subchannel_ != connected_subchannel) { in MaybeUpdateConnectedSubchannel()
1533 connected_subchannel_ = std::move(connected_subchannel); in MaybeUpdateConnectedSubchannel()
1537 DEBUG_LOCATION, "ConnectedSubchannelUpdate")] = connected_subchannel_; in MaybeUpdateConnectedSubchannel()
1551 RefCountedPtr<ConnectedSubchannel> connected_subchannel_; member in grpc_core::__anon5e2240680111::ChannelData::SubchannelWrapper
5215 std::move(connected_subchannel_), pollent_, path_, call_start_time_, in CreateSubchannelCall()
5351 GPR_ASSERT(connected_subchannel_ == nullptr); in PickSubchannelLocked()
5416 connected_subchannel_ = in PickSubchannelLocked()
5418 GPR_ASSERT(connected_subchannel_ != nullptr); in PickSubchannelLocked()
/external/grpc-grpc/src/core/ext/filters/client_channel/lb_policy/
Dsubchannel_list.h95 return connected_subchannel_.get(); in connected_subchannel()
175 RefCountedPtr<ConnectedSubchannel> connected_subchannel_; variable
313 connected_subchannel_.reset(); in UnrefSubchannelLocked()
402 connected_subchannel_ = in UpdateConnectedSubchannelLocked()
415 if (connected_subchannel_ == nullptr) { in UpdateConnectedSubchannelLocked()
430 connected_subchannel_.reset(); in UpdateConnectedSubchannelLocked()
/external/rust/crates/grpcio-sys/grpc/src/core/ext/filters/client_channel/health/
Dhealth_check_client.cc59 connected_subchannel_(std::move(connected_subchannel)), in HealthCheckClient()
255 arena_(Arena::Create(health_check_client_->connected_subchannel_ in CallState()
287 health_check_client_->connected_subchannel_, in StartCall()
Dhealth_check_client.h154 RefCountedPtr<ConnectedSubchannel> connected_subchannel_; variable