| /openbmc/sdbusplus/include/sdbusplus/async/stdexec/__detail/ |
| H A D | __shared.hpp | 155 auto* const __self = static_cast<__local_state*>(__base); in __notify() local
159 using __variant_t = decltype(__self->__sh_state_->__results_); in __notify()
163 __self->__on_stop_.reset(); in __notify()
165 auto __visitor = __make_notify_visitor(__self->__receiver()); in __notify()
167 __self->__sh_state_->__results_)); in __notify()
279 if (auto* __self = __ptr.__release_()) in __detach() local
281 auto __old = __self->__dec_ref(); in __detach()
288 static_cast<__shared_state*>(__self) in __detach()
298 __self->__dec_ref(); in __detach()
504 __local_state<_Sender, _Receiver>& __self,
[all …]
|
| H A D | __tuple.hpp | 75 static auto apply(_Fn&& __fn, _Self&& __self, _Us&&... __us) // in apply()
78 static_cast<_Self&&>(__self).__box<_Ts, _Is>::__value...))) in apply()
81 static_cast<_Self&&>(__self).__box<_Ts, _Is>::__value...)) in apply()
85 static_cast<_Self&&>(__self).__box<_Ts, _Is>::__value...); in apply()
91 static auto for_each(_Fn&& __fn, _Self&& __self, _Us&&... __us) // in for_each()
97 static_cast<_Self&&>(__self).__box<_Ts, _Is>::__value), in for_each()
131 constexpr _Ty&& get(__box<_Ty, _Idx>&& __self) noexcept in get() argument
133 return static_cast<_Ty&&>(__self.__value); in get()
138 constexpr _Ty& get(__box<_Ty, _Idx>& __self) noexcept in get() argument
140 return __self.__value; in get()
[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 | 188 static void visit(_Fn&& __fn, _Self&& __self, _As&&... __as) // in visit() argument
192 STDEXEC_ASSERT(__self.__index_ != __variant_npos); in visit()
193 auto __index = __self.__index_; // make it local so we don't access it in visit()
197 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 | 611 static auto connect(_Self&& __self, _Receiver&& __rcvr) // in connect()
616 return __impl<_Self>::connect(static_cast<_Self&&>(__self), in connect()
634 friend auto get(_Self&& __self) noexcept -> decltype(auto) in get() argument
643 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 | 228 void operator()(__mtype<_Tp>, _Storage& __self, const _Storage& __from) // in operator ()()
232 stdexec::tag_invoke(__copy_construct_t{}, __mtype<_Tp>{}, __self, in operator ()()
244 void operator()(__mtype<_Tp>, _Storage& __self, in operator ()()
249 stdexec::tag_invoke(__move_construct_t{}, __mtype<_Tp>{}, __self, in operator ()()
429 __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()
439 std::exchange(__self.__object_pointer_, nullptr)); in STDEXEC_MEMFN_DECL()
623 STDEXEC_MEMFN_DECL(void __delete)(this __mtype<_Tp>, __t& __self) noexcept in STDEXEC_MEMFN_DECL()
625 if (!__self.__object_pointer_) in STDEXEC_MEMFN_DECL()
[all …]
|
| H A D | task.hpp | 182 __default_task_context_impl<_Affinity>& __self, in __default_awaiter_context()
200 __default_task_context_impl<_Affinity>& __self, in __default_awaiter_context()
212 __self.__stop_token_ = __stop_source_.get_token();
228 __default_task_context_impl<_Affinity>& __self, in __default_awaiter_context()
231 __self.__stop_token_ = get_stop_token(get_env(__parent)); in __default_awaiter_context()
254 __default_task_context_impl<_Affinity>& __self, in __default_awaiter_context()
261 __default_task_context_impl<_Affinity>& __self, in __default_awaiter_context()
273 __self.__stop_token_ = get_stop_token(get_env(__parent)); in __default_awaiter_context()
280 __self.__stop_token_ = __stop_source_.get_token(); in __default_awaiter_context()
537 STDEXEC_MEMFN_DECL(auto as_awaitable)(this basic_task&& __self, in STDEXEC_MEMFN_DECL()
[all …]
|
| H A D | async_scope.hpp | 104 static void __notify_waiter(__task* __self) noexcept in __notify_waiter()
106 stdexec::start(static_cast<__t*>(__self)->__op_); in __notify_waiter()
131 [[nodiscard]] static auto connect(_Self&& __self, _Receiver __rcvr) // in connect()
135 __self.__scope_, static_cast<_Self&&>(__self).__c_, in connect()
301 [[nodiscard]] static auto connect(_Self&& __self, _Receiver __rcvr) in connect()
305 __self.__scope_, static_cast<_Self&&>(__self).__c_, in connect()
455 [](__subscription* __self) noexcept -> void { in __t()
456 static_cast<__t*>(__self)->__complete_(); in __t()
758 static auto connect(_Self&& __self, _Receiver __rcvr) in connect() argument
763 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()
|