Searched refs:__state_ (Results 1 – 4 of 4) sorted by relevance
| /openbmc/sdbusplus/include/sdbusplus/async/stdexec/ |
| H A D | stop_token.hpp | 147 return (__state_.load(std::memory_order_acquire) & in stop_requested()
171 mutable std::atomic<uint8_t> __state_{0}; member in stdexec::in_place_stop_source
292 (__state_.load(std::memory_order_relaxed) & __locked_flag_) == 0); in ~in_place_stop_source()
329 __state_.store(__stop_requested_flag_, std::memory_order_release); in request_stop()
336 auto __old_state = __state_.load(std::memory_order_relaxed); in __lock_()
342 __old_state = __state_.load(std::memory_order_relaxed); in __lock_()
344 } while (!__state_.compare_exchange_weak( in __lock_()
353 (void)__state_.store(__old_state, std::memory_order_release); in __unlock_()
360 auto __old_state = __state_.load(std::memory_order_relaxed); in __try_lock_unless_stop_requested_()
377 __old_state = __state_.load(std::memory_order_relaxed); in __try_lock_unless_stop_requested_()
[all …]
|
| H A D | async_scope.hpp | 373 auto __state = std::move(__state_); in __complete_()
425 if (!!__state_) in __start_()
457 if (__state_ != nullptr) in ~__t()
459 auto __raw_state = __state_.get(); in ~__t()
481 __state_(std::move(__state)),
619 auto& __state = *__state_; in __dispatch_result_()
644 auto& __state = *__self.__state_; in tag_invoke()
665 return __self.__state_->__env_; in tag_invoke()
707 if (__state_ != nullptr) in ~__t()
709 auto __raw_state = __state_.get(); in ~__t()
[all …]
|
| H A D | execution.hpp | 4893 __state_{__state} in __receiver2()
4898 return std::move(__state_->__receiver()); in base()
4903 return __state_->__receiver(); in base()
4927 __state_->__data_); in set_value()
4930 __state<_Scheduler, _Sexpr, _Receiver>* __state_; member
5663 std::atomic<__state_t> __state_{__started}; member
5829 if (__state.__state_ == __started)
6458 __state<_Values...>* __state_; member
6465 __state_->__data_.template emplace<2>( in __set_error()
6468 __state_->__data_.template emplace<2>( in __set_error()
[all …]
|
| /openbmc/sdbusplus/include/sdbusplus/async/stdexec/__detail/ |
| H A D | __basic_sender.hpp | 292 STDEXEC_IMMOVABLE_NO_UNIQUE_ADDRESS __state_t __state_; member
296 __state_(__sexpr_impl<__tag_t>::get_state(static_cast<_Sexpr&&>(__sndr), in __op_base()
339 using __derived_t = decltype(__op_base_t::__state_); in __receiver()
341 constexpr std::size_t __offset = offsetof(__op_base_t, __state_); in __receiver()
425 __sexpr_impl<__tag_t>::start(__self.__state_, __rcvr, __ops...); in tag_invoke()
436 __sexpr_impl<__tag_t>::complete(_Index(), this->__state_, __rcvr, in __complete()
447 return __sexpr_impl<__tag_t>::get_env(_Index(), this->__state_, __rcvr); in __get_env()
|