Home
last modified time | relevance | path

Searched refs:connected_subchannel (Results 1 – 12 of 12) sorted by relevance

/external/grpc-grpc/src/core/ext/filters/client_channel/lb_policy/round_robin/
Dround_robin.cc277 pick->connected_subchannel.reset(); in ShutdownLocked()
294 pick->connected_subchannel.reset(); in CancelPickLocked()
316 pick->connected_subchannel.reset(); in CancelMatchingPicksLocked()
354 GPR_ASSERT(sd->connected_subchannel() != nullptr); in DoPickLocked()
355 pick->connected_subchannel = sd->connected_subchannel()->Ref(); in DoPickLocked()
363 this, sd->subchannel(), pick->connected_subchannel.get(), in DoPickLocked()
651 subchannel(last_ready_index)->connected_subchannel()); in UpdateLastReadySubchannelIndexLocked()
/external/grpc-grpc/src/core/ext/filters/client_channel/
Dsubchannel.cc115 grpc_core::RefCountedPtr<grpc_core::ConnectedSubchannel> connected_subchannel; member
257 c->connected_subchannel.reset(); in disconnect()
486 if (c->connected_subchannel != nullptr) { in maybe_start_connecting_locked()
563 if (!c->disconnected && c->connected_subchannel != nullptr) { in on_connected_subchannel_connectivity_changed()
568 c->connected_subchannel.get(), c, in on_connected_subchannel_connectivity_changed()
572 c->connected_subchannel.reset(); in on_connected_subchannel_connectivity_changed()
590 c->connected_subchannel->NotifyOnStateChange( in on_connected_subchannel_connectivity_changed()
643 c->connected_subchannel.reset(grpc_core::New<grpc_core::ConnectedSubchannel>( in publish_transport_locked()
646 c->connected_subchannel.get(), c); in publish_transport_locked()
652 c->connected_subchannel->NotifyOnStateChange( in publish_transport_locked()
[all …]
Dlb_policy.h78 RefCountedPtr<ConnectedSubchannel> connected_subchannel; member
Dclient_channel.cc588 if (pick_state.connected_subchannel != nullptr) { in start_transport_op_locked()
589 pick_state.connected_subchannel->Ping(op->send_ping.on_initiate, in start_transport_op_locked()
1398 if (calld->pick.connected_subchannel != nullptr) { in do_retry()
1399 calld->pick.connected_subchannel.reset(); in do_retry()
1981 calld->pick.connected_subchannel->channelz_subchannel(); in recv_trailing_metadata_ready()
2612 calld->pick.connected_subchannel->channelz_subchannel(); in recv_trailing_metadata_ready_channelz()
2634 if (calld->pick.connected_subchannel->channelz_subchannel() == nullptr) { in maybe_intercept_recv_trailing_metadata_for_channelz()
2674 grpc_error* new_error = calld->pick.connected_subchannel->CreateCall( in create_subchannel_call()
2685 calld->pick.connected_subchannel->channelz_subchannel(); in create_subchannel_call()
2706 if (GPR_UNLIKELY(calld->pick.connected_subchannel == nullptr)) { in pick_done()
[all …]
/external/grpc-grpc/src/core/ext/filters/client_channel/lb_policy/pick_first/
Dpick_first.cc200 pick->connected_subchannel.reset(); in ShutdownLocked()
217 pick->connected_subchannel.reset(); in CancelPickLocked()
275 pick->connected_subchannel = selected_->connected_subchannel()->Ref(); in PickLocked()
589 pick->connected_subchannel = p->selected_->connected_subchannel()->Ref(); in ProcessUnselectedReadyLocked()
/external/rust/crates/grpcio-sys/grpc/src/core/ext/filters/client_channel/
Dsubchannel.cc136 args.connected_subchannel->GetInitialCallSizeEstimate(); in Create()
143 : connected_subchannel_(std::move(args.connected_subchannel)), in SubchannelCall()
215 RefCountedPtr<ConnectedSubchannel> connected_subchannel = in Destroy() local
372 RefCountedPtr<ConnectedSubchannel> connected_subchannel; in AsyncWatcherNotifierLocked() local
374 connected_subchannel = subchannel->connected_subchannel_; in AsyncWatcherNotifierLocked()
377 {state, status, std::move(connected_subchannel)}); in AsyncWatcherNotifierLocked()
826 RefCountedPtr<ConnectedSubchannel>* connected_subchannel) { in CheckConnectivityState() argument
835 if (connected_subchannel != nullptr && state == GRPC_CHANNEL_READY) { in CheckConnectivityState()
836 *connected_subchannel = connected_subchannel_; in CheckConnectivityState()
Dsubchannel.h105 RefCountedPtr<ConnectedSubchannel> connected_subchannel; member
179 RefCountedPtr<ConnectedSubchannel> connected_subchannel; member
254 RefCountedPtr<ConnectedSubchannel>* connected_subchannel);
Dclient_channel.cc1310 RefCountedPtr<ConnectedSubchannel> connected_subchannel; in CheckConnectivityState() local
1313 &connected_subchannel); in CheckConnectivityState()
1314 MaybeUpdateConnectedSubchannel(std::move(connected_subchannel)); in CheckConnectivityState()
1388 ConnectedSubchannel* connected_subchannel() const { in connected_subchannel() function in grpc_core::__anon5e2240680111::ChannelData::SubchannelWrapper
1397 RefCountedPtr<ConnectedSubchannel> connected_subchannel) { in set_connected_subchannel_in_data_plane() argument
1398 connected_subchannel_in_data_plane_ = std::move(connected_subchannel); in set_connected_subchannel_in_data_plane()
1508 std::move(state_change.connected_subchannel)); in ApplyUpdateInControlPlaneWorkSerializer()
1521 RefCountedPtr<ConnectedSubchannel> connected_subchannel) { in MaybeUpdateConnectedSubchannel() argument
1532 if (connected_subchannel_ != connected_subchannel) { in MaybeUpdateConnectedSubchannel()
1533 connected_subchannel_ = std::move(connected_subchannel); in MaybeUpdateConnectedSubchannel()
[all …]
/external/rust/crates/grpcio-sys/grpc/src/core/ext/filters/client_channel/health/
Dhealth_check_client.h48 RefCountedPtr<ConnectedSubchannel> connected_subchannel,
Dhealth_check_client.cc50 RefCountedPtr<ConnectedSubchannel> connected_subchannel, in HealthCheckClient() argument
59 connected_subchannel_(std::move(connected_subchannel)), in HealthCheckClient()
/external/grpc-grpc/src/core/ext/filters/client_channel/lb_policy/grpclb/
Dgrpclb.cc1115 pp->pick->connected_subchannel.reset(); in ShutdownLocked()
1158 pick->connected_subchannel.reset(); in CancelPickLocked()
1523 if (pp->pick->connected_subchannel != nullptr) { in PendingPickSetMetadataAndContext()
/external/grpc-grpc/src/core/ext/filters/client_channel/lb_policy/
Dsubchannel_list.h94 ConnectedSubchannel* connected_subchannel() const { in connected_subchannel() function