| /openbmc/sdbusplus/include/sdbusplus/async/stdexec/__detail/ |
| H A D | __write_env.hpp | 37 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.hpp | 59 _Env&& __env) const noexcept 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 ()()
145 __env...); in operator ()()
163 __env), in operator ()()
164 __env))) -> decltype(auto) in operator ()()
170 __env); in operator ()()
[all …]
|
| H A D | __schedulers.hpp | 102 inline auto get_scheduler_t::operator()(const _Env& __env) const noexcept in operator ()()
107 return tag_invoke(get_scheduler_t{}, __env); in operator ()()
112 inline auto get_delegatee_scheduler_t::operator()(const _Env& __env) const in operator ()()
119 return tag_invoke(get_delegatee_scheduler_t{}, __env); in operator ()()
125 const _Env& __env) const noexcept in operator ()()
134 return tag_invoke(*this, __env); in operator ()()
143 auto __mkenv_sched(_Env&& __env, _Scheduler __sched) in __mkenv_sched() argument
146 __env::__join(prop{get_scheduler, __sched}, in __mkenv_sched()
147 __env::__without(static_cast<_Env&&>(__env), get_domain)); in __mkenv_sched()
|
| H A D | __env.hpp | 188 auto operator()(const _Env& __env) const noexcept
226 return tag_invoke(get_allocator_t{}, __env); in operator ()()
408 namespace __env namespace
616 auto operator()(_Env&& __env) const in operator ()()
661 constexpr auto operator()(_Env&& __env, in operator ()()
713 return static_cast<_Env&&>(__env);
753 using __env::env;
754 using __env::prop;
803 using __env::__as_root_env;
804 using __env::__as_root_env_t;
[all …]
|
| H A D | __on.hpp | 144 static auto __transform_env_fn(_Env&& __env) noexcept in __transform_env_fn()
150 return __detail::__mkenv_sched(static_cast<_Env&&>(__env), in __transform_env_fn()
155 return static_cast<_Env>(static_cast<_Env&&>(__env)); in __transform_env_fn()
162 static auto __transform_sender_fn(const _Env& __env) noexcept in __transform_sender_fn()
170 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.hpp | 60 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));
161 static_cast<_Sender&&>(__sndr), __env); in transform_sender()
192 _Env&& __env) const noexcept -> decltype(auto) 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()
280 auto operator()(const _Sender& __sndr, const _Env& __env) const noexcept in operator ()()
289 return get_domain(__env); in operator ()()
[all …]
|
| H A D | __sync_wait.hpp | 49 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 | __start_detached.hpp | 84 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 | __split.hpp | 49 _Env&& __env = {}) const -> __well_formed_sender auto 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 | __let.hpp | 47 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()
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()
339 __env::__without(static_cast<_Env&&>(__env), get_domain)); in __mk_transform_env_fn()
[all …]
|
| H A D | __ensure_started.hpp | 48 [[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.hpp | 76 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 | __transfer_just.hpp | 64 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.hpp | 44 || __awaitable<_Sender, __env::__promise<empty_env>>;
62 && requires(_Sender&& __sndr, _Env&&... __env) {
65 static_cast<_Env&&>(__env)...)
|
| H A D | __senders.hpp | 138 __env::__promise<_Env>...>)) in __impl()
141 __await_result_t<_TfxSender, __env::__promise<_Env>...>; in __impl()
308 auto&& __env = get_env(__rcvr);
309 auto __domain = __get_late_domain(__sndr, __env);
319 __domain, static_cast<_Sender&&>(__sndr), __env);
330 __env)
343 __env),
350 __env),
360 static_cast<_Sender&&>(__sndr), __env),
|
| H A D | __tag_invoke.hpp | 58 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.hpp | 137 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.hpp | 61 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 | __continue_on.hpp | 98 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.hpp | 54 struct __env struct
73 [](__ignore) noexcept { return __inln::__env(); }; in __anond6e5414a0102()
|
| H A D | __execution_fwd.hpp | 54 namespace __env namespace
63 using __env::env;
64 using __env::prop;
|
| H A D | __schedule_from.hpp | 200 auto __env = _Env{{static_cast<_Scheduler&&>(__sched)}}; in operator ()()
204 std::move(__env), static_cast<_Sender&&>(__sndr))); in operator ()()
224 return __env::__join(__data, stdexec::get_env(__child));
|
| /openbmc/sdbusplus/include/sdbusplus/async/stdexec/ |
| H A D | env.hpp | 42 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 D | async_scope.hpp | 560 __future_state_base(_Env __env, const __impl* __scope) : in __future_state_base()
564 static_cast<_Env&&>(__env),
705 __future_state(_Sender __sndr, _Env __env, const __impl* __scope) : in __future_state()
706 __future_state_base<_Completions, _Env>(static_cast<_Env&&>(__env), in __future_state()
812 using __spawn_env_t = __env::__join_t<_Env, __spawn_env_>;
868 __t(_Sndr&& __sndr, _Env __env, const __impl* __scope) : in __t()
870 __env::__join( in __t()
871 static_cast<_Env&&>(__env), in __t()
924 void spawn(_Sender&& __sndr, _Env __env = {}) in spawn()
931 static_cast<_Env&&>(__env), &__impl_});
[all …]
|
| H A D | sequence_senders.hpp | 249 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));
|