Home
last modified time | relevance | path

Searched refs:active_combiner (Results 1 – 3 of 3) sorted by relevance

/external/grpc-grpc/src/core/lib/iomgr/
Dcombiner.cc134 if (grpc_core::ExecCtx::Get()->combiner_data()->active_combiner == nullptr) { in push_last_on_exec_ctx()
135 grpc_core::ExecCtx::Get()->combiner_data()->active_combiner = in push_last_on_exec_ctx()
147 grpc_core::ExecCtx::Get()->combiner_data()->active_combiner; in push_first_on_exec_ctx()
148 grpc_core::ExecCtx::Get()->combiner_data()->active_combiner = lock; in push_first_on_exec_ctx()
190 grpc_core::ExecCtx::Get()->combiner_data()->active_combiner = in move_next()
193 ->active_combiner->next_combiner_on_this_exec_ctx; in move_next()
194 if (grpc_core::ExecCtx::Get()->combiner_data()->active_combiner == nullptr) { in move_next()
214 grpc_core::ExecCtx::Get()->combiner_data()->active_combiner; in grpc_combiner_continue_exec_ctx()
332 grpc_core::ExecCtx::Get()->combiner_data()->active_combiner)); in combiner_finally_exec()
333 if (grpc_core::ExecCtx::Get()->combiner_data()->active_combiner != lock) { in combiner_finally_exec()
[all …]
Dexec_ctx.h128 grpc_combiner* active_combiner; member
144 return combiner_data_.active_combiner != nullptr || in HasWork()
Dexec_ctx.cc141 GPR_ASSERT(combiner_data_.active_combiner == nullptr); in Flush()