| /third_party/flutter/engine/flutter/fml/synchronization/ |
| D | waitable_event.cc | 20 bool WaitWithTimeoutImpl(std::unique_lock<std::mutex>* locker, in WaitWithTimeoutImpl() argument
24 FML_DCHECK(locker->owns_lock()); in WaitWithTimeoutImpl()
34 cv->wait_for(*locker, in WaitWithTimeoutImpl()
58 std::scoped_lock locker(mutex_); in Signal() local
64 std::scoped_lock locker(mutex_); in Reset() local
69 std::unique_lock<std::mutex> locker(mutex_); in Wait() local
71 cv_.wait(locker); in Wait()
76 std::unique_lock<std::mutex> locker(mutex_); in WaitWithTimeout() local
88 cv_.wait_for(locker, in WaitWithTimeout()
113 std::scoped_lock locker(mutex_); in IsSignaledForTest() local
[all …]
|
| /third_party/mindspore/mindspore/ccsrc/runtime/device/gpu/ |
| D | blocking_queue.cc | 113 std::unique_lock<std::mutex> locker(mutex_); in Push() local
115 …if (not_full_cond_.wait_for(locker, std::chrono::microseconds(kTimeout)) == std::cv_status::timeou… in Push()
128 std::unique_lock<std::mutex> locker(mutex_); in Front() local
129 …bool timeout = not_empty_cond_.wait_for(locker, std::chrono::seconds(30), [this] { return !queue_-… in Front()
138 std::unique_lock<std::mutex> locker(mutex_); in Pop() local
139 not_empty_cond_.wait(locker, [this] { return !queue_->IsEmpty(); }); in Pop()
|
| /third_party/glib/glib/ |
| D | gthread.h | 349 g_mutex_locker_free (GMutexLocker *locker) in g_mutex_locker_free() argument
351 g_mutex_unlock ((GMutex *) locker); in g_mutex_locker_free()
427 g_rec_mutex_locker_free (GRecMutexLocker *locker) in g_rec_mutex_locker_free() argument
429 g_rec_mutex_unlock ((GRecMutex *) locker); in g_rec_mutex_locker_free()
538 g_rw_lock_writer_locker_free (GRWLockWriterLocker *locker) in g_rw_lock_writer_locker_free() argument
540 g_rw_lock_writer_unlock ((GRWLock *) locker); in g_rw_lock_writer_locker_free()
593 g_rw_lock_reader_locker_free (GRWLockReaderLocker *locker) in g_rw_lock_reader_locker_free() argument
595 g_rw_lock_reader_unlock ((GRWLock *) locker); in g_rw_lock_reader_locker_free()
|
| /third_party/mindspore/mindspore/ccsrc/ps/ps_cache/ps_data/ |
| D | ps_data_channel.cc | 28 std::unique_lock<std::mutex> locker(channel_mutex_); in TryLockChannel() local
29 channel_.wait(locker, [this] { return channel_open_; }); in TryLockChannel()
38 std::lock_guard<std::mutex> locker(channel_mutex_); in TryWakeChannel() local
|
| D | ps_data_prefetch.cc | 70 std::unique_lock<std::mutex> locker(data_mutex_); in PrefetchData() local
78 if (data_prefetch_.wait_for(locker, std::chrono::seconds(kLongestTimeToWait), in PrefetchData()
96 std::unique_lock<std::mutex> locker(data_mutex_); in FinalizeData() local
104 if (data_process_.wait_for(locker, std::chrono::seconds(kLongestTimeToWait), in FinalizeData()
|
| /third_party/gstreamer/gstplugins_base/tests/examples/gl/qt/qglwtextureshare/ |
| D | AsyncQueue.h | 42 QMutexLocker locker(&mutex); in size()
48 QMutexLocker locker(&mutex); in put()
56 QMutexLocker locker(&mutex); in get()
|
| /third_party/gstreamer/gstplugins_good/ext/qt/ |
| D | qtitem.cc | 544 QMutexLocker locker(&lock); in setSink() local
556 QMutexLocker locker(&lock); in setBuffer() local
630 QMutexLocker locker(&lock); in initWinSys() local
701 QMutexLocker locker(&lock); in setCaps() local
732 QMutexLocker locker(&lock); in getQtContext() local
743 QMutexLocker locker(&lock); in getContext() local
754 QMutexLocker locker(&lock); in getDisplay() local
765 QMutexLocker locker(&lock); in setDAR() local
774 QMutexLocker locker(&lock); in getDAR() local
783 QMutexLocker locker(&lock); in setForceAspectRatio() local
[all …]
|
| /third_party/node/deps/npm/test/tap/ |
| D | locker.js | 7 var locker = require('../../lib/utils/locker.js') variable
8 var lock = locker.lock
9 var unlock = locker.unlock
|
| /third_party/mindspore/mindspore/ccsrc/backend/optimizer/mem_reuse/ |
| D | mem_dynamic_allocator.cc | 31 std::lock_guard<std::mutex> locker(mutex_); in AllocTensorMem() local
48 std::lock_guard<std::mutex> locker(mutex_); in AllocContinuousTensorMem() local
204 std::lock_guard<std::mutex> locker(mutex_); in FreeTensorMem() local
282 std::lock_guard<std::mutex> locker(mutex_); in ReleaseDeviceRes() local
300 std::lock_guard<std::mutex> locker(mutex_); in DumpDynamicMemPoolInfo() local
|
| D | mem_dynamic_allocator.h | 99 std::lock_guard<std::mutex> locker(mutex_); in global_idle_mem_buf_map()
|
| /third_party/mindspore/mindspore/ccsrc/profiler/device/ |
| D | profiling.cc | 69 std::lock_guard<std::mutex> locker(record_mutex_); in RecordOneStepStartEndInfo() local
76 std::lock_guard<std::mutex> locker(record_mutex_); in RecordOneStepStartEndInfo() local
|
| /third_party/mindspore/mindspore/ccsrc/ps/ps_cache/ |
| D | ps_cache_manager.cc | 175 std::unique_lock<std::mutex> locker(data_mutex_); in InitParameterServer() local
176 …insert_init_info_.wait(locker, [this] { return finish_insert_init_info_ == true || running_ == fal… in InitParameterServer()
208 std::unique_lock<std::mutex> locker(data_mutex_); in InitDataChannel() local
209 data_prase_.wait(locker, [this] { return !channel_name_.empty() || running_ == false; }); in InitDataChannel()
265 std::lock_guard<std::mutex> locker(channel_mutex_); in channel_name() local
273 std::lock_guard<std::mutex> locker(channel_mutex_); in set_channel_name() local
301 std::unique_lock<std::mutex> locker(data_mutex_); in IncreaseGraphStep() local
302 …data_prase_.wait(locker, [this] { return ((finish_init_parameter_server_ == true) || (running_ == … in IncreaseGraphStep()
372 std::unique_lock<std::mutex> locker(data_mutex_); in ProcessData() local
374 (void)data_prase_.wait_for(locker, std::chrono::milliseconds(longest_time_to_wait)); in ProcessData()
[all …]
|
| /third_party/boost/boost/interprocess/sync/detail/ |
| D | condition_algorithm_8a.hpp | 208 scoped_lock<mutex_type> locker(data.get_mtx_unblock_lock()); in signal() local
275 scoped_lock<mutex_type> locker(data.get_mtx_unblock_lock()); in wait() local
|
| /third_party/boost/boost/thread/win32/ |
| D | condition_variable.hpp | 258 relocker<lock_type> locker(lock); in do_wait_until() local
260 locker.unlock(); in do_wait_until()
274 locker.lock(); in do_wait_until()
|
| /third_party/abseil-cpp/absl/synchronization/ |
| D | mutex_benchmark.cc | 84 RaiiLocker<MutexType> locker(&shared->mu); in BM_Contended() local
|
| /third_party/node/test/embedding/ |
| D | embedtest.cc | 73 Locker locker(isolate); in RunNodeInstance() local
|
| /third_party/node/src/ |
| D | node_main_instance.cc | 110 Locker locker(isolate_); in Run() local
|
| D | node_worker.cc | 167 Locker locker(isolate); in WorkerThreadData() local
264 Locker locker(isolate_); in Run() local
|
| /third_party/boost/libs/thread/doc/ |
| D | external_locking.qbk | 512 : lock_(lock) // Store reference to locker
513 , tmp_lock_(lock.move()) // Move ownership to temporary locker
524 lock_=tmp_lock_.move(); // Move ownership to nesting locker
560 … BOOST_STATIC_ASSERT((is_strict_lock<Locker>::value)); // locker is a strict locker "sur parole"
563 …efine BOOST_THREAD_EXTERNALLY_LOCKED_NO_CHECK_OWNERSHIP if you don't want to check locker ownership
|
| /third_party/mindspore/mindspore/ccsrc/runtime/hardware/gpu/ |
| D | gpu_device_context.cc | 409 std::lock_guard<std::mutex> locker(launch_mutex_); in LaunchKernel() local
413 std::lock_guard<std::mutex> locker(launch_mutex_); in LaunchKernel() local
|
| /third_party/skia/third_party/externals/abseil-cpp/absl/synchronization/ |
| D | mutex_benchmark.cc | 200 RaiiLocker<MutexType> locker(&shared->mu); in BM_Contended() local
|
| /third_party/node/deps/npm/lib/ |
| D | install.js | 117 var locker = require('./utils/locker.js') variable
118 var lock = locker.lock
119 var unlock = locker.unlock
|
| /third_party/mindspore/mindspore/ccsrc/runtime/hardware/cpu/ |
| D | cpu_device_context.cc | 271 std::lock_guard<std::mutex> locker(launch_mutex_); in LaunchKernelWithProfiling() local
|
| /third_party/libusb/libusb/os/ |
| D | haiku_usb_backend.cpp | 205 BAutolock locker(fTransfersLock); in SubmitTransfer() local
|
| /third_party/node/doc/api/ |
| D | embedding.md | 122 Locker locker(isolate);
|