Home
last modified time | relevance | path

Searched refs:__state_ (Results 1 – 13 of 13) sorted by relevance

/freebsd-14.2/contrib/llvm-project/libcxx/src/
H A Dfuture.cpp83 __state_ |= ready; in set_exception()
97 __state_ |= ready; in __make_ready()
130 if (__state_) in ~future()
144 if (__state_) { in ~promise()
146 if (!__state_->__has_value() && __state_->use_count() > 1) in ~promise()
154 if (__state_ == nullptr) in get_future()
162 __state_->set_value(); in set_value()
184 if (__state_) in ~shared_future()
189 if (__rhs.__state_) in operator =()
191 if (__state_) in operator =()
[all …]
H A Dshared_mutex.cpp26 __state_ |= __write_entered_; in lock()
33 if (__state_ == 0) { in try_lock()
34 __state_ = __write_entered_; in try_lock()
42 __state_ = 0; in unlock()
50 while ((__state_ & __write_entered_) || (__state_ & __n_readers_) == __n_readers_) in lock_shared()
53 __state_ &= ~__n_readers_; in lock_shared()
54 __state_ |= num_readers; in lock_shared()
62 __state_ &= ~__n_readers_; in try_lock_shared()
63 __state_ |= num_readers; in try_lock_shared()
72 __state_ &= ~__n_readers_; in unlock_shared()
[all …]
/freebsd-14.2/contrib/llvm-project/libcxx/include/__stop_token/
H A Dstop_source.h36 …_LIBCPP_HIDE_FROM_ABI stop_source() : __state_(new __stop_state()) { __state_->__increment_stop_so… in stop_source()
40 …IBCPP_HIDE_FROM_ABI stop_source(const stop_source& __other) noexcept : __state_(__other.__state_) { in stop_source()
41 if (__state_) { in stop_source()
50 if (__other.__state_) {
53 if (__state_) {
56 __state_ = __other.__state_;
63 if (__state_) { in ~stop_source()
68 …_LIBCPP_HIDE_FROM_ABI void swap(stop_source& __other) noexcept { __state_.swap(__other.__state_); } in swap()
75 return __state_ != nullptr && __state_->__stop_requested(); in stop_requested()
78 …_LIBCPP_HIDE_FROM_ABI bool request_stop() noexcept { return __state_ && __state_->__request_stop()… in request_stop()
[all …]
H A Dstop_token.h36 _LIBCPP_HIDE_FROM_ABI void swap(stop_token& __other) noexcept { __state_.swap(__other.__state_); } in swap()
39 return __state_ != nullptr && __state_->__stop_requested(); in stop_requested()
43 return __state_ != nullptr && __state_->__stop_possible_for_stop_token(); in stop_possible()
51 __intrusive_shared_ptr<__stop_state> __state_;
57 …ABI explicit stop_token(const __intrusive_shared_ptr<__stop_state>& __state) : __state_(__state) {} in stop_token()
H A Datomic_unique_lock.h34 std::atomic<_State>& __state_; variable
39 : __state_(__state), __is_locked_(true) { in __atomic_unique_lock()
45 : __state_(__state), __is_locked_(false) { in __atomic_unique_lock()
55 : __state_(__state), __is_locked_(false) { in __atomic_unique_lock()
83 __state_.fetch_and(static_cast<_State>(~_LockedBit), std::memory_order_release); in __unlock()
84 __state_.notify_all(); in __unlock()
98 _State __current_state = __state_.load(std::memory_order_relaxed); in __lock_impl()
106 __state_.wait(__current_state, std::memory_order_relaxed); in __lock_impl()
110 __current_state = __state_.load(std::memory_order_relaxed); in __lock_impl()
117 } while (!__state_.compare_exchange_weak( in __lock_impl()
H A Dstop_state.h54 atomic<uint32_t> __state_ = 0; variable
73 …__state_.load(std::memory_order_relaxed) <= static_cast<__state_t>(~(1 << __stop_source_counter_sh… in __increment_stop_source_counter()
75 __state_.fetch_add(1 << __stop_source_counter_shift, std::memory_order_relaxed); in __increment_stop_source_counter()
82 …__state_.load(std::memory_order_relaxed) >= static_cast<__state_t>(1 << __stop_source_counter_shif… in __decrement_stop_source_counter()
84 __state_.fetch_sub(1 << __stop_source_counter_shift, std::memory_order_relaxed); in __decrement_stop_source_counter()
92 return (__state_.load(std::memory_order_acquire) & __stop_requested_bit) != 0; in __stop_requested()
99 __state_t __curent_state = __state_.load(std::memory_order_acquire); in __stop_possible_for_stop_token()
152 __callback_list_lock __cb_list_lock(__state_, __give_up_trying_to_lock_condition); in __add_callback()
168 __callback_list_lock __cb_list_lock(__state_); in __remove_callback()
215 …return __callback_list_lock(__state_, __lock_fail_condition, __after_lock_state, __locked_ordering… in __try_lock_for_request_stop()
H A Dstop_callback.h52 : stop_callback(__private_tag{}, __st.__state_, std::forward<_Cb>(__cb)) {} in stop_callback()
58 : stop_callback(__private_tag{}, std::move(__st.__state_), std::forward<_Cb>(__cb)) {} in stop_callback()
61 if (__state_) { in ~stop_callback()
62 __state_->__remove_callback(this); in ~stop_callback()
73 __intrusive_shared_ptr<__stop_state> __state_; variable
87 __state_() {
90 __state_ = std::forward<_StatePtr>(__state);
/freebsd-14.2/contrib/llvm-project/libcxx/include/
H A Dfuture969 if (__state_)
1036 if (__state_)
1163 if (__state_) {
1164 if (!__state_->__has_value() && __state_->use_count() > 1)
1279 if (!__state_->__has_value() && __state_->use_count() > 1)
1921 if (__state_)
1929 if (__state_)
1931 __state_ = __rhs.__state_;
1977 if (__state_)
1985 if (__state_)
[all …]
H A Dshared_mutex161 unsigned __state_;
268 if (__base_.__state_ & __base_.__write_entered_) {
271 if ((__base_.__state_ & __base_.__write_entered_) == 0)
277 __base_.__state_ |= __base_.__write_entered_;
278 if (__base_.__state_ & __base_.__n_readers_) {
281 if ((__base_.__state_ & __base_.__n_readers_) == 0)
284 __base_.__state_ &= ~__base_.__write_entered_;
296 if ((__base_.__state_ & __base_.__write_entered_) ||
300 if ((__base_.__state_ & __base_.__write_entered_) == 0 &&
308 __base_.__state_ &= ~__base_.__n_readers_;
[all …]
/freebsd-14.2/contrib/llvm-project/libcxx/include/__mutex/
H A Donce_flag.h51 _LIBCPP_HIDE_FROM_ABI _LIBCPP_CONSTEXPR once_flag() _NOEXCEPT : __state_(_Unset) {} in once_flag()
66 _State_type __state_;
127 if (__libcpp_acquire_load(&__flag.__state_) != once_flag::_Complete) { in call_once()
131 std::__call_once(__flag.__state_, &__p, &__call_once_proxy<_Gp>); in call_once()
139 if (__libcpp_acquire_load(&__flag.__state_) != once_flag::_Complete) { in call_once()
141 std::__call_once(__flag.__state_, &__p, &__call_once_proxy<_Callable>); in call_once()
147 if (__libcpp_acquire_load(&__flag.__state_) != once_flag::_Complete) { in call_once()
149 std::__call_once(__flag.__state_, &__p, &__call_once_proxy<const _Callable>); in call_once()
/freebsd-14.2/contrib/llvm-project/libcxx/include/__filesystem/
H A Dpath_iterator.h52 …_LIBCPP_HIDE_FROM_ABI iterator() : __stashed_elem_(), __path_ptr_(nullptr), __entry_(), __state_(_… in iterator()
64 _LIBCPP_ASSERT_NON_NULL(__state_ != _Singular, "attempting to increment a singular iterator");
65 _LIBCPP_ASSERT_UNCATEGORIZED(__state_ != _AtEnd, "attempting to increment the end iterator");
76 _LIBCPP_ASSERT_NON_NULL(__state_ != _Singular, "attempting to decrement a singular iterator");
99 _ParserState __state_; variable
/freebsd-14.2/contrib/llvm-project/libcxx/include/__algorithm/
H A Dshuffle.h34 __state_ = __seed(); in __libcpp_debug_randomizer()
35 __inc_ = __state_ + 0xda3e39cb94b95bdbULL; in __libcpp_debug_randomizer()
44 uint_fast64_t __oldstate = __state_; in operator()
45 __state_ = __oldstate * 6364136223846793005ULL + __inc_; in operator()
53 uint_fast64_t __state_;
/freebsd-14.2/contrib/llvm-project/libcxx/src/filesystem/
H A Dpath.cpp383 it.__state_ = static_cast<path::iterator::_ParserState>(PP.State); in begin()
391 it.__state_ = path::iterator::_AtEnd; in end()
397 PathParser PP(__path_ptr_->native(), __entry_, __state_); in __increment()
399 __state_ = static_cast<_ParserState>(PP.State); in __increment()
406 PathParser PP(__path_ptr_->native(), __entry_, __state_); in __decrement()
408 __state_ = static_cast<_ParserState>(PP.State); in __decrement()