Searched refs:__rcvr_ (Results 1 – 9 of 9) sorted by relevance
| /openbmc/sdbusplus/include/sdbusplus/async/stdexec/__detail/ |
| H A D | __submit.hpp | 61 auto&& __env = stdexec::get_env(__op->__rcvr_); in __delete_op()
80 stdexec::set_value(static_cast<_Receiver&&>(__opref_().__rcvr_), in set_value()
88 stdexec::set_error(static_cast<_Receiver&&>(__opref_().__rcvr_), in set_error()
95 stdexec::set_stopped(__opref_().__rcvr_); in set_stopped()
102 return stdexec::get_env(__opref_().__rcvr_); in get_env()
114 _Receiver __rcvr_;
118 __rcvr_(static_cast<_Receiver&&>(__rcvr)), in __operation()
|
| H A D | __let.hpp | 81 return (__op_state.__rcvr_);
86 return __op_state.__state_.__get_env(__op_state.__rcvr_);
111 _Receiver __rcvr_; member
117 stdexec::set_value(static_cast<_Receiver&&>(__rcvr_), in set_value()
124 stdexec::set_error(static_cast<_Receiver&&>(__rcvr_), in set_error()
130 stdexec::set_stopped(static_cast<_Receiver&&>(__rcvr_)); in set_stopped()
419 _Receiver& __rcvr = __op_state.__rcvr_; in __get_result_receiver()
560 using _Receiver = decltype(__op_state.__rcvr_); in __bind()
568 _Receiver& __rcvr = __op_state.__rcvr_; in __bind()
585 using _Receiver = decltype(__op_state.__rcvr_); in __bind()
[all …]
|
| H A D | __connect_awaitable.hpp | 120 explicit __t(auto&, _Receiver& __rcvr) noexcept : __rcvr_(__rcvr) {} in __t()
124 stdexec::set_stopped(static_cast<_Receiver&&>(__rcvr_)); in unhandled_stopped()
157 return stdexec::get_env(__rcvr_); in get_env()
160 _Receiver& __rcvr_; member
|
| H A D | __run_loop.hpp | 68 _Receiver __rcvr_;
72 auto& __rcvr = static_cast<__t*>(__p)->__rcvr_; in __execute_impl()
96 __rcvr_{static_cast<_Receiver&&>(__rcvr)}
222 stdexec::set_error(static_cast<_Receiver&&>(__rcvr_), in start()
|
| H A D | __basic_sender.hpp | 235 STDEXEC_IMMOVABLE_NO_UNIQUE_ADDRESS _Receiver __rcvr_; member
241 __rcvr_(static_cast<_Receiver&&>(__rcvr)), in __op_base()
243 __rcvr_)) in __op_base()
248 return __rcvr_; in __rcvr()
253 return __rcvr_; in __rcvr()
|
| /openbmc/sdbusplus/include/sdbusplus/async/stdexec/ |
| H A D | env.hpp | 94 _Receiver __rcvr_; member
102 const auto& __env = get_env(__rcvr_); in start()
103 stdexec::set_value(std::move(__rcvr_), _Tag{}(__env)); in start()
107 stdexec::set_value(std::move(__rcvr_), in start()
113 stdexec::set_error(std::move(__rcvr_), in start()
|
| H A D | async_scope.hpp | 164 _Receiver __rcvr_;
202 stdexec::set_value(std::move(__op_->__rcvr_), in set_value()
214 stdexec::set_error(std::move(__op_->__rcvr_), in set_error()
225 stdexec::set_stopped(std::move(__op_->__rcvr_)); in set_stopped()
234 stdexec::get_env(__op_->__rcvr_), in get_env()
385 else if (get_stop_token(get_env(__rcvr_)).stop_requested()) in __complete_()
417 stdexec::set_error(static_cast<_Receiver&&>(__rcvr_), in __complete_()
423 _Receiver __rcvr_;
456 __rcvr_(static_cast<_Receiver2&&>(__rcvr)),
458 __forward_consumer_(get_stop_token(get_env(__rcvr_)),
[all …]
|
| H A D | sequence_senders.hpp | 101 _Receiver __rcvr_;
105 return stdexec::get_env(__rcvr_); in get_env()
111 return stdexec::set_value(static_cast<_Receiver&&>(__rcvr_)); in set_value()
121 stdexec::set_value(static_cast<_Receiver&&>(__rcvr_)); in set_stopped()
126 stdexec::get_stop_token(stdexec::get_env(__rcvr_)); in set_stopped()
129 stdexec::set_stopped(static_cast<_Receiver&&>(__rcvr_)); in set_stopped()
133 stdexec::set_value(static_cast<_Receiver&&>(__rcvr_)); in set_stopped()
|
| H A D | any_sender_of.hpp | 798 void* __rcvr_; member
851 (*__vfun->__complete_)(__env_.__rcvr_); in set_stopped()
893 void* __rcvr_; member
940 (*__vfun->__complete_)(__env_.__rcvr_); in set_stopped()
992 _Receiver __rcvr_;
1019 return exec::set_next(__self.__op_->__rcvr_, in STDEXEC_MEMFN_DECL()
1028 stdexec::set_value(static_cast<_Receiver&&>(__op_->__rcvr_), in set_value()
1037 stdexec::set_error(static_cast<_Receiver&&>(__op_->__rcvr_), in set_error()
1045 stdexec::set_stopped(static_cast<_Receiver&&>(__op_->__rcvr_)); in set_stopped()
1052 stdexec::get_env(__op_->__rcvr_)); in get_env()
[all …]
|