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()
137 __env::__without(stdexec::get_env(__rcvr_), get_domain)); in get_env()
425 _Receiver& __rcvr = __op_state.__rcvr_; in __get_result_receiver()
582 using _Receiver = decltype(__op_state.__rcvr_); in __bind()
590 _Receiver& __rcvr = __op_state.__rcvr_; in __bind()
[all …]
|
| H A D | __connect_awaitable.hpp | 121 __t(auto&&, _Receiver&& __rcvr) noexcept : __rcvr_(__rcvr) {} in __t()
123 explicit __t(auto&, _Receiver& __rcvr) noexcept : __rcvr_(__rcvr) {} in __t()
128 stdexec::set_stopped(static_cast<_Receiver&&>(__rcvr_)); in unhandled_stopped()
161 return stdexec::get_env(__rcvr_); in get_env()
164 _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 | 240 _Receiver __rcvr_; member
245 return this->__rcvr_; in __rcvr()
251 return this->__rcvr_; in __rcvr()
282 return (static_cast<__op_base<_Sexpr, _Receiver>*>(__sbox)->__rcvr_); in __receiver()
299 _Receiver __rcvr_; member
307 __rcvr_(static_cast<_Receiver&&>(__rcvr)), in __op_base()
309 __rcvr_)) in __op_base()
315 return __rcvr_; in __rcvr()
321 return __rcvr_; in __rcvr()
341 this->__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 | 165 _Receiver __rcvr_;
203 stdexec::set_value(std::move(__op_->__rcvr_), in set_value()
215 stdexec::set_error(std::move(__op_->__rcvr_), in set_error()
226 stdexec::set_stopped(std::move(__op_->__rcvr_)); in set_stopped()
235 stdexec::get_env(__op_->__rcvr_), in get_env()
387 else if (get_stop_token(get_env(__rcvr_)).stop_requested()) in __complete_()
390 stdexec::set_stopped(static_cast<_Receiver&&>(__rcvr_)); in __complete_()
407 tag(static_cast<_Receiver&&>(__rcvr_), in __complete_()
419 stdexec::set_error(static_cast<_Receiver&&>(__rcvr_), in __complete_()
425 _Receiver __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 | 797 void* __rcvr_; member
806 return (*__vtable_)(_Tag{}, __rcvr_, static_cast<_As&&>(__as)...); in query()
834 (*__vfun->__complete_)(__env_.__rcvr_, static_cast<_As&&>(__as)...); in set_value()
843 (*__vfun->__complete_)(__env_.__rcvr_, static_cast<_Error&&>(__err)); in set_error()
850 (*__vfun->__complete_)(__env_.__rcvr_); in set_stopped()
892 void* __rcvr_; member
900 return (*__vtable_)(_Tag{}, __rcvr_, static_cast<_As&&>(__as)...); in query()
923 (*__vfun->__complete_)(__env_.__rcvr_, static_cast<_As&&>(__as)...); in set_value()
932 (*__vfun->__complete_)(__env_.__rcvr_, static_cast<_Error&&>(__err)); in set_error()
939 (*__vfun->__complete_)(__env_.__rcvr_); in set_stopped()
[all …]
|