Searched refs:__op_ (Results 1 – 3 of 3) sorted by relevance
| /openbmc/sdbusplus/include/sdbusplus/async/stdexec/ |
| H A D | async_scope.hpp | 99 stdexec::start(this->__op_); in start()
176 __nest_op_base<_ReceiverId>* __op_; member
201 auto __scope = __op_->__scope_; in set_value()
270 stdexec::start(__op_); in start()
708 __op_( in __future_state()
831 __spawn_op_base<_EnvId>* __op_; member
835 __op_->__delete_(__op_); in set_value()
846 __op_->__delete_(__op_); in set_stopped()
851 return __op_->__env_; in get_env()
882 stdexec::start(__op_); in start()
[all …]
|
| H A D | any_sender_of.hpp | 1011 __operation_base<_Receiver>* __op_; member
1019 return exec::set_next(__self.__op_->__rcvr_, in STDEXEC_MEMFN_DECL()
1027 __op_->__on_stop_.reset(); in set_value()
1028 stdexec::set_value(static_cast<_Receiver&&>(__op_->__rcvr_), in set_value()
1036 __op_->__on_stop_.reset(); in set_error()
1037 stdexec::set_error(static_cast<_Receiver&&>(__op_->__rcvr_), in set_error()
1044 __op_->__on_stop_.reset(); in set_stopped()
1045 stdexec::set_stopped(static_cast<_Receiver&&>(__op_->__rcvr_)); in set_stopped()
1051 prop{get_stop_token, __op_->__stop_source_.get_token()}, in get_env()
1052 stdexec::get_env(__op_->__rcvr_)); in get_env()
|
| /openbmc/sdbusplus/include/sdbusplus/async/stdexec/__detail/ |
| H A D | __basic_sender.hpp | 179 __parent_op_t* __op_; member
195 __op_->__complete(_Idx(), stdexec::set_value, in set_value()
203 __op_->__complete(_Idx(), stdexec::set_error, in set_error()
210 __op_->__complete(_Idx(), stdexec::set_stopped); in set_stopped()
218 return __op_->__get_env(_Idx()); in get_env()
311 __op_state<_Sexpr, _Receiver>* __op_; member
315 __op_state<_Sexpr, _Receiver>* __op_; member
323 __receiver_t<_Is>{__op_})...}; in operator ()()
332 return __impl{__op_}(__indices_for<_Child...>(), in operator ()()
|