| /ohos5.0/commonlibrary/ets_utils/js_concurrent_module/worker/ |
| H A D | message_queue.cpp | 22 queueLock_.lock(); in EnQueue()
24 queueLock_.unlock(); in EnQueue()
29 queueLock_.lock(); in DeQueue()
31 queueLock_.unlock(); in DeQueue()
40 queueLock_.unlock(); in DeQueue()
51 queueLock_.lock(); in Clear()
58 queueLock_.unlock(); in Clear()
63 std::unique_lock<std::mutex> lock(queueLock_); in Push()
69 std::unique_lock<std::mutex> lock(queueLock_); in Pop()
75 std::unique_lock<std::mutex> lock(queueLock_); in Front()
[all …]
|
| H A D | message_queue.h | 38 std::mutex queueLock_;
51 std::unique_lock<std::mutex> lock(queueLock_); in GetSize()
56 std::mutex queueLock_;
|
| /ohos5.0/foundation/graphic/graphic_3d/lume/LumeEngine/src/threading/ |
| H A D | dispatcher_task_queue.cpp | 43 std::lock_guard lock(queueLock_); in Remove()
55 std::lock_guard lock(queueLock_); in Clear()
63 std::lock_guard lock(queueLock_); in Submit()
70 std::lock_guard lock(queueLock_); in SubmitAfter()
104 std::lock_guard lock(queueLock_); in Execute()
119 std::lock_guard lock(queueLock_); in Execute()
127 std::lock_guard lock(queueLock_); in CollectFinishedTasks()
|
| H A D | dispatcher_task_queue.h | 58 std::mutex queueLock_; in CORE_BEGIN_NAMESPACE() local
|
| /ohos5.0/drivers/peripheral/camera/vdi_base/common/pipeline_core/ipp/src/ |
| H A D | offline_pipeline.cpp | 45 std::unique_lock<std::mutex> l(queueLock_); in StartProcess()
69 std::unique_lock<std::mutex> l(queueLock_); in StopProcess()
107 std::unique_lock<std::mutex> l(queueLock_); in CancelCapture()
140 std::unique_lock<std::mutex> l(queueLock_); in FlushOfflineStream()
162 std::unique_lock<std::mutex> l(queueLock_); in ReceiveCache()
173 std::unique_lock<std::mutex> l(queueLock_); in HandleBuffers()
248 std::unique_lock<std::mutex> l(queueLock_); in CacheQueueDry()
254 std::unique_lock<std::mutex> l(queueLock_); in CheckOwnerOfCaptureId()
|
| /ohos5.0/commonlibrary/ets_utils/js_concurrent_module/taskpool/ |
| H A D | message_queue.h | 28 std::lock_guard<std::mutex> lock(queueLock_); in EnQueue()
34 std::lock_guard<std::mutex> lock(queueLock_); in DeQueue()
46 std::lock_guard<std::mutex> lock(queueLock_); in IsEmpty()
51 std::mutex queueLock_;
|
| /ohos5.0/foundation/graphic/graphic_2d/rosen/modules/platform/eventhandler_impl/ |
| H A D | event_queue.cpp | 99 std::lock_guard<std::mutex> lock(queueLock_); in ~EventQueue()
110 std::lock_guard<std::mutex> lock(queueLock_); in Insert()
152 std::lock_guard<std::mutex> lock(queueLock_); in RemoveOrphan()
216 std::lock_guard<std::mutex> lock(queueLock_); in Remove()
252 std::lock_guard<std::mutex> lock(queueLock_); in HasInnerEvent()
368 std::lock_guard<std::mutex> lock(queueLock_); in AddFileDescriptorListener()
405 std::lock_guard<std::mutex> lock(queueLock_); in RemoveFileDescriptorListener()
419 std::lock_guard<std::mutex> lock(queueLock_); in RemoveFileDescriptorListener()
430 std::lock_guard<std::mutex> lock(queueLock_); in Prepare()
439 std::lock_guard<std::mutex> lock(queueLock_); in Finish()
[all …]
|
| /ohos5.0/base/notification/eventhandler/frameworks/eventhandler/src/ |
| H A D | event_queue_ffrt.cpp | 95 std::lock_guard<std::mutex> lock(queueLock_); in ~EventQueueFFRT()
116 std::lock_guard<std::mutex> lock(queueLock_); in RemoveOrphanByHandlerId()
128 std::lock_guard<std::mutex> lock(queueLock_); in RemoveAll()
149 std::lock_guard<std::mutex> lock(queueLock_); in Remove()
173 std::lock_guard<std::mutex> lock(queueLock_); in Remove()
197 std::lock_guard<std::mutex> lock(queueLock_); in Remove()
222 std::lock_guard<std::mutex> lock(queueLock_); in Remove()
245 std::lock_guard<std::mutex> lock(queueLock_); in HasInnerEvent()
267 std::lock_guard<std::mutex> lock(queueLock_); in HasInnerEvent()
285 std::lock_guard<std::mutex> lock(queueLock_); in Dump()
[all …]
|
| H A D | event_queue.cpp | 80 std::lock_guard<std::mutex> lock(queueLock_); in ~EventQueue()
119 std::lock_guard<std::mutex> lock(queueLock_); in AddFileDescriptorListener()
159 std::lock_guard<std::mutex> lock(queueLock_); in RemoveFileDescriptorListener()
175 std::lock_guard<std::mutex> lock(queueLock_); in RemoveFileDescriptorListener()
194 std::lock_guard<std::mutex> lock(queueLock_); in Prepare()
205 std::lock_guard<std::mutex> lock(queueLock_); in Finish()
230 std::lock_guard<std::mutex> lock(queueLock_); in HandleFileDescriptorEvent()
287 std::unique_lock<std::mutex> lock(queueLock_); in CheckFileDescriptorEvent()
|
| H A D | event_queue_base.cpp | 103 std::lock_guard<std::mutex> lock(queueLock_); in ~EventQueueBase()
117 std::lock_guard<std::mutex> lock(queueLock_); in Insert()
155 std::lock_guard<std::mutex> lock(queueLock_); in RemoveOrphan()
167 std::lock_guard<std::mutex> lock(queueLock_); in RemoveAll()
248 std::lock_guard<std::mutex> lock(queueLock_); in Remove()
306 std::lock_guard<std::mutex> lock(queueLock_); in HasInnerEvent()
399 std::unique_lock<std::mutex> lock(queueLock_); in GetEvent()
563 std::lock_guard<std::mutex> lock(queueLock_); in Dump()
583 std::lock_guard<std::mutex> lock(queueLock_); in DumpQueueInfo()
621 std::lock_guard<std::mutex> lock(queueLock_); in IsQueueEmpty()
[all …]
|
| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/syncer/src/device/singlever/ |
| H A D | single_ver_data_message_schedule.cpp | 40 std::lock_guard<std::mutex> lock(queueLock_); in PutMsg()
47 std::lock_guard<std::mutex> lock(queueLock_); in IsNeedReloadQueue()
117 std::lock_guard<std::mutex> lock(queueLock_); in UpdateMsgMap()
187 std::lock_guard<std::mutex> lock(queueLock_); in GetLastMsgFromQueue()
218 std::lock_guard<std::mutex> lock(queueLock_); in ClearMsgQueue()
|
| H A D | single_ver_data_message_schedule.h | 58 std::mutex queueLock_; variable
|
| /ohos5.0/drivers/peripheral/usb/ddk/host/src/ |
| H A D | ddk_uevent_queue.cpp | 64 std::mutex queueLock_; member in TaskQueue
158 std::unique_lock<std::mutex> uniqueLock(queueLock_); in Init()
182 std::lock_guard<std::mutex> lock(queueLock_); in UnInit()
195 std::lock_guard<std::mutex> lock(queueLock_); in AddTask()
|
| /ohos5.0/drivers/peripheral/camera/vdi_base/common/metadata_manager/src/ |
| H A D | metadata_controller.cpp | 46 std::unique_lock<std::mutex> lock(queueLock_); in ~MetadataController()
84 std::unique_lock<std::mutex> lock(queueLock_); in AddNodeCallback()
96 std::unique_lock<std::mutex> lock(queueLock_); in ClearNodeCallback()
239 std::unique_lock<std::mutex> lock(queueLock_); in DealMetadata()
260 std::unique_lock<std::mutex> lock(queueLock_); in DealMetadata()
498 std::unique_lock<std::mutex> lock(queueLock_); in DealMessage()
580 std::unique_lock<std::mutex> lock(queueLock_); in Stop()
|
| /ohos5.0/drivers/peripheral/camera/vdi_base/common/pipeline_core/ipp/include/ |
| H A D | offline_pipeline.h | 60 std::mutex queueLock_; variable
|
| /ohos5.0/foundation/graphic/graphic_2d/rosen/modules/platform/eventhandler/ |
| H A D | event_queue.h | 236 std::mutex queueLock_; variable
|
| /ohos5.0/drivers/peripheral/camera/vdi_base/common/metadata_manager/include/ |
| H A D | metadata_controller.h | 82 std::mutex queueLock_; variable
|
| /ohos5.0/foundation/multimedia/media_library/interfaces/kits/js/include/ |
| H A D | thumbnail_manager.h | 196 std::mutex queueLock_; variable
|
| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/syncer/src/device/ |
| H A D | sync_engine.cpp | 45 std::mutex SyncEngine::queueLock_; member in DistributedDB::SyncEngine
130 std::lock_guard<std::mutex> msgLock(queueLock_); in Close()
406 std::lock_guard<std::mutex> lock(queueLock_); in DealMsgUtilQueueEmpty()
528 std::lock_guard<std::mutex> lock(queueLock_); in MessageReciveCallbackInner()
|
| H A D | sync_engine.h | 242 static std::mutex queueLock_; variable
|
| /ohos5.0/base/notification/eventhandler/interfaces/inner_api/ |
| H A D | event_queue.h | 364 std::mutex queueLock_; variable
|
| /ohos5.0/foundation/multimedia/media_library/frameworks/js/src/ |
| H A D | thumbnail_manager.cpp | 530 std::unique_lock<std::mutex> lock(queueLock_); in ImageWorker()
|