Lines Matching refs:Combiner

46 static void combiner_exec(grpc_core::Combiner* lock, grpc_closure* closure,
48 static void combiner_finally_exec(grpc_core::Combiner* lock,
54 grpc_core::Combiner* grpc_combiner_create(void) { in grpc_combiner_create()
55 grpc_core::Combiner* lock = new grpc_core::Combiner(); in grpc_combiner_create()
64 static void really_destroy(grpc_core::Combiner* lock) { in really_destroy()
70 static void start_destroy(grpc_core::Combiner* lock) { in start_destroy()
91 void grpc_combiner_unref(grpc_core::Combiner* lock GRPC_COMBINER_DEBUG_ARGS) { in grpc_combiner_unref()
98 grpc_core::Combiner* grpc_combiner_ref( in grpc_combiner_ref()
99 grpc_core::Combiner* lock GRPC_COMBINER_DEBUG_ARGS) { in grpc_combiner_ref()
105 static void push_last_on_exec_ctx(grpc_core::Combiner* lock) { in push_last_on_exec_ctx()
118 static void push_first_on_exec_ctx(grpc_core::Combiner* lock) { in push_first_on_exec_ctx()
127 static void combiner_exec(grpc_core::Combiner* lock, grpc_closure* cl, in combiner_exec()
167 grpc_core::Combiner* lock = static_cast<grpc_core::Combiner*>(arg); in offload()
171 static void queue_offload(grpc_core::Combiner* lock) { in queue_offload()
178 grpc_core::Combiner* lock = in grpc_combiner_continue_exec_ctx()
291 static void combiner_finally_exec(grpc_core::Combiner* lock, in combiner_finally_exec()
314 grpc_core::Combiner* lock = in enqueue_finally()
315 reinterpret_cast<grpc_core::Combiner*>(cl->error_data.scratch); in enqueue_finally()
321 void Combiner::Run(grpc_closure* closure, grpc_error_handle error) { in Run()
325 void Combiner::FinallyRun(grpc_closure* closure, grpc_error_handle error) { in FinallyRun()