Home
last modified time | relevance | path

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

/third_party/grpc/src/core/lib/iomgr/
Dexecutor.cc100 size_t Executor::RunClosures(const char* executor_name, in RunClosures() function in grpc_core::Executor
196 RunClosures(thd_state_[i].name, thd_state_[i].elems); in SetThreading()
248 subtract_depth = RunClosures(ts->name, closures); in ThreadMain()
Dexecutor.h107 static size_t RunClosures(const char* executor_name, grpc_closure_list list);
Dcall_combiner.h164 void RunClosures(CallCombiner* call_combiner) { in RunClosures() function
/third_party/grpc/src/core/lib/transport/
Dtransport.cc209 closures.RunClosures(call_combiner);
/third_party/grpc/src/core/ext/filters/client_channel/
Dclient_channel.cc2851 closures.RunClosures(call_combiner_); in PendingBatchesFail()
2897 closures.RunClosures(call_combiner_); in PendingBatchesResume()
3591 closures.RunClosures(call_combiner_); in PendingBatchesFail()
3640 closures.RunClosures(call_combiner_); in PendingBatchesResume()
4189 closures.RunClosures(call_combiner_); in RunClosuresForCompletedCall()
4358 closures.RunClosures(call->call_combiner_); in OnComplete()
4767 closures.RunClosures(call->call_combiner_); in StartRetriableSubchannelBatches()
5039 closures.RunClosures(call_combiner_); in PendingBatchesFail()
5083 closures.RunClosures(call_combiner_); in PendingBatchesResume()
/third_party/grpc/test/cpp/microbenchmarks/
Dbm_call_create.cc633 closures.RunClosures(calld->call_combiner); in StartTransportStreamOp()