Home
last modified time | relevance | path

Searched refs:queueMutex_ (Results 1 - 25 of 29) sorted by relevance

12

/foundation/ability/ability_lite/frameworks/ability_lite/src/
H A Dability_event_handler.cpp27 (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()
/foundation/ai/intelligent_voice_framework/utils/
H A Dqueue_util.h42 std::unique_lock<std::mutex> lock(queueMutex_); in Init()
49 std::unique_lock<std::mutex> lock(queueMutex_); in Push()
64 std::unique_lock<std::mutex> lock(queueMutex_); in Push()
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_; member in OHOS::IntellVoiceUtils::QueueUtil
/foundation/CastEngine/castengine_cast_framework/service/src/session/src/utils/src/
H A Dhandler.cpp30 std::unique_lock<std::mutex> lock(this->queueMutex_); in Handler()
64 std::unique_lock<std::mutex> lock(queueMutex_); in ~Handler()
85 std::unique_lock<std::mutex> lock(queueMutex_); in SendCastMessage()
125 std::unique_lock<std::mutex> lock(queueMutex_); in RemoveMessage()
138 std::unique_lock<std::mutex> lock(queueMutex_); in RemoveCallbackAndMessages()
144 std::unique_lock<std::mutex> lock(queueMutex_); in StopSafty()
156 std::unique_lock<std::mutex> lock(queueMutex_); in IsQuiting()
/foundation/CastEngine/castengine_cast_plus_stream/src/utils/src/
H A Dhandler.cpp30 std::unique_lock<std::mutex> lock(this->queueMutex_); in Handler()
64 std::unique_lock<std::mutex> lock(queueMutex_); in ~Handler()
85 std::unique_lock<std::mutex> lock(queueMutex_); in SendCastMessage()
125 std::unique_lock<std::mutex> lock(queueMutex_); in RemoveMessage()
138 std::unique_lock<std::mutex> lock(queueMutex_); in RemoveCallbackAndMessages()
144 std::unique_lock<std::mutex> lock(queueMutex_); in StopSafty()
156 std::unique_lock<std::mutex> lock(queueMutex_); in IsQuiting()
/foundation/communication/netstack/utils/http_over_curl/include/
H A Dthread_safe_storage.h37 spinlock_mutex queueMutex_; member in OHOS::NetStack::HttpOverCurl::ThreadSafeStorage
49 std::lock_guard lock(queueMutex_); in Push()
57 std::lock_guard lock(queueMutex_); in Flush()
70 std::lock_guard lock(queueMutex_); in IsEmpty()
/foundation/multimedia/media_library/frameworks/services/media_scanner/src/scanner/
H A Dmedia_scan_executor.cpp25 lock_guard<mutex> lock(queueMutex_); in Commit()
44 std::lock_guard<std::mutex> lock(queueMutex_); in HandleScanExecution()
73 std::lock_guard<std::mutex> lock(queueMutex_); in Stop()
/foundation/multimedia/media_library/frameworks/services/media_cloud_enhancement/src/utils/
H A Denhancement_thread_manager.cpp41 lock_guard<mutex> lock(queueMutex_); in ~EnhancementThreadManager()
58 lock_guard<mutex> lock(queueMutex_); in OnProducerCallback()
73 unique_lock<mutex> lock(queueMutex_); in DealWithTasks()
/foundation/multimodalinput/input/service/event_dump/src/
H A Devent_statistic.cpp38 std::mutex EventStatistic::queueMutex_; member in OHOS::MMI::EventStatistic
84 std::lock_guard<std::mutex> lock(queueMutex_); in PushEvent()
99 std::unique_lock<std::mutex> lock(queueMutex_); in PopEvent()
138 std::lock_guard<std::mutex> lock(queueMutex_); in Dump()
/foundation/CastEngine/castengine_wifi_display/services/protocol/rtp/include/
H A Drtp_codec_ts.h56 std::mutex queueMutex_; member in OHOS::Sharing::RtpDecoderTs
92 std::mutex queueMutex_; member in OHOS::Sharing::RtpEncoderTs
/foundation/CastEngine/castengine_wifi_display/services/protocol/rtp/src/
H A Drtp_codec_ts.cpp83 std::lock_guard<std::mutex> lock(queueMutex_); in InputRtp()
183 std::unique_lock<std::mutex> lock(queueMutex_); in ReadPacket()
227 std::lock_guard<std::mutex> lock(queueMutex_); in Release()
353 std::lock_guard<std::mutex> lock(queueMutex_); in SaveFrame()
371 std::unique_lock<std::mutex> lock(queueMutex_); in ReadFrame()
394 std::unique_lock<std::mutex> lock(queueMutex_); in RemoveFrameAfterMuxing()
/foundation/multimedia/media_foundation/src/buffer/avbuffer_queue/
H A Davbuffer_queue.cpp119 std::lock_guard<std::mutex> lockGuard(queueMutex_); in SetQueueSize()
290 std::unique_lock<std::mutex> lock(queueMutex_); in RequestBuffer()
356 std::lock_guard<std::mutex> lockGuard(queueMutex_); in PushBuffer()
399 std::lock_guard<std::mutex> lockGuard(queueMutex_); in ReturnBuffer()
455 std::lock_guard<std::mutex> lockGuard(queueMutex_); in SetQueueSizeAndAttachBuffer()
534 std::lock_guard<std::mutex> lockGuard(queueMutex_); in AttachBuffer()
576 std::lock_guard<std::mutex> lockGuard(queueMutex_); in DetachBuffer()
589 std::lock_guard<std::mutex> lockGuard(queueMutex_); in AcquireBuffer()
604 std::lock_guard<std::mutex> lockGuard(queueMutex_); in ReleaseBuffer()
640 std::lock_guard<std::mutex> lockGuard(queueMutex_); in Clear()
[all...]
/foundation/multimedia/media_foundation/engine/scene/player/standard/
H A Dhiplayer_callback_looper.cpp166 OSAL::ScopedLock lock(queueMutex_); in Enqueue()
185 OSAL::ScopedLock lock(queueMutex_); in Next()
208 OSAL::ScopedLock lock(queueMutex_); in Quit()
H A Dhiplayer_callback_looper.h71 OSAL::Mutex queueMutex_ {};
/foundation/ability/ability_lite/interfaces/kits/ability_lite/
H A Dability_event_handler.h90 pthread_mutex_t queueMutex_ = PTHREAD_MUTEX_INITIALIZER; member in OHOS::AbilityEventHandler
/foundation/multimedia/media_library/frameworks/services/media_scanner/include/scanner/
H A Dmedia_scan_executor.h45 std::mutex queueMutex_; member in OHOS::Media::MediaScanExecutor
/foundation/CastEngine/castengine_cast_plus_stream/src/utils/include/
H A Dhandler.h53 std::mutex queueMutex_; member in OHOS::CastEngine::CastEngineService::Handler
/foundation/CastEngine/castengine_cast_framework/service/src/session/src/utils/include/
H A Dhandler.h53 std::mutex queueMutex_; member in OHOS::CastEngine::CastEngineService::Handler
/foundation/multimedia/media_library/frameworks/services/media_cloud_enhancement/include/utils/
H A Denhancement_thread_manager.h49 std::mutex queueMutex_; member in OHOS::Media::EnhancementThreadManager
/foundation/multimodalinput/input/service/event_dump/include/
H A Devent_statistic.h58 static std::mutex queueMutex_; member in OHOS::MMI::final
/foundation/CastEngine/castengine_cast_framework/service/src/session/src/stream/src/
H A Di_cast_stream_manager.cpp47 std::lock_guard<std::mutex> lock(queueMutex_); in ~ICastStreamManager()
65 std::unique_lock<std::mutex> lock(queueMutex_); in Handle()
106 std::lock_guard<std::mutex> lock(queueMutex_); in ProcessActionsEvent()
/foundation/CastEngine/castengine_cast_plus_stream/src/stream/src/
H A Di_cast_stream_manager.cpp47 std::lock_guard<std::mutex> lock(queueMutex_); in ~ICastStreamManager()
65 std::unique_lock<std::mutex> lock(queueMutex_); in Handle()
106 std::lock_guard<std::mutex> lock(queueMutex_); in ProcessActionsEvent()
/foundation/distributedhardware/distributed_camera/services/cameraservice/sourceservice/src/distributedcameramgr/dcameradata/feedingsmoother/base/
H A Difeeding_smoother.cpp43 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()
/foundation/multimedia/player_framework/services/engine/histreamer/transcoder/
H A Dhitranscoder_callback_looper.h64 OHOS::Media::Mutex queueMutex_ {};
/foundation/distributedhardware/distributed_hardware_fwk/av_transport/av_trans_engine/plugin/plugins/av_trans_output/output_control/src/
H A Doutput_controller.cpp37 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()
/foundation/distributedhardware/distributed_camera/services/cameraservice/sourceservice/include/distributedcameramgr/dcameradata/feedingsmoother/base/
H A Difeeding_smoother.h82 std::mutex queueMutex_; member in OHOS::DistributedHardware::IFeedingSmoother

Completed in 16 milliseconds

12