Searched refs:__op_state (Results 1 – 4 of 4) sorted by relevance
| /openbmc/sdbusplus/include/sdbusplus/async/stdexec/__detail/ |
| H A D | __receiver_ref.hpp | 62 _Env (*__do_get_env)(const void* __op_state) noexcept;
67 auto* __op_state = static_cast<const _OpState*>(__ptr); in __s_get_env() local
68 return _GetEnv()(*__op_state); in __s_get_env()
81 auto __get_env(const void* __op_state) const noexcept -> _Env in __get_env()
83 return __do_get_env(__op_state); in __get_env()
101 __receiver_ref(_OpState& __op_state, _GetEnv, _GetReceiver = {}) noexcept : in __receiver_ref() argument
104 __op_state_{&__op_state}
|
| H A D | __let.hpp | 80 [](auto& __op_state) noexcept -> decltype(auto) {
81 return (__op_state.__rcvr_);
85 [](auto& __op_state) noexcept -> decltype(auto) {
86 return __op_state.__state_.__get_env(__op_state.__rcvr_);
419 _Receiver& __rcvr = __op_state.__rcvr_; in __get_result_receiver()
559 using _State = decltype(__op_state.__state_); in __bind()
560 using _Receiver = decltype(__op_state.__rcvr_); in __bind()
567 _State& __state = __op_state.__state_; in __bind()
568 _Receiver& __rcvr = __op_state.__rcvr_; in __bind()
594 __ignore, _OpState& __op_state, _Tag,
[all …]
|
| H A D | __basic_sender.hpp | 78 struct __op_state;
135 -> __op_state<_Sender, _Receiver>
174 using __parent_op_t = __op_state<_Sexpr, _Receiver>;
311 __op_state<_Sexpr, _Receiver>* __op_;
315 __op_state<_Sexpr, _Receiver>* __op_;
344 struct __op_state : __op_base<_Sexpr, _Receiver> struct
350 using __state_t = typename __op_state::__state_t; argument
363 __op_state(_Sexpr&& __sexpr, _Receiver __rcvr) // in __op_state() argument
368 __op_state::__op_base{static_cast<_Sexpr&&>(__sexpr), in __op_state()
377 using __tag_t = typename __op_state::__tag_t; in start()
[all …]
|
| H A D | __sync_wait.hpp | 316 auto __op_state = connect(static_cast<_Sender&&>(__sndr), in apply_sender() local
318 stdexec::start(__op_state); in apply_sender()
|