| /third_party/boost/boost/thread/ |
| D | externally_locked.hpp | 53 obj_(obj), mtx_(&mtx) in externally_locked()
62 obj_(move(obj)), mtx_(&mtx) in externally_locked()
71 : obj_(), mtx_(&mtx) in externally_locked()
79 : obj_(rhs.obj_), mtx_(rhs.mtx_) in externally_locked()
86 : obj_(move(rhs.obj_)), mtx_(rhs.mtx_) in externally_locked()
94 mtx_=rhs.mtx_; in operator =()
102 mtx_=rhs.mtx_; in operator =()
109 swap(mtx_, rhs.mtx_); in swap()
121 …BOOST_THREAD_ASSERT_PRECONDITION( lk.owns_lock(mtx_), lock_error() ); /*< run time check throw if… in get()
127 …BOOST_THREAD_ASSERT_PRECONDITION( lk.owns_lock(mtx_), lock_error() ); /*< run time check throw if… in get()
[all …]
|
| D | synchronized_value.hpp | 421 mutable mutex_type mtx_; member in boost::synchronized_value
465 strict_lock<mutex_type> lk(rhs.mtx_); in synchronized_value()
475 strict_lock<mutex_type> lk(BOOST_THREAD_RV(other).mtx_); in synchronized_value()
495 unique_lock<mutex_type> lk1(mtx_, defer_lock); in operator =()
496 unique_lock<mutex_type> lk2(rhs.mtx_, defer_lock); in operator =()
511 strict_lock<mutex_type> lk(mtx_); in operator =()
527 strict_lock<mutex_type> lk(mtx_); in get()
566 return mtx_; in mutex()
582 unique_lock<mutex_type> lk1(mtx_, defer_lock); in swap()
583 unique_lock<mutex_type> lk2(rhs.mtx_, defer_lock); in swap()
[all …]
|
| D | externally_locked_stream.hpp | 38 mtx_(&mtx) in stream_guard()
44 mtx_(&mtx) in stream_guard()
49 : mtx_(rhs.mtx_) in stream_guard()
51 rhs.mtx_= 0; in stream_guard()
56 if (mtx_ != 0) mtx_->unlock(); in ~stream_guard()
61 return l == mtx_->mutex(); in owns_lock()
69 BOOST_THREAD_ASSERT_PRECONDITION( mtx_, lock_error() ); in get()
70 return mtx_->get(*this); in get()
79 externally_locked_stream<Stream, RecursiveMutex>* mtx_; member in boost::stream_guard
|
| D | testable_mutex.hpp | 38 Lockable mtx_; member in boost::testable_mutex
52 mtx_.lock(); in lock()
60 mtx_.unlock(); in unlock()
66 if (mtx_.try_lock()) in try_lock()
81 if (mtx_.try_lock_for(rel_time)) in try_lock_for()
95 if (mtx_.try_lock_until(abs_time)) in try_lock_until()
|
| D | strict_lock.hpp | 48 mtx_(mtx) in strict_lock()
56 mtx_(*(const_cast<thread_detail::lockable_wrapper<Lockable>*>(l_.begin())->m)) in strict_lock()
58 mtx_.lock(); in strict_lock()
71 mtx_.unlock(); in ~strict_lock()
82 return &mtx_; in mutex()
107 mutex_type& mtx_; member in boost::strict_lock
|
| /third_party/boost/boost/thread/concurrent_queues/ |
| D | sync_bounded_queue.hpp | 91 mutable mutex mtx_; member in boost::concurrent::sync_bounded_queue
274 lock_guard<mutex> lk(mtx_); in close()
284 lock_guard<mutex> lk(mtx_); in closed()
296 lock_guard<mutex> lk(mtx_); in empty()
302 lock_guard<mutex> lk(mtx_); in full()
309 lock_guard<mutex> lk(mtx_); in capacity()
316 lock_guard<mutex> lk(mtx_); in size()
345 unique_lock<mutex> lk(mtx_); in try_pull()
365 unique_lock<mutex> lk(mtx_); in try_pull_front()
373 unique_lock<mutex> lk(mtx_, try_to_lock); in try_pull()
[all …]
|
| D | sync_deque.hpp | 161 unique_lock<mutex> lk(super::mtx_); in try_pull_front()
168 unique_lock<mutex> lk(super::mtx_); in wait_pull_front()
175 unique_lock<mutex> lk(super::mtx_, try_to_lock); in nonblocking_pull_front()
186 unique_lock<mutex> lk(super::mtx_); in pull_front()
196 unique_lock<mutex> lk(super::mtx_); in pull_front()
213 unique_lock<mutex> lk(super::mtx_); in try_push_back()
228 unique_lock<mutex> lk(super::mtx_); in wait_push_back()
235 unique_lock<mutex> lk(super::mtx_, try_to_lock); in nonblocking_push_back()
243 unique_lock<mutex> lk(super::mtx_); in push_back()
259 unique_lock<mutex> lk(super::mtx_); in try_push_back()
[all …]
|
| D | sync_queue.hpp | 161 unique_lock<mutex> lk(super::mtx_); in try_pull()
168 unique_lock<mutex> lk(super::mtx_); in wait_pull()
175 unique_lock<mutex> lk(super::mtx_, try_to_lock); in nonblocking_pull()
186 unique_lock<mutex> lk(super::mtx_); in pull()
196 unique_lock<mutex> lk(super::mtx_); in pull()
213 unique_lock<mutex> lk(super::mtx_); in try_push()
228 unique_lock<mutex> lk(super::mtx_); in wait_push()
235 unique_lock<mutex> lk(super::mtx_, try_to_lock); in nonblocking_push()
243 unique_lock<mutex> lk(super::mtx_); in push()
259 unique_lock<mutex> lk(super::mtx_); in try_push()
[all …]
|
| D | sync_priority_queue.hpp | 189 lock_guard<mutex> lk(super::mtx_); in push()
211 lock_guard<mutex> lk(super::mtx_); in push()
219 lock_guard<mutex> lk(super::mtx_); in try_push()
229 lock_guard<mutex> lk(super::mtx_); in try_push()
251 unique_lock<mutex> lk(super::mtx_); in pull()
272 unique_lock<mutex> lk(super::mtx_); in pull()
284 unique_lock<mutex> lk(super::mtx_); in pull_until()
330 lock_guard<mutex> lk(super::mtx_); in try_pull()
347 unique_lock<mutex> lk(super::mtx_); in wait_pull()
355 unique_lock<mutex> lk(super::mtx_, try_to_lock); in nonblocking_pull()
|
| /third_party/boost/boost/fiber/future/detail/ |
| D | shared_state.hpp | 43 mutable mutex mtx_{}; member in boost::fibers::detail::shared_state_base
112 std::unique_lock< mutex > lk{ mtx_ }; in owner_destroyed()
117 std::unique_lock< mutex > lk{ mtx_ }; in set_exception()
122 std::unique_lock< mutex > lk{ mtx_ }; in get_exception_ptr()
127 std::unique_lock< mutex > lk{ mtx_ }; in wait()
133 std::unique_lock< mutex > lk{ mtx_ }; in wait_for()
139 std::unique_lock< mutex > lk{ mtx_ }; in wait_until()
204 std::unique_lock< mutex > lk{ mtx_ }; in set_value()
209 std::unique_lock< mutex > lk{ mtx_ }; in set_value()
214 std::unique_lock< mutex > lk{ mtx_ }; in get()
[all …]
|
| /third_party/boost/boost/thread/executors/ |
| D | inline_executor.hpp | 36 mutable mutex mtx_; member in boost::executors::inline_executor
77 lock_guard<mutex> lk(mtx_); in close()
90 lock_guard<mutex> lk(mtx_); in closed()
111 lock_guard<mutex> lk(mtx_); in submit()
128 lock_guard<mutex> lk(mtx_); in submit()
146 lock_guard<mutex> lk(mtx_); in submit()
|
| D | thread_executor.hpp | 42 mutable mutex mtx_; member in boost::executors::thread_executor
85 lock_guard<mutex> lk(mtx_); in close()
98 lock_guard<mutex> lk(mtx_); in closed()
118 lock_guard<mutex> lk(mtx_); in submit()
127 lock_guard<mutex> lk(mtx_); in submit()
137 lock_guard<mutex> lk(mtx_); in submit()
|
| D | serial_executor_cont.hpp | 43 mutex mtx_; member in boost::executors::serial_executor_cont
110 lock_guard<mutex> lk(mtx_); in close()
119 lock_guard<mutex> lk(mtx_); in closed()
149 lock_guard<mutex> lk(mtx_); in submit()
156 lock_guard<mutex> lk(mtx_); in submit()
164 lock_guard<mutex> lk(mtx_); in submit()
|
| /third_party/mindspore/mindspore/ccsrc/debug/rdr/ |
| D | recorder_manager.cc | 55 std::lock_guard<std::mutex> lock(mtx_); in RecordObject()
65 std::lock_guard<std::mutex> lock(mtx_); in GetRecorder()
75 std::lock_guard<std::mutex> lock(mtx_); in RdrEnable()
83 std::lock_guard<std::mutex> lock(mtx_); in CheckRdrMemIsRecord()
91 std::lock_guard<std::mutex> lock(mtx_); in SetRdrMemIsRecord()
100 std::lock_guard<std::mutex> lock(mtx_); in TriggerAll()
116 std::lock_guard<std::mutex> lock(mtx_); in ClearAll()
|
| /third_party/boost/boost/fiber/cuda/ |
| D | waitfor.hpp | 55 std::unique_lock< mutex > lk{ mtx_ }; in notify()
64 std::unique_lock< mutex > lk{ mtx_ }; in wait()
70 mutex mtx_{}; member in boost::fibers::cuda::detail::single_stream_rendezvous
86 std::unique_lock< mutex > lk{ mtx_ };
94 std::unique_lock< mutex > lk{ mtx_ }; in notify()
104 std::unique_lock< mutex > lk{ mtx_ }; in wait()
110 mutex mtx_{}; member in boost::fibers::cuda::detail::many_streams_rendezvous
|
| /third_party/boost/boost/fiber/hip/ |
| D | waitfor.hpp | 55 std::unique_lock< mutex > lk{ mtx_ }; in notify()
64 std::unique_lock< mutex > lk{ mtx_ }; in wait()
70 mutex mtx_{}; member in boost::fibers::cuda::detail::single_stream_rendezvous
86 std::unique_lock< mutex > lk{ mtx_ };
94 std::unique_lock< mutex > lk{ mtx_ }; in notify()
104 std::unique_lock< mutex > lk{ mtx_ }; in wait()
110 mutex mtx_{}; member in boost::fibers::cuda::detail::many_streams_rendezvous
|
| /third_party/mindspore/mindspore/ccsrc/fl/server/ |
| D | local_meta_store.cc | 23 std::unique_lock<std::mutex> lock(mtx_); in remove_value()
30 std::unique_lock<std::mutex> lock(mtx_); in has_value()
35 std::unique_lock<std::mutex> lock(mtx_); in set_curr_iter_num()
40 std::unique_lock<std::mutex> lock(mtx_); in curr_iter_num()
|
| D | local_meta_store.h | 41 std::unique_lock<std::mutex> lock(mtx_); in put_value()
47 std::unique_lock<std::mutex> lock(mtx_); in value()
59 std::unique_lock<std::mutex> lock(mtx_); in mutable_value()
82 std::mutex mtx_; variable
|
| /third_party/boost/boost/thread/concurrent_queues/detail/ |
| D | sync_queue_base.hpp | 60 lock_guard<mutex> lk(mtx_); in underlying_queue()
65 mutable mutex mtx_; member in boost::concurrent::detail::sync_queue_base
122 lock_guard<mutex> lk(mtx_); in close()
131 lock_guard<mutex> lk(mtx_); in closed()
148 lock_guard<mutex> lk(mtx_); in empty()
160 lock_guard<mutex> lk(mtx_); in size()
|
| D | sync_deque_base.hpp | 60 lock_guard<mutex> lk(mtx_); in underlying_queue()
65 mutable mutex mtx_; member in boost::concurrent::detail::sync_deque_base
122 lock_guard<mutex> lk(mtx_); in close()
131 lock_guard<mutex> lk(mtx_); in closed()
148 lock_guard<mutex> lk(mtx_); in empty()
160 lock_guard<mutex> lk(mtx_); in size()
|
| /third_party/boost/libs/thread/doc/ |
| D | internal_locking.qbk | 64 boost::mutex mtx_;
68 mtx_.lock();
70 mtx_.unlock();
73 mtx_.lock();
75 mtx_.unlock();
78 mtx_.lock();
80 mtx_.unlock();
89 …below, guard's constructor locks the passed-in object `mtx_`, and guard's destructor unlocks `mtx_…
92 boost::mutex mtx_; // explicit mutex declaration
96 boost::lock_guard<boost::mutex> guard(mtx_);
[all …]
|
| /third_party/boost/libs/fiber/examples/asio/ps/ |
| D | server.cpp | 58 boost::fibers::mutex mtx_; member in registry
102 std::unique_lock< boost::fibers::mutex > lk( mtx_); in register_queue()
108 std::unique_lock< boost::fibers::mutex > lk( mtx_); in unregister_queue()
114 std::unique_lock< boost::fibers::mutex > lk( mtx_); in subscribe()
120 std::unique_lock< boost::fibers::mutex > lk( mtx_); in unsubscribe()
126 std::unique_lock< boost::fibers::mutex > lk( mtx_); in publish()
170 std::unique_lock< boost::fibers::mutex > lk( mtx_); in run()
204 std::unique_lock< boost::fibers::mutex > lk( mtx_); in publish()
213 boost::fibers::mutex mtx_; member in subscriber_session
|
| /third_party/mindspore/mindspore/ccsrc/minddata/dataset/util/ |
| D | lock.cc | 38 std::unique_lock<std::mutex> lck(mtx_); in LockShared()
46 std::unique_lock<std::mutex> lck(mtx_); in Unlock()
65 std::unique_lock<std::mutex> lck(mtx_); in Upgrade()
82 std::unique_lock<std::mutex> lck(mtx_); in Downgrade()
|
| /third_party/boost/boost/serialization/detail/ |
| D | shared_count_132.hpp | 114 mutex_type::scoped_lock lock(mtx_); in add_ref_copy()
122 mutex_type::scoped_lock lock(mtx_); in add_ref_lock()
132 mutex_type::scoped_lock lock(mtx_); in release()
146 mutex_type::scoped_lock lock(mtx_); in weak_add_ref()
157 mutex_type::scoped_lock lock(mtx_); in weak_release()
171 mutex_type::scoped_lock lock(mtx_); in use_count()
185 mutable mutex_type mtx_; member in boost_132::detail::sp_counted_base
|
| /third_party/mindspore/mindspore/ccsrc/ps/core/communicator/ |
| D | task_executor.cc | 33 std::unique_lock<std::mutex> lock(mtx_); in TaskExecutor()
62 std::unique_lock<std::mutex> lock(mtx_); in TaskExecutor()
77 std::unique_lock<std::mutex> lock(mtx_); in ~TaskExecutor()
|