Home
last modified time | relevance | path

Searched refs:__env (Results 1 – 25 of 35) sorted by relevance

12

/openbmc/sdbusplus/include/sdbusplus/async/stdexec/__detail/
H A D__write_env.hpp37 auto operator()(_Sender&& __sndr, _Env __env) const in operator ()()
39 return __make_sexpr<__write_env_t>(static_cast<_Env&&>(__env), in operator ()()
45 auto operator()(_Env __env) const -> __binder_back<__write_env_t, _Env> in operator ()()
47 return {{static_cast<_Env&&>(__env)}, {}, {}}; in operator ()()
52 static auto __transform_env_fn(_Env&& __env) noexcept in __transform_env_fn()
55 return __env::__join(__state, static_cast<_Env&&>(__env)); in __transform_env_fn()
60 static auto transform_env(const _Self& __self, _Env&& __env) noexcept in transform_env()
63 __transform_env_fn(static_cast<_Env&&>(__env))); in transform_env()
71 return __env::__join(__state, stdexec::get_env(__rcvr)); in __anon164445800202()
78 __meval<__env::__join_t, const __decay_t<__data_of<_Self>>&,
H A D__transform_sender.hpp45 decltype(auto) transform_sender(_Sender&& __sndr, const _Env& __env) const
59 _Env&& __env) const noexcept in operator ()()
64 static_cast<_Env&&>(__env)); in operator ()()
69 static_cast<_Sender&&>(__sndr), static_cast<_Env&&>(__env)); in operator ()()
98 const _Env&... __env) const in operator ()()
105 __env...); in operator ()()
110 static_cast<_Sender&&>(__sndr), __env...); in operator ()()
125 const _Env&... __env) const in operator ()()
136 __env...); in operator ()()
144 __dom, static_cast<_Sender&&>(__sndr), __env...), in operator ()()
[all …]
H A D__schedulers.hpp102 inline auto get_scheduler_t::operator()(const _Env& __env) const noexcept in operator ()()
107 return tag_invoke(get_scheduler_t{}, __env); in operator ()()
113 const _Env& __env) const noexcept in operator ()()
121 return tag_invoke(get_delegation_scheduler_t{}, __env); in operator ()()
127 const _Env& __env) const noexcept in operator ()()
136 return tag_invoke(*this, __env); in operator ()()
145 auto __mkenv_sched(_Env&& __env, _Scheduler __sched) in __mkenv_sched() argument
148 __env::__join(prop{get_scheduler, __sched}, in __mkenv_sched()
149 __env::__without(static_cast<_Env&&>(__env), get_domain)); in __mkenv_sched()
H A D__env.hpp188 auto operator()(const _Env& __env) const noexcept
223 auto operator()(const _Env& __env) const noexcept in operator ()()
229 return tag_invoke(get_allocator_t{}, __env); in operator ()()
251 auto operator()(const _Env& __env) const noexcept in operator ()()
258 return tag_invoke(get_stop_token_t{}, __env); in operator ()()
333 constexpr auto operator()(const _Env& __env) const noexcept -> bool in operator ()()
335 STDEXEC_ASSERT(tag_invoke(__root_t{}, __env) == true); in operator ()()
417 namespace __env namespace
625 auto operator()(_Env&& __env) const in operator ()()
627 return __t<__fwd<__cvref_id<_Env>>>{static_cast<_Env&&>(__env)}; in operator ()()
[all …]
H A D__on.hpp143 static auto __transform_env_fn(_Env&& __env) noexcept in __transform_env_fn()
149 return __detail::__mkenv_sched(static_cast<_Env&&>(__env), in __transform_env_fn()
154 return static_cast<_Env>(static_cast<_Env&&>(__env)); in __transform_env_fn()
161 static auto __transform_sender_fn(const _Env& __env) noexcept in __transform_sender_fn()
169 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()
222 static auto transform_env(const _Sender& __sndr, _Env&& __env) noexcept in transform_env()
225 __transform_env_fn(static_cast<_Env&&>(__env))); in transform_env()
230 static auto transform_sender(_Sender&& __sndr, const _Env& __env) in transform_sender()
232 auto __tfx_sndr_fn = __transform_sender_fn(__env); in transform_sender()
H A D__domain.hpp60 requires(_DomainOrTag __tag, _Sender&& __sender, const _Env&... __env) {
61 __tag.transform_sender(static_cast<_Sender&&>(__sender), __env...);
71 requires(_Type __obj, _Sender&& __sender, _Env&& __env) {
73 static_cast<_Env&&>(__env));
155 decltype(auto) transform_sender(_Sender&& __sndr, const _Env& __env) const in transform_sender()
161 static_cast<_Sender&&>(__sndr), __env); in transform_sender()
191 auto transform_env(_Sender&& __sndr, _Env&& __env) const noexcept in transform_env()
197 static_cast<_Sender&&>(__sndr), static_cast<_Env&&>(__env)); in transform_env()
201 return static_cast<_Env>(static_cast<_Env&&>(__env)); in transform_env()
285 auto operator()(const _Sender& __sndr, const _Env& __env) const noexcept in operator ()()
[all …]
H A D__sync_wait.hpp49 struct __env struct
72 __value_types_of_t<_Sender, __env,
143 auto get_env() const noexcept -> __env in get_env()
145 return __env{&__state_->__loop_}; in get_env()
191 template <__mstring _Diagnostic, class _Sender, class _Env = __env>
204 _Sender, __env>>;
212 if constexpr (!sender_in<_Sender, __env>) in __diagnose_error()
214 using _Completions = __completion_signatures_of_t<_Sender, __env>; in __diagnose_error()
254 template <sender_in<__env> _Sender>
307 template <sender_in<__env> _Sender>
[all …]
H A D__let.hpp47 struct __env struct
65 constexpr auto get_env() const noexcept -> __env in get_env()
67 return __env(); in get_env()
135 return __env::__join( in get_env()
137 __env::__without(stdexec::get_env(__rcvr_), get_domain)); in get_env()
150 __env::__join_t< //
152 __env::__without_t<_Env, get_domain_t>>>;
317 auto __mk_transform_env_fn(_Env&& __env) noexcept in __mk_transform_env_fn() argument
332 return (__env); in __mk_transform_env_fn()
336 return __env::__join( in __mk_transform_env_fn()
[all …]
H A D__split.hpp48 auto operator()(_Sender&& __sndr, _Env&& __env = {}) const in operator ()()
51 auto __domain = __get_late_domain(__sndr, __env);
53 __domain, __make_sexpr<split_t>(static_cast<_Env&&>(__env),
84 [&]<class _Env, class _Child>(__ignore, _Env&& __env, in transform_sender()
90 static_cast<_Env&&>(__env)); in transform_sender()
H A D__start_detached.hpp84 void operator()(_Sender&& __sndr, _Env&& __env) const in operator ()()
86 auto __domain = __get_late_domain(__sndr, __env); in operator ()()
88 __as_root_env(static_cast<_Env&&>(__env))); in operator ()()
101 void apply_sender(_Sender&& __sndr, _Env&& __env = {}) const in apply_sender()
104 __detached_receiver_t<_Env>{static_cast<_Env&&>(__env)});
H A D__ensure_started.hpp48 [[nodiscard]] auto operator()(_Sender&& __sndr, _Env&& __env = {}) const in operator ()()
57 auto __domain = __get_late_domain(__sndr, __env);
60 __make_sexpr<ensure_started_t>(static_cast<_Env&&>(__env),
92 [&]<class _Env, class _Child>(__ignore, _Env&& __env, in transform_sender()
98 static_cast<_Env&&>(__env)); in transform_sender()
H A D__start_on.hpp76 static auto __transform_env_fn(_Env&& __env) noexcept in __transform_env_fn()
79 return __detail::__mkenv_sched(static_cast<_Env&&>(__env), __sched); in __transform_env_fn()
84 static auto transform_env(const _Sender& __sndr, _Env&& __env) noexcept in transform_env()
87 __transform_env_fn(static_cast<_Env&&>(__env))); in transform_env()
H A D__starts_on.hpp77 static auto __transform_env_fn(_Env&& __env) noexcept in __transform_env_fn()
80 return __detail::__mkenv_sched(static_cast<_Env&&>(__env), __sched); in __transform_env_fn()
85 static auto transform_env(const _Sender& __sndr, _Env&& __env) noexcept in transform_env()
88 __transform_env_fn(static_cast<_Env&&>(__env))); in transform_env()
H A D__senders.hpp139 __env::__promise<_Env>...>)) in __impl()
142 __await_result_t<_TfxSender, __env::__promise<_Env>...>; in __impl()
307 auto&& __env = get_env(__rcvr);
308 auto __domain = __get_late_domain(__sndr, __env);
318 __domain, static_cast<_Sender&&>(__sndr), __env);
329 __env)
342 __env),
349 __env),
359 static_cast<_Sender&&>(__sndr), __env),
H A D__transfer_just.hpp64 auto __transform_sender_fn(const _Env& __env) in __transform_sender_fn() argument
67 return __data.apply(__make_transform_fn(__env), in __transform_sender_fn()
102 static auto transform_sender(_Sender&& __sndr, const _Env& __env) in transform_sender()
105 __transform_sender_fn(__env)); in transform_sender()
H A D__senders_core.hpp44 || __awaitable<_Sender, __env::__promise<empty_env>>;
62 && requires(_Sender&& __sndr, _Env&&... __env) {
65 static_cast<_Env&&>(__env)...)
H A D__tag_invoke.hpp58 constexpr auto tag_invoke(_Tag, const _Env& __env) noexcept( in tag_invoke() argument
59 noexcept(__env.query(_Tag()))) -> decltype(__env.query(_Tag())) in tag_invoke()
61 return __env.query(_Tag()); in tag_invoke()
H A D__run_loop.hpp137 struct __env struct
139 using __t = __env; argument
140 using __id = __env; argument
159 auto get_env() const noexcept -> __env in get_env()
161 return __env{__loop_}; in get_env()
H A D__submit.hpp61 auto&& __env = stdexec::get_env(__op->__rcvr_); in __delete_op()
62 auto __alloc = stdexec::get_allocator(__env); in __delete_op()
131 auto&& __env = get_env(__rcvr); in operator ()()
132 auto __alloc = get_allocator(__env); in operator ()()
H A D__continues_on.hpp98 static auto transform_sender(_Sender&& __sndr, const _Env& __env) in transform_sender()
101 __transform_sender_fn(__env)); in transform_sender()
111 return __env::__join(__data, stdexec::get_env(__child));
H A D__continue_on.hpp98 static auto transform_sender(_Sender&& __sndr, const _Env& __env) in transform_sender()
101 __transform_sender_fn(__env)); in transform_sender()
111 return __env::__join(__data, stdexec::get_env(__child));
H A D__inline_scheduler.hpp54 struct __env struct
73 [](__ignore) noexcept { return __inln::__env(); }; in __anond6e5414a0102()
/openbmc/sdbusplus/include/sdbusplus/async/stdexec/
H A Denv.hpp42 auto operator()(_Env&& __env, _Tag) const -> decltype(auto) in operator ()()
44 return stdexec::__env::__without(static_cast<_Env&&>(__env), _Tag()); in operator ()()
54 auto operator()(_Base&& __base, _Env&& __env) const noexcept in operator ()()
55 -> stdexec::__env::__join_t<_Env, _Base> in operator ()()
57 return stdexec::__env::__join(static_cast<_Env&&>(__env), in operator ()()
62 auto operator()(_Env&& __env) const noexcept -> _Env in operator ()()
64 return static_cast<_Env&&>(__env); in operator ()()
102 const auto& __env = get_env(__rcvr_); in start() local
103 stdexec::set_value(std::move(__rcvr_), _Tag{}(__env)); in start()
H A Dsequence_senders.hpp249 requires(_Sender&& __sndr, _Env&&... __env) {
251 static_cast<_Env&&>(__env)...);
425 auto&& __env = get_env(__rcvr);
426 auto __domain = __get_late_domain(__sndr, __env);
437 __domain, static_cast<_Sender&&>(__sndr), __env));
454 __env),
465 static_cast<_Sender&&>(__sndr), __env),
472 __domain, static_cast<_Sender&&>(__sndr), __env));
H A Dasync_scope.hpp562 __future_state_base(_Env __env, const __impl* __scope) : in __future_state_base()
566 static_cast<_Env&&>(__env),
704 __future_state(_Sender __sndr, _Env __env, const __impl* __scope) : in __future_state()
705 __future_state_base<_Completions, _Env>(static_cast<_Env&&>(__env), in __future_state()
811 using __spawn_env_t = __env::__join_t<_Env, __spawn_env_>;
867 __t(_Sndr&& __sndr, _Env __env, const __impl* __scope) : in __t()
869 __env::__join( in __t()
870 static_cast<_Env&&>(__env), in __t()
923 void spawn(_Sender&& __sndr, _Env __env = {}) in spawn()
930 static_cast<_Env&&>(__env), &__impl_}));
[all …]

12