| /openbmc/sdbusplus/include/sdbusplus/async/stdexec/ |
| H A D | any_sender_of.hpp | 231 __mtype<_Tp>, _Storage& __self, in operator ()()
630 if (!__self.__object_pointer_) in tag_invoke()
670 __self.__vtable_ = std::exchange( in tag_invoke()
828 return (*__self.__vtable_)(_Tag{}, __self.__rcvr_, in tag_invoke()
835 return __self.__token_; in tag_invoke()
865 return __self.__env_; in tag_invoke()
911 return (*__self.__vtable_)(_Tag{}, __self.__rcvr_, in tag_invoke()
942 return __self.__env_; in tag_invoke()
1084 __self.__on_stop_.emplace( in tag_invoke()
1212 return __self.__vtable_->__queries()(_Tag{}, __self.__sender_, in tag_invoke()
[all …]
|
| H A D | task.hpp | 120 return __self.__scheduler_; in tag_invoke()
127 return __self.__stop_token_; in tag_invoke()
172 __default_task_context_impl<_Affinity>& __self, in __default_awaiter_context()
196 __default_task_context_impl<_Affinity>& __self, in __default_awaiter_context()
213 __self.__stop_token_ = __stop_source_.get_token();
229 __default_task_context_impl<_Affinity>& __self, in __default_awaiter_context()
249 __default_task_context_impl<_Affinity>& __self, in __default_awaiter_context()
267 __default_task_context_impl<_Affinity>& __self, in __default_awaiter_context()
280 __default_task_context_impl<_Affinity>& __self, in __default_awaiter_context()
486 return __self.__context_; in tag_invoke()
[all …]
|
| H A D | async_scope.hpp | 103 return __self.__start_(); in tag_invoke()
133 __self.__scope_, static_cast<_Self&&>(__self).__c_, in tag_invoke()
259 return __self.__start_(); in tag_invoke()
293 __self.__scope_, static_cast<_Self&&>(__self).__c_, in tag_invoke()
366 __self.__start_(); in tag_invoke()
644 auto& __state = *__self.__state_; in tag_invoke()
652 __self.__dispatch_result_(); in tag_invoke()
665 return __self.__state_->__env_; in tag_invoke()
800 __self.__op_->__delete_(__self.__op_); in tag_invoke()
814 return __self.__op_->__env_; in tag_invoke()
[all …]
|
| H A D | at_coroutine_exit.hpp | 54 friend void tag_invoke(_Tag, _Self&& __self, in tag_invoke()
57 _Tag{}(static_cast<_Receiver&&>(__self.__receiver_), in tag_invoke()
67 friend auto tag_invoke(get_env_t, const __t& __self) noexcept in tag_invoke()
70 return get_env(__self.__receiver_); in tag_invoke()
94 friend auto tag_invoke(connect_t, __t&& __self, in tag_invoke()
99 static_cast<_Sender&&>(__self.__sender_), in tag_invoke()
110 friend auto tag_invoke(get_env_t, const __t& __self) noexcept in tag_invoke()
113 return get_env(__self.__sender_); in tag_invoke()
210 friend auto tag_invoke(get_scheduler_t, __env __self) noexcept in tag_invoke() argument
213 return __self.__promise_.__scheduler_; in tag_invoke()
[all …]
|
| H A D | env.hpp | 96 friend void tag_invoke(start_t, __t& __self) noexcept in tag_invoke()
102 const auto& __env = get_env(__self.__rcvr_); in tag_invoke()
103 set_value(std::move(__self.__rcvr_), _Tag{}(__env)); in tag_invoke()
107 set_value(std::move(__self.__rcvr_), in tag_invoke()
108 std::move(__self.__default_)); in tag_invoke()
113 set_error(std::move(__self.__rcvr_), std::current_exception()); in tag_invoke()
143 friend auto tag_invoke(connect_t, _Self&& __self, _Receiver __rcvr) // in tag_invoke() argument
148 static_cast<_Self&&>(__self).__default_, in tag_invoke()
|
| H A D | execution.hpp | 1411 __self.__coro_.resume(); in tag_invoke()
1475 return get_env(__self.__rcvr_); in tag_invoke()
1791 __self.__continuation_.resume(); in tag_invoke()
2165 __self.__delete_op(); in tag_invoke()
2342 return __self.__env_; in tag_invoke()
3568 *__self.__shared_state_; in tag_invoke()
4618 __self.__start_(); in tag_invoke()
4706 return __self.__schedule(); in tag_invoke()
5238 return __sexpr_apply(__self, in transform_env()
5748 static_cast<_Self&&>(__self),
[all …]
|
| H A D | sequence_senders.hpp | 104 friend auto tag_invoke(_GetEnv, const _Self& __self) noexcept in tag_invoke()
107 return stdexec::get_env(__self.__rcvr_); in tag_invoke()
112 friend void tag_invoke(_SetValue, _Self&& __self) noexcept in tag_invoke()
114 return stdexec::set_value(static_cast<_Receiver&&>(__self.__rcvr_)); in tag_invoke()
121 friend void tag_invoke(_SetStopped, _Self&& __self) noexcept in tag_invoke()
125 stdexec::set_value(static_cast<_Receiver&&>(__self.__rcvr_)); in tag_invoke()
130 stdexec::get_stop_token(stdexec::get_env(__self.__rcvr_)); in tag_invoke()
134 static_cast<_Receiver&&>(__self.__rcvr_)); in tag_invoke()
139 static_cast<_Receiver&&>(__self.__rcvr_)); in tag_invoke()
|
| /openbmc/sdbusplus/include/sdbusplus/async/stdexec/__detail/ |
| H A D | __tuple.hpp | 61 constexpr _Ty&& __get(__box<_Ty, _Idx>&& __self) noexcept in __get() argument
63 return static_cast<_Ty&&>(__self.__value); in __get()
68 constexpr _Ty& __get(__box<_Ty, _Idx>& __self) noexcept in __get() argument
70 return __self.__value; in __get()
75 constexpr const _Ty& __get(const __box<_Ty, _Idx>& __self) noexcept in __get() argument
77 return __self.__value; in __get()
|
| H A D | __basic_sender.hpp | 265 __self.__op_->__complete(_Idx(), _Tag(), in tag_invoke()
271 friend auto tag_invoke(_Tag, const __t& __self) noexcept in tag_invoke()
274 return __self.__op_->__get_env(_Idx()); in tag_invoke()
419 friend void tag_invoke(_Tag2, __op_state& __self) noexcept in tag_invoke() argument
422 auto&& __rcvr = __self.__rcvr(); in tag_invoke()
427 __self.__inner_ops_); in tag_invoke()
575 return __sexpr_apply(__self, in tag_invoke()
582 friend auto tag_invoke(_Tag, _Self&& __self, _Env&& __env) noexcept // in tag_invoke() argument
602 return __impl<_Tag>::connect(static_cast<_Self&&>(__self), in tag_invoke()
623 friend decltype(auto) get(_Self&& __self) noexcept in get() argument
[all …]
|
| H A D | __env.hpp | 411 friend auto tag_invoke(_Key, const __with& __self) // in tag_invoke() argument
414 return __self.__value_; in tag_invoke()
432 friend auto tag_invoke(_Tag, const __fwd& __self) // in tag_invoke() argument
436 return _Tag()(__self.__env_); in tag_invoke()
452 friend auto tag_invoke(_Tag, const __ref& __self) // in tag_invoke() argument
456 return _Tag()(__self.__env_); in tag_invoke()
532 friend auto tag_invoke(_Tag, const __joined& __self) // in tag_invoke() argument
536 return _Tag()(__self.__env_); in tag_invoke()
553 friend auto tag_invoke(_Tag, const __from& __self) // in tag_invoke() argument
557 return __self.__fun_(_Tag()); in tag_invoke()
|