| /ohos5.0/foundation/ability/ability_lite/frameworks/ability_lite/src/ |
| H A D | ability_event_handler.cpp | 27 (void) pthread_mutex_init(&queueMutex_, nullptr); in AbilityEventHandler()
33 (void) pthread_mutex_destroy(&queueMutex_); in ~AbilityEventHandler()
41 (void) pthread_mutex_lock(&queueMutex_); in Run()
44 (void) pthread_cond_wait(&pthreadCond_, &queueMutex_); in Run()
48 (void) pthread_mutex_unlock(&queueMutex_); in Run()
50 (void) pthread_mutex_lock(&queueMutex_); in Run()
52 (void) pthread_mutex_unlock(&queueMutex_); in Run()
60 (void) pthread_mutex_lock(&queueMutex_); in PostTask()
64 (void) pthread_mutex_unlock(&queueMutex_); in PostTask()
|
| /ohos5.0/foundation/ai/intelligent_voice_framework/utils/ |
| H A D | queue_util.h | 42 std::unique_lock<std::mutex> lock(queueMutex_);
49 std::unique_lock<std::mutex> lock(queueMutex_);
64 std::unique_lock<std::mutex> lock(queueMutex_);
79 std::unique_lock<std::mutex> lock(queueMutex_); in Pop()
94 std::unique_lock<std::mutex> lock(queueMutex_); in PopUntilTimeout()
114 std::unique_lock<std::mutex> lock(queueMutex_); in Uninit()
141 std::mutex queueMutex_; variable
|
| /ohos5.0/base/hiviewdfx/hiview/base/ |
| H A D | event_loop.cpp | 123 std::lock_guard<std::mutex> lock(queueMutex_); in StartLoop()
148 std::lock_guard<std::mutex> lock(queueMutex_); in StopLoop()
178 std::lock_guard<std::mutex> lock(queueMutex_); in AddEvent()
209 std::lock_guard<std::mutex> lock(queueMutex_); in AddEventForResult()
243 std::lock_guard<std::mutex> lock(queueMutex_); in AddTimerEvent()
253 std::lock_guard<std::mutex> lock(queueMutex_); in RemoveEvent()
285 std::lock_guard<std::mutex> lock(queueMutex_); in AddFileDescriptorEventCallback()
329 std::lock_guard<std::mutex> lock(queueMutex_); in RemoveFileDescriptorEventCallback()
357 std::lock_guard<std::mutex> lock(queueMutex_); in ModifyFdStatus()
476 std::lock_guard<std::mutex> lock(queueMutex_); in FetchNextEvent()
[all …]
|
| /ohos5.0/foundation/communication/netstack/utils/http_over_curl/include/ |
| H A D | thread_safe_storage.h | 37 spinlock_mutex queueMutex_;
49 std::lock_guard lock(queueMutex_); in Push()
57 std::lock_guard lock(queueMutex_); in Flush()
70 std::lock_guard lock(queueMutex_); in IsEmpty()
|
| /ohos5.0/foundation/multimedia/media_library/frameworks/services/media_scanner/src/scanner/ |
| H A D | media_scan_executor.cpp | 23 std::lock_guard<std::mutex> lock(queueMutex_); in Commit()
39 std::lock_guard<std::mutex> lock(queueMutex_); in HandleScanExecution()
68 std::lock_guard<std::mutex> lock(queueMutex_); in Stop()
|
| /ohos5.0/foundation/multimedia/media_library/frameworks/services/media_cloud_enhancement/src/utils/ |
| H A D | enhancement_thread_manager.cpp | 41 lock_guard<mutex> lock(queueMutex_); in ~EnhancementThreadManager()
58 lock_guard<mutex> lock(queueMutex_); in OnProducerCallback()
73 unique_lock<mutex> lock(queueMutex_); in DealWithTasks()
|
| /ohos5.0/foundation/multimedia/media_foundation/src/buffer/avbuffer_queue/ |
| H A D | avbuffer_queue.cpp | 119 std::lock_guard<std::mutex> lockGuard(queueMutex_); in SetQueueSize()
290 std::unique_lock<std::mutex> lock(queueMutex_); in RequestBuffer()
357 std::lock_guard<std::mutex> lockGuard(queueMutex_); in PushBuffer()
400 std::lock_guard<std::mutex> lockGuard(queueMutex_); in ReturnBuffer()
456 std::lock_guard<std::mutex> lockGuard(queueMutex_); in SetQueueSizeAndAttachBuffer()
535 std::lock_guard<std::mutex> lockGuard(queueMutex_); in AttachBuffer()
577 std::lock_guard<std::mutex> lockGuard(queueMutex_); in DetachBuffer()
590 std::lock_guard<std::mutex> lockGuard(queueMutex_); in AcquireBuffer()
605 std::lock_guard<std::mutex> lockGuard(queueMutex_); in ReleaseBuffer()
641 std::lock_guard<std::mutex> lockGuard(queueMutex_); in Clear()
|
| /ohos5.0/base/update/updater/services/script/threadpool/ |
| H A D | threadpool.cpp | 91 std::lock_guard<std::mutex> lock(queueMutex_); in ~ThreadPool()
121 std::lock_guard<std::mutex> lock(queueMutex_); in AddNewTask()
127 std::lock_guard<std::mutex> lock(queueMutex_); in AcquireWorkIndex()
|
| H A D | thread_pool.h | 74 std::mutex queueMutex_; variable
|
| /ohos5.0/foundation/multimedia/media_foundation/engine/scene/player/standard/ |
| H A D | hiplayer_callback_looper.cpp | 166 OSAL::ScopedLock lock(queueMutex_); in Enqueue()
185 OSAL::ScopedLock lock(queueMutex_); in Next()
208 OSAL::ScopedLock lock(queueMutex_); in Quit()
|
| H A D | hiplayer_callback_looper.h | 71 OSAL::Mutex queueMutex_ {};
|
| /ohos5.0/commonlibrary/ets_utils/js_concurrent_module/taskpool/ |
| H A D | worker.h | 64 std::lock_guard<std::mutex> lock(queueMutex_); in Enqueue()
70 std::lock_guard<std::mutex> lock(queueMutex_); in Dequeue()
220 std::mutex queueMutex_; // for sendData variable
|
| /ohos5.0/foundation/distributedhardware/distributed_camera/services/cameraservice/sourceservice/src/distributedcameramgr/dcameradata/feedingsmoother/base/ |
| H A D | ifeeding_smoother.cpp | 43 std::lock_guard<std::mutex> lock(queueMutex_); in PushData()
74 std::unique_lock<std::mutex> lock(queueMutex_); in LooperSmooth()
90 std::lock_guard<std::mutex> lock(queueMutex_); in LooperSmooth()
|
| /ohos5.0/foundation/distributedhardware/distributed_hardware_fwk/av_transport/av_trans_engine/plugin/plugins/av_trans_output/output_control/src/ |
| H A D | output_controller.cpp | 37 std::lock_guard<std::mutex> lock(queueMutex_); in PushData()
227 std::unique_lock<std::mutex> lock(queueMutex_); in LooperControl()
419 std::lock_guard<std::mutex> lock(queueMutex_); in CheckIsProcessInDynamicBalance()
557 std::lock_guard<std::mutex> lock(queueMutex_); in HandleControlResult()
566 std::lock_guard<std::mutex> lock(queueMutex_); in HandleControlResult()
800 std::lock_guard<std::mutex> lock(queueMutex_); in GetQueueSize()
|
| /ohos5.0/foundation/multimedia/media_library/frameworks/services/media_scanner/include/scanner/ |
| H A D | media_scan_executor.h | 45 std::mutex queueMutex_; variable
|
| /ohos5.0/foundation/ability/ability_lite/interfaces/kits/ability_lite/ |
| H A D | ability_event_handler.h | 90 pthread_mutex_t queueMutex_ = PTHREAD_MUTEX_INITIALIZER; variable
|
| /ohos5.0/foundation/multimedia/media_library/frameworks/services/media_cloud_enhancement/include/utils/ |
| H A D | enhancement_thread_manager.h | 49 std::mutex queueMutex_; variable
|
| /ohos5.0/foundation/multimedia/player_framework/services/engine/histreamer/transcoder/ |
| H A D | hitranscoder_callback_looper.h | 64 OHOS::Media::Mutex queueMutex_ {};
|
| /ohos5.0/foundation/multimedia/player_framework/services/engine/histreamer/player/ |
| H A D | hiplayer_callback_looper.h | 81 OHOS::Media::Mutex queueMutex_ {};
|
| /ohos5.0/base/telephony/sms_mms/services/sms/include/ |
| H A D | sms_receive_handler.h | 90 std::mutex queueMutex_; variable
|
| /ohos5.0/foundation/distributedhardware/distributed_camera/services/cameraservice/sourceservice/include/distributedcameramgr/dcameradata/feedingsmoother/base/ |
| H A D | ifeeding_smoother.h | 82 std::mutex queueMutex_; variable
|
| /ohos5.0/base/telephony/sms_mms/services/sms/ |
| H A D | sms_receive_handler.cpp | 94 std::lock_guard<std::mutex> lock(queueMutex_); in HandleReconnectEvent()
262 std::lock_guard lock(queueMutex_); in HandleReceivedSmsWithoutDataShare()
|
| /ohos5.0/base/hiviewdfx/hiview/base/include/ |
| H A D | event_loop.h | 153 std::mutex queueMutex_; variable
|
| /ohos5.0/foundation/multimedia/media_foundation/src/buffer/avbuffer_queue/include/ |
| H A D | avbuffer_queue_impl.h | 105 std::mutex queueMutex_; variable
|
| /ohos5.0/foundation/distributedhardware/distributed_hardware_fwk/av_transport/av_trans_engine/plugin/plugins/av_trans_output/output_control/include/ |
| H A D | output_controller.h | 155 std::mutex queueMutex_; variable
|