| /openbmc/sdbusplus/include/sdbusplus/async/stdexec/__detail/ |
| H A D | __tuple.hpp | 63 static auto apply(_Fn&& __fn, _Self&& __self, _Us&&... __us) // in apply()
66 static_cast<_Self&&>(__self).__box<_Ts, _Is>::__value...))) in apply()
69 static_cast<_Self&&>(__self).__box<_Ts, _Is>::__value...)) in apply()
79 static auto for_each(_Fn&& __fn, _Self&& __self, _Us&&... __us) // in for_each()
85 static_cast<_Self&&>(__self).__box<_Ts, _Is>::__value), in for_each()
119 constexpr _Ty&& get(__box<_Ty, _Idx>&& __self) noexcept in get() argument
121 return static_cast<_Ty&&>(__self.__value); in get()
126 constexpr _Ty& get(__box<_Ty, _Idx>& __self) noexcept in get() argument
128 return __self.__value; in get()
133 constexpr const _Ty& get(const __box<_Ty, _Idx>& __self) noexcept in get() argument
[all …]
|
| H A D | __shared.hpp | 162 __self->__on_stop_.reset(); in __notify()
277 if (auto* __self = __ptr.__release_()) in __detach() local
279 auto __old = __self->__dec_ref(); in __detach()
286 static_cast<__shared_state*>(__self) in __detach()
296 __self->__dec_ref(); in __detach()
502 __local_state<_Sender, _Receiver>& __self,
517 __self.__on_stop_.emplace(__stok, __self);
527 __self.__sh_state_->__try_start();
528 if (__self.__sh_state_->__try_add_waiter(&__self, __stok))
537 __self.__on_stop_.reset();
[all …]
|
| H A D | __receiver_adaptor.hpp | 90 static auto __call_##_TAG(_Self&& __self, _Ts&&... __ts) noexcept \
91 -> decltype((static_cast<_Self&&>(__self)) \
94 static_assert(noexcept((static_cast<_Self&&>(__self)) \
96 return static_cast<_Self&&>(__self)._TAG(static_cast<_Ts&&>(__ts)...); \
134 static auto __get_base(_Self&& __self) noexcept -> __base_t<_Self> in __get_base()
138 return __c_upcast<receiver_adaptor>(static_cast<_Self&&>(__self)) in __get_base()
143 return static_cast<_Self&&>(__self).base(); in __get_base()
|
| H A D | __variant.hpp | 177 static void visit(_Fn&& __fn, _Self&& __self, _As&&... __as) // in visit() argument
181 STDEXEC_ASSERT(__self.__index_ != __variant_npos); in visit()
182 auto __index = __self.__index_; // make it local so we don't access it in visit()
186 static_cast<_Self&&>(__self).template get<_Is>()) in visit()
|
| H A D | __write_env.hpp | 60 static auto transform_env(const _Self& __self, _Env&& __env) noexcept in transform_env()
62 return __sexpr_apply(__self, in transform_env()
|
| H A D | __basic_sender.hpp | 538 static auto connect(_Self&& __self, _Receiver&& __rcvr) // in connect()
543 return __impl<_Self>::connect(static_cast<_Self&&>(__self), in connect()
561 friend auto get(_Self&& __self) noexcept -> decltype(auto) in get() argument
570 return __self.__impl_(__copy_cvref_fn<_Self>(), in get()
|
| H A D | __when_all.hpp | 329 []<class _Self, class _Receiver>(_Self&& __self, _Receiver& __rcvr)
332 static_cast<_Self&&>(__self),
|
| /openbmc/sdbusplus/include/sdbusplus/async/stdexec/ |
| H A D | any_sender_of.hpp | 429 (this __mtype<_Tp>, __t& __self) noexcept in STDEXEC_MEMFN_DECL()
431 if (!__self.__object_pointer_) in STDEXEC_MEMFN_DECL()
437 _Alloc __alloc{__self.__allocator_}; in STDEXEC_MEMFN_DECL()
625 (this __mtype<_Tp>, __t& __self) noexcept in STDEXEC_MEMFN_DECL()
627 if (!__self.__object_pointer_) in STDEXEC_MEMFN_DECL()
633 _Alloc __alloc{__self.__allocator_}; in STDEXEC_MEMFN_DECL()
660 _Alloc __alloc{__self.__allocator_}; in STDEXEC_MEMFN_DECL()
667 __self.__vtable_ = std::exchange( in STDEXEC_MEMFN_DECL()
691 __self.__vtable_ = __other.__vtable_; in STDEXEC_MEMFN_DECL()
1358 if (__self.__storage_.__get_vtable() != in operator ==()
[all …]
|
| H A D | task.hpp | 183 __default_task_context_impl<_Affinity>& __self, in __default_awaiter_context()
201 __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()
232 __self.__stop_token_ = get_stop_token(get_env(__parent)); in __default_awaiter_context()
255 __default_task_context_impl<_Affinity>& __self, in __default_awaiter_context()
262 __default_task_context_impl<_Affinity>& __self, in __default_awaiter_context()
274 __self.__stop_token_ = get_stop_token(get_env(__parent)); in __default_awaiter_context()
281 __self.__stop_token_ = __stop_source_.get_token(); in __default_awaiter_context()
536 (this basic_task&& __self, in STDEXEC_MEMFN_DECL()
[all …]
|
| H A D | async_scope.hpp | 103 static void __notify_waiter(__task* __self) noexcept in __notify_waiter()
105 stdexec::start(static_cast<__t*>(__self)->__op_); in __notify_waiter()
130 [[nodiscard]] static auto connect(_Self&& __self, _Receiver __rcvr) // in connect()
134 __self.__scope_, static_cast<_Self&&>(__self).__c_, in connect()
300 [[nodiscard]] static auto connect(_Self&& __self, _Receiver __rcvr) in connect()
304 __self.__scope_, static_cast<_Self&&>(__self).__c_, in connect()
453 [](__subscription* __self) noexcept -> void { in __t()
454 static_cast<__t*>(__self)->__complete_(); in __t()
759 static auto connect(_Self&& __self, in connect() argument
764 static_cast<_Self&&>(__self).__state_}; in connect()
|
| H A D | env.hpp | 145 static auto connect(_Self&& __self, _Receiver __rcvr) // in connect()
150 static_cast<_Self&&>(__self).__default_, in connect()
|