Searched refs:connected_subchannel (Results 1 – 7 of 7) sorted by relevance
277 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()
115 grpc_core::RefCountedPtr<grpc_core::ConnectedSubchannel> connected_subchannel; member257 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 …]
78 RefCountedPtr<ConnectedSubchannel> connected_subchannel; member
588 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 …]
200 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()
1115 pp->pick->connected_subchannel.reset(); in ShutdownLocked()1158 pick->connected_subchannel.reset(); in CancelPickLocked()1523 if (pp->pick->connected_subchannel != nullptr) { in PendingPickSetMetadataAndContext()
94 ConnectedSubchannel* connected_subchannel() const { in connected_subchannel() function