Searched refs:__op_ (Results 1 – 3 of 3) sorted by relevance
| /openbmc/sdbusplus/include/sdbusplus/async/stdexec/ |
| H A D | async_scope.hpp | 85 __op_(stdexec::connect(static_cast<_Constrained&&>(__sndr),
100 stdexec::start(this->__op_); in start()
106 stdexec::start(static_cast<__t*>(__self)->__op_); in __notify_waiter()
110 connect_result_t<_Constrained, _Receiver> __op_; member
177 __nest_op_base<_ReceiverId>* __op_; member
202 auto __scope = __op_->__scope_; in set_value()
203 stdexec::set_value(std::move(__op_->__rcvr_), in set_value()
214 auto __scope = __op_->__scope_; in set_error()
215 stdexec::set_error(std::move(__op_->__rcvr_), in set_error()
225 auto __scope = __op_->__scope_; in set_stopped()
[all …]
|
| H A D | any_sender_of.hpp | 1010 __operation_base<_Receiver>* __op_; member
1018 return exec::set_next(__self.__op_->__rcvr_, in STDEXEC_MEMFN_DECL()
1026 __op_->__on_stop_.reset(); in set_value()
1027 stdexec::set_value(static_cast<_Receiver&&>(__op_->__rcvr_), in set_value()
1035 __op_->__on_stop_.reset(); in set_error()
1036 stdexec::set_error(static_cast<_Receiver&&>(__op_->__rcvr_), in set_error()
1043 __op_->__on_stop_.reset(); in set_stopped()
1044 stdexec::set_stopped(static_cast<_Receiver&&>(__op_->__rcvr_)); in set_stopped()
1050 prop{get_stop_token, __op_->__stop_source_.get_token()}, in get_env()
1051 stdexec::get_env(__op_->__rcvr_)); in get_env()
|
| /openbmc/sdbusplus/include/sdbusplus/async/stdexec/__detail/ |
| H A D | __basic_sender.hpp | 180 __parent_op_t* __op_; member
196 __op_->__complete(_Idx(), stdexec::set_value, in set_value()
204 __op_->__complete(_Idx(), stdexec::set_error, in set_error()
211 __op_->__complete(_Idx(), stdexec::set_stopped); in set_stopped()
219 return __op_->__get_env(_Idx()); in get_env()
377 __op_state<_Sexpr, _Receiver>* __op_; member
381 __op_state<_Sexpr, _Receiver>* __op_; member
389 __receiver_t<_Is>{__op_})...}; in operator ()()
398 return __impl{__op_}(__indices_for<_Child...>(), in operator ()()
|