| /third_party/boost/boost/thread/concurrent_queues/ |
| D | sync_bounded_queue.hpp | 156 inline void notify_not_empty_if_needed(unique_lock<mutex>& lk) in notify_not_empty_if_needed()
165 inline void notify_not_full_if_needed(unique_lock<mutex>& lk) in notify_not_full_if_needed()
176 inline void pull(value_type& elem, unique_lock<mutex>& lk) in pull()
182 inline value_type pull(unique_lock<mutex>& lk) in pull()
189 inline boost::shared_ptr<value_type> ptr_pull(unique_lock<mutex>& lk) in ptr_pull()
197 inline void pull_front(value_type& elem, unique_lock<mutex>& lk) in pull_front()
203 inline value_type pull_front(unique_lock<mutex>& lk) in pull_front()
211 inline void set_in(size_type in, unique_lock<mutex>& lk) in set_in()
217 inline void push_at(const value_type& elem, size_type in_p_1, unique_lock<mutex>& lk) in push_at()
223 …inline void push_at(BOOST_THREAD_RV_REF(value_type) elem, size_type in_p_1, unique_lock<mutex>& lk) in push_at()
[all …]
|
| D | sync_deque.hpp | 92 inline void push_back(const value_type& elem, unique_lock<mutex>& lk) in push_back()
98 inline void push_back(BOOST_THREAD_RV_REF(value_type) elem, unique_lock<mutex>& lk) in push_back()
139 …op_status sync_deque<ValueType, Container>::try_pull_front(ValueType& elem, unique_lock<mutex>& lk) in try_pull_front()
150 …p_status sync_deque<ValueType, Container>::wait_pull_front(ValueType& elem, unique_lock<mutex>& lk) in wait_pull_front()
161 unique_lock<mutex> lk(super::mtx_); in try_pull_front() local
168 unique_lock<mutex> lk(super::mtx_); in wait_pull_front() local
175 unique_lock<mutex> lk(super::mtx_, try_to_lock); in nonblocking_pull_front() local
186 unique_lock<mutex> lk(super::mtx_); in pull_front() local
196 unique_lock<mutex> lk(super::mtx_); in pull_front() local
203 …atus sync_deque<ValueType, Container>::try_push_back(const ValueType& elem, unique_lock<mutex>& lk) in try_push_back()
[all …]
|
| D | sync_queue.hpp | 92 inline void push(const value_type& elem, unique_lock<mutex>& lk) in push()
98 inline void push(BOOST_THREAD_RV_REF(value_type) elem, unique_lock<mutex>& lk) in push()
139 …queue_op_status sync_queue<ValueType, Container>::try_pull(ValueType& elem, unique_lock<mutex>& lk) in try_pull()
150 …ueue_op_status sync_queue<ValueType, Container>::wait_pull(ValueType& elem, unique_lock<mutex>& lk) in wait_pull()
161 unique_lock<mutex> lk(super::mtx_); in try_pull() local
168 unique_lock<mutex> lk(super::mtx_); in wait_pull() local
175 unique_lock<mutex> lk(super::mtx_, try_to_lock); in nonblocking_pull() local
186 unique_lock<mutex> lk(super::mtx_); in pull() local
196 unique_lock<mutex> lk(super::mtx_); in pull() local
203 …op_status sync_queue<ValueType, Container>::try_push(const ValueType& elem, unique_lock<mutex>& lk) in try_push()
[all …]
|
| D | sync_priority_queue.hpp | 173 void sync_priority_queue<T,Container,Cmp>::push(unique_lock<mutex>& lk, const T& elem) in push()
180 void sync_priority_queue<T,Container,Cmp>::push(lock_guard<mutex>& lk, const T& elem) in push()
189 lock_guard<mutex> lk(super::mtx_); in push() local
195 …void sync_priority_queue<T,Container,Cmp>::push(unique_lock<mutex>& lk, BOOST_THREAD_RV_REF(T) ele… in push()
202 …void sync_priority_queue<T,Container,Cmp>::push(lock_guard<mutex>& lk, BOOST_THREAD_RV_REF(T) elem) in push()
211 lock_guard<mutex> lk(super::mtx_); in push() local
219 lock_guard<mutex> lk(super::mtx_); in try_push() local
229 lock_guard<mutex> lk(super::mtx_); in try_push() local
251 unique_lock<mutex> lk(super::mtx_); in pull() local
272 unique_lock<mutex> lk(super::mtx_); in pull() local
[all …]
|
| /third_party/boost/boost/fiber/future/detail/ |
| D | shared_state.hpp | 47 void mark_ready_and_notify_( std::unique_lock< mutex > & lk) noexcept { in mark_ready_and_notify_()
54 void owner_destroyed_( std::unique_lock< mutex > & lk) { in owner_destroyed_()
63 void set_exception_( std::exception_ptr except, std::unique_lock< mutex > & lk) { in set_exception_()
72 std::exception_ptr get_exception_ptr_( std::unique_lock< mutex > & lk) { in get_exception_ptr_()
84 future_status wait_for_( std::unique_lock< mutex > & lk, in wait_for_()
93 future_status wait_until_( std::unique_lock< mutex > & lk, in wait_until_()
112 std::unique_lock< mutex > lk{ mtx_ }; in owner_destroyed() local
117 std::unique_lock< mutex > lk{ mtx_ }; in set_exception() local
122 std::unique_lock< mutex > lk{ mtx_ }; in get_exception_ptr() local
127 std::unique_lock< mutex > lk{ mtx_ }; in wait() local
[all …]
|
| /third_party/boost/libs/thread/test/sync/conditions/condition_variable_any/ |
| D | lost_notif_pass.cpp | 76 boost::unique_lock<boost::mutex> lk(mut); in test_posix_wait_function() local
92 boost::unique_lock<boost::mutex> lk(mut); in timed_wait_absolute_without_pred() local
102 boost::unique_lock<boost::mutex> lk(mut); in timed_wait_absolute_with_pred() local
111 boost::unique_lock<boost::mutex> lk(mut); in timed_wait_relative_without_pred() local
121 boost::unique_lock<boost::mutex> lk(mut); in timed_wait_relative_with_pred() local
147 boost::unique_lock<boost::mutex> lk(mut); in test_chrono_wait_function() local
163 boost::unique_lock<boost::mutex> lk(mut); in wait_until_system_without_pred() local
173 boost::unique_lock<boost::mutex> lk(mut); in wait_until_system_with_pred() local
182 boost::unique_lock<boost::mutex> lk(mut); in wait_until_steady_without_pred() local
192 boost::unique_lock<boost::mutex> lk(mut); in wait_until_steady_with_pred() local
[all …]
|
| /third_party/boost/libs/thread/test/sync/conditions/condition_variable/ |
| D | lost_notif_pass.cpp | 76 boost::unique_lock<boost::mutex> lk(mut); in test_posix_wait_function() local
92 boost::unique_lock<boost::mutex> lk(mut); in timed_wait_absolute_without_pred() local
102 boost::unique_lock<boost::mutex> lk(mut); in timed_wait_absolute_with_pred() local
111 boost::unique_lock<boost::mutex> lk(mut); in timed_wait_relative_without_pred() local
121 boost::unique_lock<boost::mutex> lk(mut); in timed_wait_relative_with_pred() local
147 boost::unique_lock<boost::mutex> lk(mut); in test_chrono_wait_function() local
163 boost::unique_lock<boost::mutex> lk(mut); in wait_until_system_without_pred() local
173 boost::unique_lock<boost::mutex> lk(mut); in wait_until_system_with_pred() local
182 boost::unique_lock<boost::mutex> lk(mut); in wait_until_steady_without_pred() local
192 boost::unique_lock<boost::mutex> lk(mut); in wait_until_steady_with_pred() local
[all …]
|
| /third_party/boost/boost/thread/pthread/ |
| D | shared_mutex.hpp | 173 boost::unique_lock<boost::mutex> lk(state_change); in lock_shared() local
180 boost::unique_lock<boost::mutex> lk(state_change); in try_lock_shared() local
196 boost::unique_lock<boost::mutex> lk(state_change); in timed_lock_shared() local
211 boost::unique_lock<boost::mutex> lk(state_change); in timed_lock_shared() local
232 boost::unique_lock<boost::mutex> lk(state_change); in try_lock_shared_until() local
243 boost::unique_lock<boost::mutex> lk(state_change); in unlock_shared() local
271 boost::unique_lock<boost::mutex> lk(state_change); in lock() local
283 boost::unique_lock<boost::mutex> lk(state_change); in timed_lock() local
301 boost::unique_lock<boost::mutex> lk(state_change); in timed_lock() local
325 boost::unique_lock<boost::mutex> lk(state_change); in try_lock_until() local
[all …]
|
| /third_party/boost/boost/thread/ |
| D | latch.hpp | 46 bool try_count_down(unique_lock<mutex> &lk) in try_count_down()
74 boost::unique_lock<boost::mutex> lk(mutex_); in wait() local
83 boost::unique_lock<boost::mutex> lk(mutex_); in try_wait() local
92 boost::unique_lock<boost::mutex> lk(mutex_); in wait_for() local
105 boost::unique_lock<boost::mutex> lk(mutex_); in wait_until() local
117 boost::unique_lock<boost::mutex> lk(mutex_); in count_down() local
124 boost::unique_lock<boost::mutex> lk(mutex_); in try_count_down() local
137 boost::unique_lock<boost::mutex> lk(mutex_); in count_down_and_wait() local
154 boost::lock_guard<boost::mutex> lk(mutex_); in reset() local
|
| D | completion_latch.hpp | 64 bool count_down(unique_lock<mutex> &lk) in count_down()
112 boost::unique_lock<boost::mutex> lk(mutex_); in wait() local
120 boost::unique_lock<boost::mutex> lk(mutex_); in try_wait() local
130 boost::unique_lock<boost::mutex> lk(mutex_); in wait_for() local
142 boost::unique_lock<boost::mutex> lk(mutex_); in wait_until() local
153 unique_lock<mutex> lk(mutex_); in count_down() local
166 boost::unique_lock<boost::mutex> lk(mutex_); in count_down_and_wait() local
183 boost::lock_guard<boost::mutex> lk(mutex_); in reset() local
199 boost::lock_guard<boost::mutex> lk(mutex_); in then() local
207 boost::lock_guard<boost::mutex> lk(mutex_); in then() local
|
| /third_party/boost/boost/thread/v2/ |
| D | shared_mutex.hpp | 277 boost::unique_lock<mutex_t> lk(mut_); in lock() local
285 boost::unique_lock<mutex_t> lk(mut_); in try_lock() local
299 boost::unique_lock<mutex_t> lk(mut_); in try_lock_until() local
320 boost::unique_lock<mutex_t> lk(mut_); in timed_lock() local
352 boost::unique_lock<mutex_t> lk(mut_); in lock_shared() local
361 boost::unique_lock<mutex_t> lk(mut_); in try_lock_shared() local
377 boost::unique_lock<mutex_t> lk(mut_); in try_lock_shared_until() local
394 boost::unique_lock<mutex_t> lk(mut_); in timed_lock_shared() local
655 boost::unique_lock<mutex_t> lk(mut_); in lock() local
663 boost::unique_lock<mutex_t> lk(mut_); in try_lock() local
[all …]
|
| /third_party/boost/libs/fiber/src/algo/ |
| D | shared_work.cpp | 32 std::unique_lock< std::mutex > lk{ rqueue_mtx_ }; /*< in awakened() local
44 std::unique_lock< std::mutex > lk{ rqueue_mtx_ }; in pick_next() local
73 std::unique_lock< std::mutex > lk{ mtx_ }; in suspend_until() local
77 std::unique_lock< std::mutex > lk{ mtx_ }; in suspend_until() local
87 std::unique_lock< std::mutex > lk{ mtx_ }; in notify() local
|
| /third_party/boost/libs/thread/test/sync/mutual_exclusion/locks/shared_lock/cons/ |
| D | move_ctor_upgrade_lock_pass.cpp | 33 boost::shared_lock<boost::shared_mutex> lk( (boost::move(lk0))); in main() local
40 boost::shared_lock<boost::shared_mutex> lk( (boost::upgrade_lock<boost::shared_mutex>(m))); in main() local
46 boost::shared_lock<boost::shared_mutex> lk( (boost::move(lk0))); in main() local
55 boost::shared_lock<boost::shared_mutex> lk( (boost::move(lk0))); in main() local
|
| D | move_ctor_unique_lock_pass.cpp | 33 boost::shared_lock<boost::shared_mutex> lk( (boost::move(lk0))); in main() local
40 boost::shared_lock<boost::shared_mutex> lk( (boost::unique_lock<boost::shared_mutex>(m))); in main() local
46 boost::shared_lock<boost::shared_mutex> lk( (boost::move(lk0))); in main() local
55 boost::shared_lock<boost::shared_mutex> lk( (boost::move(lk0))); in main() local
|
| /third_party/boost/libs/thread/test/sync/mutual_exclusion/locks/unique_lock/cons/ |
| D | move_ctor_upgrade_lock_pass.cpp | 32 boost::unique_lock<boost::upgrade_mutex> lk( (boost::move(lk0))); in main() local
39 …boost::unique_lock<boost::upgrade_mutex> lk( (BOOST_THREAD_MAKE_RV_REF(boost::upgrade_lock<boost::… in main() local
45 boost::unique_lock<boost::upgrade_mutex> lk( (boost::move(lk0))); in main() local
54 boost::unique_lock<boost::upgrade_mutex> lk( (boost::move(lk0))); in main() local
|
| D | move_ctor_pass.cpp | 32 boost::unique_lock<boost::mutex> lk( (boost::move(lk0))); in main() local
39 …boost::unique_lock<boost::mutex> lk( (BOOST_THREAD_MAKE_RV_REF(boost::unique_lock<boost::mutex>(m)… in main() local
45 boost::unique_lock<boost::mutex> lk( (boost::move(lk0))); in main() local
54 boost::unique_lock<boost::mutex> lk( (boost::move(lk0))); in main() local
|
| D | move_ctor_upgrade_lock_until_pass.cpp | 35 …boost::unique_lock<boost::upgrade_mutex> lk( boost::move(lk0), boost::chrono::steady_clock::now()+… in main() local
43 …lk( boost::upgrade_lock<boost::upgrade_mutex>(m), boost::chrono::steady_clock::now()+boost::chrono… in main() local
49 …boost::unique_lock<boost::upgrade_mutex> lk( boost::move(lk0), boost::chrono::steady_clock::now()+… in main() local
58 …boost::unique_lock<boost::upgrade_mutex> lk( boost::move(lk0), boost::chrono::steady_clock::now()+… in main() local
|
| D | move_ctor_upgrade_lock_for_pass.cpp | 35 boost::unique_lock<boost::upgrade_mutex> lk(boost::move(lk0), boost::chrono::milliseconds(1)); in main() local
43 lk(boost::upgrade_lock<boost::upgrade_mutex>(m), boost::chrono::milliseconds(1)); in main() local
49 boost::unique_lock<boost::upgrade_mutex> lk(boost::move(lk0), boost::chrono::milliseconds(1)); in main() local
58 boost::unique_lock<boost::upgrade_mutex> lk(boost::move(lk0), boost::chrono::milliseconds(1)); in main() local
|
| D | move_ctor_upgrade_lock_try_pass.cpp | 33 boost::unique_lock<boost::upgrade_mutex> lk(boost::move(lk0), boost::try_to_lock ); in main() local
40 …boost::unique_lock<boost::upgrade_mutex> lk(boost::upgrade_lock<boost::upgrade_mutex>(m), boost::t… in main() local
46 boost::unique_lock<boost::upgrade_mutex> lk(boost::move(lk0), boost::try_to_lock); in main() local
55 boost::unique_lock<boost::upgrade_mutex> lk(boost::move(lk0), boost::try_to_lock); in main() local
|
| D | move_ctor_shared_lock_for_pass.cpp | 37 boost::unique_lock<boost::shared_mutex> lk(boost::move(lk0), boost::chrono::milliseconds(1)); in main() local
45 lk(boost::shared_lock<boost::shared_mutex>(m), boost::chrono::milliseconds(1)); in main() local
51 boost::unique_lock<boost::shared_mutex> lk(boost::move(lk0), boost::chrono::milliseconds(1)); in main() local
60 boost::unique_lock<boost::shared_mutex> lk(boost::move(lk0), boost::chrono::milliseconds(1)); in main() local
|
| /third_party/boost/boost/thread/concurrent_queues/detail/ |
| D | sync_queue_base.hpp | 60 lock_guard<mutex> lk(mtx_); in underlying_queue() local
122 lock_guard<mutex> lk(mtx_); in close() local
131 lock_guard<mutex> lk(mtx_); in closed() local
148 lock_guard<mutex> lk(mtx_); in empty() local
160 lock_guard<mutex> lk(mtx_); in size() local
165 void sync_queue_base<ValueType, Queue>::throw_if_closed(unique_lock<mutex>& lk) in throw_if_closed()
173 void sync_queue_base<ValueType, Queue>::throw_if_closed(lock_guard<mutex>& lk) in throw_if_closed()
188 bool sync_queue_base<ValueType, Queue>::wait_until_not_empty_or_closed(unique_lock<mutex>& lk) in wait_until_not_empty_or_closed()
197 …eue_base<ValueType, Queue>::wait_until_not_empty_or_closed_until(unique_lock<mutex>& lk, chrono::t… in wait_until_not_empty_or_closed_until()
|
| D | sync_deque_base.hpp | 60 lock_guard<mutex> lk(mtx_); in underlying_queue() local
122 lock_guard<mutex> lk(mtx_); in close() local
131 lock_guard<mutex> lk(mtx_); in closed() local
148 lock_guard<mutex> lk(mtx_); in empty() local
160 lock_guard<mutex> lk(mtx_); in size() local
165 void sync_deque_base<ValueType, Queue>::throw_if_closed(unique_lock<mutex>& lk) in throw_if_closed()
173 void sync_deque_base<ValueType, Queue>::throw_if_closed(lock_guard<mutex>& lk) in throw_if_closed()
188 bool sync_deque_base<ValueType, Queue>::wait_until_not_empty_or_closed(unique_lock<mutex>& lk) in wait_until_not_empty_or_closed()
197 …que_base<ValueType, Queue>::wait_until_not_empty_or_closed_until(unique_lock<mutex>& lk, chrono::t… in wait_until_not_empty_or_closed_until()
|
| /third_party/boost/libs/thread/test/sync/mutual_exclusion/locks/nested_strict_lock/ |
| D | owns_lock_pass.cpp | 22 boost::unique_lock<boost::mutex> lk(m); in main() local
32 boost::unique_lock<boost::mutex> lk(m, boost::adopt_lock); in main() local
41 boost::unique_lock<boost::mutex> lk(m, boost::defer_lock); in main() local
50 boost::unique_lock<boost::mutex> lk(m, boost::try_to_lock); in main() local
|
| /third_party/boost/libs/thread/test/sync/mutual_exclusion/locks/upgrade_lock/cons/ |
| D | move_ctor_shared_lock_until_pass.cpp | 37 …boost::upgrade_lock<boost::shared_mutex> lk( boost::move(lk0), boost::chrono::steady_clock::now()+… in main() local
45 …lk( boost::shared_lock<boost::shared_mutex>(m), boost::chrono::steady_clock::now()+boost::chrono::… in main() local
51 …boost::upgrade_lock<boost::shared_mutex> lk( boost::move(lk0), boost::chrono::steady_clock::now()+… in main() local
60 …boost::upgrade_lock<boost::shared_mutex> lk( boost::move(lk0), boost::chrono::steady_clock::now()+… in main() local
|
| D | move_ctor_shared_lock_for_pass.cpp | 37 boost::upgrade_lock<boost::shared_mutex> lk(boost::move(lk0), boost::chrono::milliseconds(1)); in main() local
45 lk(boost::shared_lock<boost::shared_mutex>(m), boost::chrono::milliseconds(1)); in main() local
51 boost::upgrade_lock<boost::shared_mutex> lk(boost::move(lk0), boost::chrono::milliseconds(1)); in main() local
60 boost::upgrade_lock<boost::shared_mutex> lk(boost::move(lk0), boost::chrono::milliseconds(1)); in main() local
|