| /openbmc/sdbusplus/include/sdbusplus/async/stdexec/ |
| H A D | async_scope.hpp | 70 struct __t : __task { struct
71 using __id = __when_empty_op;
73 explicit __t(const __impl* __scope, _Constrained&& __sndr, _Receiver __rcvr) in __t() function
81 void start() & noexcept { in start()
96 static void __notify_waiter(__task* __self) noexcept { in __notify_waiter()
101 connect_result_t<_Constrained, _Receiver> __op_;
109 struct __t { struct
110 using __id = __when_empty_sender;
111 using sender_concept = stdexec::sender_t;
114 using __when_empty_op_t =
[all …]
|
| H A D | env.hpp | 78 struct __t : __immovable { struct
79 using __id = __operation;
82 _Receiver __rcvr_;
84 constexpr void start() & noexcept { in start()
106 using __t = __sender; typedef
157 struct __t { struct
158 using sender_concept = sender_t;
159 using __id = __sender;
160 _Sender __sndr_;
161 _Attrs __attrs_;
[all …]
|
| H A D | at_coroutine_exit.hpp | 39 struct __t { struct
40 using receiver_concept = stdexec::receiver_t;
41 using __id = __receiver_id;
42 _Receiver __receiver_;
46 void set_value(_Args&&... __args) noexcept { in set_value()
53 void set_error(_Error&& __err) noexcept { in set_error()
58 void set_stopped() noexcept { in set_stopped()
62 auto get_env() const noexcept -> env_of_t<_Receiver> { in get_env()
79 struct __t { struct
80 using __id = __sender_id;
[all …]
|
| H A D | any_sender_of.hpp | 269 class __t : __immovable { class
290 __t(_Tp&& __object) in __t() function in exec::__any::__immovable_storage::__t
302 __t(std::in_place_type_t<_Tp>, _Args&&... __args) in __t() function in exec::__any::__immovable_storage::__t
387 class __storage<_Vtable, _Allocator, _Copyable, _InlineSize, _Alignment>::__t class in exec::__any::__storage
431 __t(_Tp&& __object) in __t() function in exec::__any::__storage::__t
443 __t(std::in_place_type_t<_Tp>, _Args&&... __args) in __t() function in exec::__any::__storage::__t
452 __t(const __t& __other) in __t() function in exec::__any::__storage::__t
468 __t(__t&& __other) noexcept in __t() function in exec::__any::__storage::__t
664 struct __t struct
674 const __any_::__rcvr_vfun<_Tag(_As...)>& __vfun = *this;
[all …]
|
| H A D | sequence_senders.hpp | 100 struct __t { struct
101 using receiver_concept = stdexec::receiver_t;
102 using __id = __stopped_means_break;
103 using _Receiver = stdexec::__t<_ReceiverId>;
104 using __token_t = stop_token_of_t<env_of_t<_Receiver>>;
107 auto get_env() const noexcept -> env_of_t<_Receiver> { in get_env()
111 void set_value() noexcept in set_value()
117 void set_stopped() noexcept in set_stopped()
725 using __t = __debug_sequence_sender_receiver; typedef
739 using __t = __debug_sequence_sender_receiver; typedef
|
| H A D | task.hpp | 323 using __t = basic_task; typedef in exec::__task::basic_task
359 using __t = __promise; typedef
|
| /openbmc/sdbusplus/include/sdbusplus/async/stdexec/__detail/ |
| H A D | __connect_awaitable.hpp | 94 struct __t : __operation_base { struct
95 using promise_type = stdexec::__t<__promise<_ReceiverId>>;
104 struct __t struct
107 using __id = __promise;
110 __t(auto&&, _Receiver&& __rcvr) noexcept in __t() argument
114 explicit __t(auto&, _Receiver& __rcvr) noexcept in __t() function
119 auto unhandled_stopped() noexcept -> __coro::coroutine_handle<> { in unhandled_stopped()
127 auto get_return_object() noexcept -> stdexec::__t<__operation<_ReceiverId>> { in get_return_object()
133 auto get_env() const noexcept -> env_of_t<_Receiver> { in get_env()
137 _Receiver& __rcvr_;
|
| H A D | __sync_wait.hpp | 47 using __t = __env; typedef
96 struct __t { struct
97 using receiver_concept = receiver_t;
98 using __id = __receiver;
99 __state* __state_;
100 std::optional<std::tuple<_Values...>>* __values_;
104 void set_value(_As&&... __as) noexcept { in set_value()
115 void set_error(_Error __err) noexcept { in set_error()
127 void set_stopped() noexcept { in set_stopped()
132 auto get_env() const noexcept -> __env { in get_env()
[all …]
|
| H A D | __as_awaitable.hpp | 83 struct __t : __receiver_base<_Value> { struct
84 using __id = __receiver;
86 void set_stopped() noexcept { in set_stopped()
95 auto get_env() const noexcept -> env_of_t<_Promise&> { in get_env()
159 struct __t : __sender_awaitable_base<__value> { struct
160 __t(_Sender&& sndr, __coro::coroutine_handle<_Promise> __hcoro) in __t() function
169 void await_suspend(__coro::coroutine_handle<_Promise>) noexcept { in await_suspend()
174 using __receiver = __receiver_t<_Sender, _Promise>;
175 connect_result_t<_Sender, __receiver> __op_state_;
|
| H A D | __schedule_from.hpp | 107 struct __t { struct
108 using receiver_concept = receiver_t;
109 using __id = __rcvr2;
111 void set_value() noexcept { in set_value()
116 void set_error(_Error&& __err) noexcept { in set_error()
121 void set_stopped() noexcept { in set_stopped()
125 auto get_env() const noexcept -> env_of_t<_Receiver> { in get_env()
129 __state<_Scheduler, _Sexpr, _Receiver>* __state_;
|
| H A D | __run_loop.hpp | 55 struct __t : __task { struct
56 using __id = __operation;
58 run_loop* __loop_;
61 static void __execute_impl(__task* __p) noexcept { in __execute_impl()
75 explicit __t(__task* __tail) noexcept in __t() function
79 __t(__task* __next, run_loop* __loop, _Receiver __rcvr) in __t() function
97 using __t = __schedule_task; typedef
118 using __t = __env; typedef
151 using __t = __scheduler; typedef
|
| H A D | __env.hpp | 257 using __t = __root_env; typedef
363 using __t = prop; typedef
383 using __t = cprop; typedef
399 using __t = env; typedef
408 using __t = env; typedef
414 using __t = env; typedef
434 using __t = env; typedef
454 using __t = env; typedef
466 struct __t { struct
467 using __id = __fwd;
[all …]
|
| H A D | __basic_sender.hpp | 352 struct __t { struct
353 using receiver_concept = receiver_t;
354 using __id = __rcvr;
356 using __index = __msize_t<_Idx>;
357 using __parent_op_t = __op_state<_Sexpr, _Receiver>;
358 using __tag_t = tag_of_t<_Sexpr>;
362 __parent_op_t* __op_;
365 STDEXEC_ATTRIBUTE(always_inline) in STDEXEC_ATTRIBUTE()
371 STDEXEC_ATTRIBUTE(always_inline) in STDEXEC_ATTRIBUTE()
376 STDEXEC_ATTRIBUTE(always_inline) void set_stopped() noexcept { in STDEXEC_ATTRIBUTE()
[all …]
|
| H A D | __let.hpp | 102 struct __t { struct
103 using receiver_concept = receiver_t;
104 using __id = __rcvr_sch;
105 _Receiver __rcvr_;
106 _Scheduler __sched_;
109 void set_value(_As&&... __as) noexcept { in set_value()
114 void set_error(_Error&& __err) noexcept { in set_error()
118 void set_stopped() noexcept { in set_stopped()
122 auto get_env() const noexcept { in get_env()
146 using __t = __mexception< typedef
[all …]
|
| H A D | __debug.hpp | 98 using __t = __debug_receiver; typedef
106 using __t = __debug_receiver; typedef
135 struct __t { struct
139 __t(__debug_receiver<_CvrefSenderId, _Env, completion_signatures<_Sigs...>>&&) noexcept { in __t() function
|
| H A D | __shared.hpp | 181 struct __t { struct
182 using receiver_concept = receiver_t;
183 using __id = __receiver;
186 STDEXEC_ATTRIBUTE(always_inline) in STDEXEC_ATTRIBUTE()
192 STDEXEC_ATTRIBUTE(always_inline) in STDEXEC_ATTRIBUTE()
197 STDEXEC_ATTRIBUTE(always_inline) void set_stopped() noexcept { in STDEXEC_ATTRIBUTE()
201 auto get_env() const noexcept -> const __env_t<_Env>& { in get_env()
206 __shared_state<_CvrefSender, _Env>* __sh_state_;
|
| H A D | __inline_scheduler.hpp | 30 using __t = __opstate; typedef
57 using __t = __sender; typedef
75 using __t = inline_scheduler; typedef
|
| H A D | __meta.hpp | 33 using __t = _Tp::__t; typedef
37 using __t = _Ty; typedef
342 using __t = __meval__<_Fn, _Args...>; typedef
357 using __t = __minvoke__<_Fn, _Args...>; typedef
481 using __t = __minvoke<_Fn, _Args...>; typedef
492 using __t = __minvoke<_Fn, _Args...>; typedef
841 using __t = _Ty; typedef
907 using __t = __call_result_t<_Fn>; typedef
940 using __t = __minvoke<_Continuation, __minvoke<_Fn, _Cs, _Ds>...>; typedef
|
| H A D | __start_detached.hpp | 36 using __t = __submit_receiver; typedef
94 using __t = __receiver; typedef
|
| H A D | __any_receiver_ref.hpp | 85 using __t = __receiver_ref; typedef in stdexec::__any_::__receiver_ref
|
| H A D | __on.hpp | 81 using __t = __with_sched; typedef
|
| H A D | __tuple.hpp | 205 using __t = __tuple<__indices_for<_Ts...>{}, _Ts...>; typedef
|