Searched refs:__state_ (Results 1 – 7 of 7) sorted by relevance
| /openbmc/sdbusplus/include/sdbusplus/async/stdexec/ |
| H A D | stop_token.hpp | 132 return (__state_.load(std::memory_order_acquire) & in stop_requested()
156 mutable std::atomic<uint8_t> __state_{0}; member in stdexec::inplace_stop_source
274 (__state_.load(std::memory_order_relaxed) & __locked_flag_) == 0); in ~inplace_stop_source()
311 __state_.store(__stop_requested_flag_, std::memory_order_release); in request_stop()
318 auto __old_state = __state_.load(std::memory_order_relaxed); in __lock_()
324 __old_state = __state_.load(std::memory_order_relaxed); in __lock_()
326 } while (!__state_.compare_exchange_weak( in __lock_()
335 (void)__state_.store(__old_state, std::memory_order_release); in __unlock_()
342 auto __old_state = __state_.load(std::memory_order_relaxed); in __try_lock_unless_stop_requested_()
359 __old_state = __state_.load(std::memory_order_relaxed); in __try_lock_unless_stop_requested_()
[all …]
|
| H A D | async_scope.hpp | 374 auto __state = std::move(__state_); in __complete_()
433 if (__state_ != nullptr) in ~__t()
435 auto __raw_state = __state_.get(); in ~__t()
457 __state_(std::move(__state)),
466 if (!!__state_) in start()
619 auto& __state = *__state_; in __dispatch_result_()
644 auto& __state = *__state_; in __save_completion()
690 return __state_->__env_; in get_env()
741 if (__state_ != nullptr) in ~__t()
743 auto __raw_state = __state_.get(); in ~__t()
[all …]
|
| /openbmc/sdbusplus/include/sdbusplus/async/stdexec/__detail/ |
| H A D | __sync_wait.hpp | 98 __state* __state_; member
111 __state_->__eptr_ = std::current_exception(); in set_value()
113 __state_->__loop_.finish(); in set_value()
123 __state_->__eptr_ = static_cast<_Error&&>(__err); in set_error()
127 __state_->__eptr_ = in set_error()
132 __state_->__eptr_ = in set_error()
135 __state_->__loop_.finish(); in set_error()
140 __state_->__loop_.finish(); in set_stopped()
145 return __env{&__state_->__loop_}; in get_env()
|
| H A D | __schedule_from.hpp | 153 __state_->__data_.visit(__schfr::__make_visitor_fn(__state_), in set_value()
154 __state_->__data_); in set_value()
160 stdexec::set_error(static_cast<_Receiver&&>(__state_->__receiver()), in set_error()
166 stdexec::set_stopped(static_cast<_Receiver&&>(__state_->__receiver())); in set_stopped()
171 return stdexec::get_env(__state_->__receiver()); in get_env()
174 __state<_Scheduler, _Sexpr, _Receiver>* __state_; member
|
| H A D | __basic_sender.hpp | 236 STDEXEC_IMMOVABLE_NO_UNIQUE_ADDRESS __state_t __state_; member
242 __state_(__sexpr_impl<__tag_t>::get_state(static_cast<_Sexpr&&>(__sndr), in __op_base()
290 using __derived_t = decltype(__op_base_t::__state_); in __receiver()
292 constexpr std::size_t __offset = offsetof(__op_base_t, __state_); in __receiver()
381 __sexpr_impl<__tag_t>::start(this->__state_, __rcvr, __ops...); in start()
401 __sexpr_impl<__tag_t>::complete(_Index(), this->__state_, __rcvr, in __complete()
413 return __sexpr_impl<__tag_t>::get_env(_Index(), this->__state_, __rcvr); in __get_env()
|
| H A D | __when_all.hpp | 221 switch (__state_.load(std::memory_order_relaxed)) in __complete()
248 std::atomic<__state_t> __state_{__started}; member
364 if (__error != __state.__state_.exchange(__error)) in __set_error()
404 if (__state.__state_.compare_exchange_strong(__expected, __stopped))
413 if (__state.__state_ == __started)
|
| H A D | __let.hpp | 86 return __op_state.__state_.__get_env(__op_state.__rcvr_);
559 using _State = decltype(__op_state.__state_); in __bind()
567 _State& __state = __op_state.__state_; in __bind()
|