Home
last modified time | relevance | path

Searched refs:get_scheduler (Results 1 – 15 of 15) sorted by relevance

/openbmc/sdbusplus/include/sdbusplus/async/
H A Dcontext.hpp65 std::move(execution::on(loop.get_scheduler(), std::move(sender)))); in spawn()
167 static auto get_scheduler(context& ctx) in get_scheduler() function
169 return ctx.loop.get_scheduler(); in get_scheduler()
H A Dtimer.hpp107 return execution::transfer(sleep_sender(ctx, time), get_scheduler(ctx)); in sleep_for()
/openbmc/sdbusplus/include/sdbusplus/async/stdexec/__detail/
H A D__schedulers.hpp95 { get_scheduler(__sp) } -> scheduler;
146 __env::__join(prop{get_scheduler, __sched}, in __mkenv_sched()
H A D__run_loop.hpp148 return __loop_->get_scheduler(); in query()
194 auto get_scheduler() noexcept -> __scheduler in get_scheduler() function in stdexec::__loop::run_loop
H A D__on.hpp170 auto __old = query_or(get_scheduler, __env, __none_such{}); in __transform_sender_fn()
198 query_or(get_scheduler, __env, __none_such{})); in __transform_sender_fn()
H A D__sync_wait.hpp55 return __loop_->get_scheduler(); in query()
61 return __loop_->get_scheduler(); in query()
H A D__read_env.hpp146 return read_env(get_scheduler); in operator ()()
H A D__let.hpp136 prop{get_scheduler, __sched_}, in get_env()
337 prop{get_scheduler, get_completion_scheduler<_Set>( in __mk_transform_env_fn()
441 prop{get_scheduler, __sched_}, in __get_env()
H A D__execution_fwd.hpp115 extern const get_scheduler_t get_scheduler;
H A D__domain.hpp294 return get_domain(get_scheduler(__env)); in operator ()()
H A D__p2300.hpp90 inline constexpr stdexec::get_scheduler_t get_scheduler{}; variable
H A D__env.hpp377 inline constexpr get_scheduler_t get_scheduler{}; variable
/openbmc/sdbusplus/include/sdbusplus/async/stdexec/
H A Dtask.hpp126 __scheduler_ = get_scheduler(get_env(__parent)); in __default_task_context_impl()
433 get_scheduler(*__context_)), in await_transform()
446 auto __sched = get_scheduler(*__context_); in await_transform()
H A Dat_coroutine_exit.hpp172 get_scheduler(get_env(__parent.promise())); in await_suspend()
/openbmc/sdbusplus/src/async/
H A Dcontext.cpp107 ctx.loop.get_scheduler()); in loop()