| /openbmc/sdbusplus/include/sdbusplus/async/stdexec/__detail/ |
| H A D | __receivers.hpp | 41 -> decltype(static_cast<_Receiver&&>(__rcvr).set_value( in tag_invoke()
62 static_cast<_Receiver&&>(__rcvr), in operator ()()
76 -> decltype(static_cast<_Receiver&&>(__rcvr).set_error( in tag_invoke()
87 static_cast<_Receiver&&>(__rcvr).set_error( in tag_invoke()
98 static_cast<_Receiver&&>(__rcvr), in operator ()()
111 friend auto tag_invoke(_Self, _Receiver&& __rcvr) noexcept in tag_invoke() argument
120 static_cast<_Receiver&&>(__rcvr).set_stopped(); in tag_invoke()
126 void operator()(_Receiver&& __rcvr) const noexcept in operator ()()
130 static_cast<_Receiver&&>(__rcvr)); in operator ()()
203 void __set_value_invoke(_Receiver&& __rcvr, _Fun&& __fun, in __set_value_invoke() argument
[all …]
|
| H A D | __when_all.hpp | 151 auto __complete_fn(_Tag, _Receiver& __rcvr) noexcept in __complete_fn() argument
159 void __set_values(_Receiver& __rcvr, _ValuesTuple& __values) noexcept in __set_values() argument
207 void __arrive(_Receiver& __rcvr) noexcept in __arrive()
211 __complete(__rcvr); in __arrive()
216 void __complete(_Receiver& __rcvr) noexcept in __complete()
227 __when_all::__set_values(__rcvr, __values_); in __complete()
333 __when_all::__mk_state_fn(stdexec::get_env(__rcvr)));
338 _State& __state, _Receiver& __rcvr,
347 stdexec::set_stopped(static_cast<_Receiver&&>(__rcvr));
354 __state.__complete(__rcvr);
[all …]
|
| H A D | __basic_sender.hpp | 150 _Index, __ignore, _Receiver& __rcvr, _SetTag,
238 __op_base(_Sexpr&& __sndr, _Receiver&& __rcvr) // in __op_base()
241 __rcvr_(static_cast<_Receiver&&>(__rcvr)), in __op_base()
246 auto __rcvr() & noexcept -> _Receiver& in __rcvr() function
251 auto __rcvr() const& noexcept -> const _Receiver& in __rcvr() function
295 return __base->__rcvr(); in __receiver()
363 __op_state(_Sexpr&& __sexpr, _Receiver __rcvr) // in __op_state()
369 static_cast<_Receiver&&>(__rcvr)}, in __op_state()
378 auto&& __rcvr = this->__rcvr(); in start()
391 auto&& __rcvr = this->__rcvr(); in __complete()
[all …]
|
| H A D | __run_loop.hpp | 72 auto& __rcvr = static_cast<__t*>(__p)->__rcvr_; in __execute_impl() local
75 if (stdexec::get_stop_token(stdexec::get_env(__rcvr)) in __execute_impl()
78 stdexec::set_stopped(static_cast<_Receiver&&>(__rcvr)); in __execute_impl()
82 stdexec::set_value(static_cast<_Receiver&&>(__rcvr)); in __execute_impl()
87 stdexec::set_error(static_cast<_Receiver&&>(__rcvr), in __execute_impl()
94 __t(__task* __next, run_loop* __loop, _Receiver __rcvr) : in __t()
96 __rcvr_{static_cast<_Receiver&&>(__rcvr)}
128 auto connect(_Receiver __rcvr) const -> __operation<_Receiver> in connect()
131 static_cast<_Receiver&&>(__rcvr)}; in connect()
|
| H A D | __connect_awaitable.hpp | 120 explicit __t(auto&, _Receiver& __rcvr) noexcept : __rcvr_(__rcvr) {} in __t()
209 _Receiver __rcvr) -> __operation_t<_Receiver> in __co_impl()
218 static_cast<_Receiver&&>(__rcvr))); in __co_impl()
221 set_value, static_cast<_Receiver&&>(__rcvr), in __co_impl()
228 co_await __co_call(set_error, static_cast<_Receiver&&>(__rcvr), in __co_impl()
244 _Receiver __rcvr) const -> __operation_t<_Receiver> in operator ()()
247 static_cast<_Receiver&&>(__rcvr)); in operator ()()
|
| H A D | __stopped_as_optional.hpp | 88 __ignore, _State&, _Receiver& __rcvr, _Tag,
95 stdexec::set_value(static_cast<_Receiver&&>(__rcvr),
101 stdexec::set_error(static_cast<_Receiver&&>(__rcvr),
107 stdexec::set_error(static_cast<_Receiver&&>(__rcvr),
112 stdexec::set_value(static_cast<_Receiver&&>(__rcvr),
|
| H A D | __submit.hpp | 117 __operation(_Sender&& __sndr, _Receiver __rcvr) : in __operation()
118 __rcvr_(static_cast<_Receiver&&>(__rcvr)), in __operation()
127 void operator()(_Sender&& __sndr, _Receiver __rcvr) const noexcept(false) in operator ()()
131 auto&& __env = get_env(__rcvr); in operator ()()
144 static_cast<_Receiver&&>(__rcvr)); in operator ()()
158 static_cast<_Receiver&&>(__rcvr)}) in operator ()()
|
| H A D | __read_env.hpp | 106 _Receiver& __rcvr) noexcept -> void {
113 stdexec::__set_value_invoke(static_cast<_Receiver&&>(__rcvr),
114 __query(), stdexec::get_env(__rcvr));
123 return __query()(stdexec::get_env(__rcvr)); in __anona47160310102()
127 stdexec::__set_value_invoke(static_cast<_Receiver&&>(__rcvr),
|
| H A D | __into_variant.hpp | 91 __ignore, _State, _Receiver& __rcvr, _Tag,
98 set_value(static_cast<_Receiver&&>(__rcvr),
104 stdexec::set_error(static_cast<_Receiver&&>(__rcvr),
110 _Tag()(static_cast<_Receiver&&>(__rcvr),
|
| H A D | __senders.hpp | 303 auto operator()(_Sender&& __sndr, _Receiver&& __rcvr) const
308 auto&& __env = get_env(__rcvr);
321 static_cast<_Receiver&&>(__rcvr));
331 .connect(static_cast<_Receiver&&>(__rcvr));
344 static_cast<_Receiver&&>(__rcvr));
351 static_cast<_Receiver&&>(__rcvr));
361 static_cast<_Receiver&&>(__rcvr));
382 && requires(_Sender&& __sndr, _Receiver&& __rcvr) {
384 static_cast<_Receiver&&>(__rcvr));
|
| H A D | __bulk.hpp | 133 __ignore, _State& __state, _Receiver& __rcvr, _Tag,
144 _Tag()(static_cast<_Receiver&&>(__rcvr),
155 _Tag()(static_cast<_Receiver&&>(__rcvr),
160 stdexec::set_error(static_cast<_Receiver&&>(__rcvr),
167 _Tag()(static_cast<_Receiver&&>(__rcvr),
|
| H A D | __then.hpp | 91 __ignore, _State& __state, _Receiver& __rcvr, _Tag,
95 stdexec::__set_value_invoke(static_cast<_Receiver&&>(__rcvr),
101 _Tag()(static_cast<_Receiver&&>(__rcvr),
|
| H A D | __upon_error.hpp | 93 __ignore, _State& __state, _Receiver& __rcvr, _Tag,
97 stdexec::__set_value_invoke(static_cast<_Receiver&&>(__rcvr),
103 _Tag()(static_cast<_Receiver&&>(__rcvr),
|
| H A D | __upon_stopped.hpp | 94 __ignore, _State& __state, _Receiver& __rcvr, _Tag,
98 stdexec::__set_value_invoke(static_cast<_Receiver&&>(__rcvr),
104 _Tag()(static_cast<_Receiver&&>(__rcvr),
|
| H A D | __inline_scheduler.hpp | 82 []<class _Receiver>(__ignore, _Receiver& __rcvr) noexcept -> void {
83 stdexec::set_value(static_cast<_Receiver&&>(__rcvr));
|
| H A D | __write_env.hpp | 70 [](__ignore, const auto& __state, const auto& __rcvr) noexcept { in __anon164445800202()
71 return __env::__join(__state, stdexec::get_env(__rcvr)); in __anon164445800202()
|
| H A D | __let.hpp | 419 _Receiver& __rcvr = __op_state.__rcvr_; in __get_result_receiver() local
422 return static_cast<_Receiver&&>(__rcvr); in __get_result_receiver()
426 return __receiver_with_sched{static_cast<_Receiver&&>(__rcvr), in __get_result_receiver()
432 auto __get_env(const _Receiver& __rcvr) const noexcept -> __env_t in __get_env()
436 return stdexec::get_env(__rcvr); in __get_env()
442 __env::__without(stdexec::get_env(__rcvr), get_domain)); in __get_env()
568 _Receiver& __rcvr = __op_state.__rcvr_; in __bind() local
586 stdexec::set_error(static_cast<_Receiver&&>(__rcvr), in __bind()
|
| H A D | __just.hpp | 48 _Receiver& __rcvr) noexcept -> void {
51 __tag_t()(static_cast<_Receiver&&>(__rcvr),
|
| H A D | __shared.hpp | 67 auto __make_notify_visitor(_Receiver& __rcvr) noexcept in __make_notify_visitor() argument
72 __tag(static_cast<_Receiver&&>(__rcvr), in __make_notify_visitor()
503 _Receiver& __rcvr) noexcept -> void {
516 const auto __stok = stdexec::get_stop_token(stdexec::get_env(__rcvr));
539 stdexec::set_stopped(static_cast<_Receiver&&>(__rcvr));
|
| H A D | __schedule_from.hpp | 246 __ignore, _State& __state, _Receiver& __rcvr, _Tag __tag,
266 stdexec::set_error(static_cast<_Receiver&&>(__rcvr),
|
| /openbmc/sdbusplus/include/sdbusplus/async/stdexec/ |
| H A D | sequence_senders.hpp | 67 auto operator()(_Receiver& __rcvr, _Item&& __item) const in operator ()()
425 auto&& __env = get_env(__rcvr);
436 __rcvr, transform_sender(
441 static_cast<_Receiver&&>(__rcvr)});
455 static_cast<_Receiver&&>(__rcvr));
466 static_cast<_Receiver&&>(__rcvr));
471 __rcvr, transform_sender(
477 static_cast<_Receiver&&>(__rcvr)});
501 requires(_Sender&& __sndr, _Receiver&& __rcvr) {
503 static_cast<_Receiver&&>(__rcvr));
[all …]
|
| H A D | async_scope.hpp | 82 _Receiver __rcvr) : in __t()
85 static_cast<_Receiver&&>(__rcvr)))
135 static_cast<_Receiver&&>(__rcvr)}; in connect()
256 explicit __t(const __impl* __scope, _Sender&& __c, _Rcvr&& __rcvr) : in __t()
258 {}, __scope, static_cast<_Rcvr&&>(__rcvr)}, in __t()
300 [[nodiscard]] static auto connect(_Self&& __self, _Receiver __rcvr) in connect()
305 static_cast<_Receiver&&>(__rcvr)}; in connect()
450 explicit __t(_Receiver2&& __rcvr, in __t() argument
456 __rcvr_(static_cast<_Receiver2&&>(__rcvr)),
760 _Receiver __rcvr) -> __future_op_t<_Receiver> in connect() argument
[all …]
|
| H A D | any_sender_of.hpp | 56 auto operator()(_Tag, void* __rcvr, _As&&... __as) const -> _Ret in operator ()()
58 return __fn_(__rcvr, static_cast<_As&&>(__as)...); in operator ()()
69 return __fn_(__rcvr, static_cast<_As&&>(__as)...); in operator ()()
80 return __fn_(__rcvr, static_cast<_As&&>(__as)...); in operator ()()
91 return __fn_(__rcvr, static_cast<_As&&>(__as)...); in operator ()()
824 __ref(_Rcvr& __rcvr) noexcept : in __ref()
826 &__rcvr, stdexec::get_stop_token(stdexec::get_env(__rcvr))} in __ref()
913 __ref(_Rcvr& __rcvr) noexcept : in __ref()
915 &__rcvr} in __ref()
1251 auto connect(_Rcvr __rcvr) && // in connect()
[all …]
|
| H A D | env.hpp | 145 static auto connect(_Self&& __self, _Receiver __rcvr) // in connect()
151 static_cast<_Receiver&&>(__rcvr)}; in connect()
|
| H A D | at_coroutine_exit.hpp | 99 auto connect(_Receiver __rcvr) && noexcept in connect()
104 __receiver<_Receiver>{static_cast<_Receiver&&>(__rcvr)}); in connect()
|