Home
last modified time | relevance | path

Searched refs:dataQueueMtx_ (Results 1 – 16 of 16) sorted by relevance

/ohos5.0/foundation/distributedhardware/distributed_hardware_fwk/av_transport/av_trans_engine/plugin/plugins/av_trans_input/dsoftbus_input_audio/
H A Ddsoftbus_input_audio_plugin.cpp296 std::lock_guard<std::mutex> lock(dataQueueMtx_); in DataEnqueue()
314 std::unique_lock<std::mutex> lock(dataQueueMtx_); in HandleData()
334 std::lock_guard<std::mutex> lock(dataQueueMtx_); in DataQueueClear()
H A Ddsoftbus_input_audio_plugin.h96 std::mutex dataQueueMtx_; variable
/ohos5.0/foundation/distributedhardware/distributed_hardware_fwk/av_transport/av_trans_engine/plugin/plugins/av_trans_output/daudio_output/
H A Ddaudio_output_plugin.cpp252 std::lock_guard<std::mutex> lock(dataQueueMtx_); in PushData()
271 std::unique_lock<std::mutex> lock(dataQueueMtx_); in HandleData()
323 std::lock_guard<std::mutex> lock(dataQueueMtx_); in DataQueueClear()
H A Ddaudio_output_plugin.h87 std::mutex dataQueueMtx_; variable
/ohos5.0/foundation/distributedhardware/distributed_hardware_fwk/av_transport/av_trans_engine/plugin/plugins/av_trans_input/dsoftbus_input/
H A Ddsoftbus_input_plugin.cpp339 std::lock_guard<std::mutex> lock(dataQueueMtx_); in DataEnqueue()
357 std::unique_lock<std::mutex> lock(dataQueueMtx_); in HandleData()
377 std::lock_guard<std::mutex> lock(dataQueueMtx_); in DataQueueClear()
H A Ddsoftbus_input_plugin.h104 std::mutex dataQueueMtx_; variable
/ohos5.0/foundation/distributedhardware/distributed_hardware_fwk/av_transport/av_trans_engine/plugin/plugins/av_trans_output/dsoftbus_output/
H A Ddsoftbus_output_plugin.cpp252 std::lock_guard<std::mutex> lock(dataQueueMtx_); in PushData()
286 std::unique_lock<std::mutex> lock(dataQueueMtx_); in FeedChannelData()
360 std::lock_guard<std::mutex> lock(dataQueueMtx_); in DataQueueClear()
H A Ddsoftbus_output_plugin.h101 std::mutex dataQueueMtx_; variable
/ohos5.0/foundation/distributedhardware/distributed_hardware_fwk/av_transport/av_trans_engine/plugin/plugins/av_trans_output/dsoftbus_output_audio/
H A Ddsoftbus_output_audio_plugin.cpp249 std::lock_guard<std::mutex> lock(dataQueueMtx_); in PushData()
275 std::unique_lock<std::mutex> lock(dataQueueMtx_); in FeedChannelData()
349 std::lock_guard<std::mutex> lock(dataQueueMtx_); in DataQueueClear()
H A Ddsoftbus_output_audio_plugin.h95 std::mutex dataQueueMtx_; variable
/ohos5.0/foundation/distributedhardware/distributed_audio/services/audioclient/spkclient/src/
H A Ddspeaker_client.cpp123 std::unique_lock<std::mutex> spkLck(dataQueueMtx_); in OnWriteData()
279 std::unique_lock<std::mutex> spkLck(dataQueueMtx_); in PlayThreadRunning()
319 std::lock_guard<std::mutex> lock(dataQueueMtx_); in FillJitterQueue()
332 std::lock_guard<std::mutex> lock(dataQueueMtx_); in FlushJitterQueue()
347 std::lock_guard<std::mutex> lock(dataQueueMtx_); in OnDecodeTransDataDone()
/ohos5.0/foundation/distributedhardware/distributed_audio/services/audiomanager/managersource/src/
H A Ddmic_dev.cpp356 std::lock_guard<std::mutex> lock(dataQueueMtx_); in ReadStreamData()
446 std::lock_guard<std::mutex> lock(dataQueueMtx_); in EnqueueThread()
482 std::lock_guard<std::mutex> lock(dataQueueMtx_); in FillJitterQueue()
557 std::lock_guard<std::mutex> lock(dataQueueMtx_); in OnDecodeTransDataDone()
/ohos5.0/foundation/distributedhardware/distributed_screen/services/screentransport/screensourcetrans/src/
H A Dscreen_source_trans.cpp94 std::lock_guard<std::mutex> lck(dataQueueMtx_); in Release()
388 std::lock_guard<std::mutex> lck(dataQueueMtx_); in OnImageProcessDone()
417 std::unique_lock<std::mutex> lock(dataQueueMtx_); in FeedChannelData()
/ohos5.0/foundation/distributedhardware/distributed_screen/services/screentransport/screensourcetrans/include/
H A Dscreen_source_trans.h73 std::mutex dataQueueMtx_; variable
/ohos5.0/foundation/distributedhardware/distributed_audio/services/audioclient/spkclient/include/
H A Ddspeaker_client.h104 std::mutex dataQueueMtx_; variable
/ohos5.0/foundation/distributedhardware/distributed_audio/services/audiomanager/managersource/include/
H A Ddmic_dev.h106 std::mutex dataQueueMtx_; variable