Searched refs:subchannel_call (Results 1 – 4 of 4) sorted by relevance
133 grpc_subchannel_call* subchannel_call);163 void grpc_subchannel_call_process_op(grpc_subchannel_call* subchannel_call,169 grpc_subchannel_call* subchannel_call, grpc_closure* closure);172 grpc_subchannel_call* subchannel_call);
835 grpc_subchannel_call* subchannel_call; // Holds a ref. member927 grpc_subchannel_call* subchannel_call; member1184 calld->subchannel_call == nullptr in pending_batches_add()1188 calld->subchannel_call)); in pending_batches_add()1272 grpc_subchannel_call* subchannel_call = in resume_pending_batch_in_call_combiner() local1275 grpc_subchannel_call_process_op(subchannel_call, batch); in resume_pending_batch_in_call_combiner()1295 chand, calld, num_batches, calld->subchannel_call); in pending_batches_resume()1303 batch->handler_private.extra_arg = calld->subchannel_call; in pending_batches_resume()1393 if (calld->subchannel_call != nullptr) { in do_retry()1394 GRPC_SUBCHANNEL_CALL_UNREF(calld->subchannel_call, in do_retry()[all …]
760 grpc_subchannel_call* subchannel_call) { in grpc_connected_subchannel_call_get_parent_data() argument761 grpc_channel_stack* chanstk = subchannel_call->connection->channel_stack(); in grpc_connected_subchannel_call_get_parent_data()762 return (char*)subchannel_call + sizeof(grpc_subchannel_call) + in grpc_connected_subchannel_call_get_parent_data()767 grpc_subchannel_call* subchannel_call) { in grpc_subchannel_call_get_call_stack() argument768 return SUBCHANNEL_CALL_TO_CALL_STACK(subchannel_call); in grpc_subchannel_call_get_call_stack()
551 RefCountedPtr<SubchannelCall> subchannel_call() const;940 RefCountedPtr<SubchannelCall> subchannel_call() const { in subchannel_call() function in grpc_core::__anon983758c10111::LoadBalancedCall1126 RefCountedPtr<SubchannelCall> subchannel_call; in Destroy() local1129 subchannel_call = calld->retrying_call_->subchannel_call(); in Destroy()1134 subchannel_call = calld->lb_call_->subchannel_call(); in Destroy()1138 if (GPR_LIKELY(subchannel_call != nullptr)) { in Destroy()1139 subchannel_call->SetAfterCallStackDestroy(then_schedule_closure); in Destroy()3329 RefCountedPtr<SubchannelCall> RetryingCall::subchannel_call() const { in subchannel_call() function in grpc_core::__anon983758c10111::RetryingCall3331 return lb_call_->subchannel_call(); in subchannel_call()5045 SubchannelCall* subchannel_call = in ResumePendingBatchInCallCombiner() local[all …]