Searched refs:RunClosures (Results 1 – 11 of 11) sorted by relevance
60 size_t GrpcExecutor::RunClosures(const char* executor_name, in RunClosures() function in GrpcExecutor146 RunClosures(thd_state_[i].name, thd_state_[i].elems); in SetThreading()191 subtract_depth = RunClosures(ts->name, closures); in ThreadMain()
66 static size_t RunClosures(const char* executor_name, grpc_closure_list list);
142 void RunClosures(grpc_call_combiner* call_combiner) { in RunClosures() function
100 size_t Executor::RunClosures(const char* executor_name, in RunClosures() function in grpc_core::Executor196 RunClosures(thd_state_[i].name, thd_state_[i].elems); in SetThreading()248 subtract_depth = RunClosures(ts->name, closures); in ThreadMain()
107 static size_t RunClosures(const char* executor_name, grpc_closure_list list);
164 void RunClosures(CallCombiner* call_combiner) { in RunClosures() function
209 closures.RunClosures(call_combiner);
239 closures.RunClosures(call_combiner);
2851 closures.RunClosures(call_combiner_); in PendingBatchesFail()2897 closures.RunClosures(call_combiner_); in PendingBatchesResume()3585 closures.RunClosures(call_combiner_); in PendingBatchesFail()3634 closures.RunClosures(call_combiner_); in PendingBatchesResume()4183 closures.RunClosures(call_combiner_); in RunClosuresForCompletedCall()4352 closures.RunClosures(call->call_combiner_); in OnComplete()4761 closures.RunClosures(call->call_combiner_); in StartRetriableSubchannelBatches()5033 closures.RunClosures(call_combiner_); in PendingBatchesFail()5077 closures.RunClosures(call_combiner_); in PendingBatchesResume()
1260 closures.RunClosures(calld->call_combiner); in pending_batches_fail()1313 closures.RunClosures(calld->call_combiner); in pending_batches_resume()1952 closures.RunClosures(calld->call_combiner); in run_closures_for_completed_call()2145 closures.RunClosures(calld->call_combiner); in on_complete()2589 closures.RunClosures(calld->call_combiner); in start_retriable_subchannel_batches()
646 closures.RunClosures(calld->call_combiner); in StartTransportStreamOp()