Home
last modified time | relevance | path

Searched refs:DATA_QUEUE_MAX_SIZE (Results 1 - 16 of 16) sorted by relevance

/foundation/distributedhardware/distributed_audio/services/audiomanager/managersource/include/
H A Ddmic_dev.h93 static constexpr size_t DATA_QUEUE_MAX_SIZE = 10; member in OHOS::DistributedHardware::DMicDev
94 static constexpr size_t DATA_QUEUE_HALF_SIZE = DATA_QUEUE_MAX_SIZE >> 1U;
/foundation/distributedhardware/distributed_hardware_fwk/av_transport/common/include/
H A Dav_trans_constants.h82 const size_t DATA_QUEUE_MAX_SIZE = 1000; member
/foundation/distributedhardware/distributed_audio/services/audioclient/spkclient/include/
H A Ddspeaker_client.h92 constexpr static size_t DATA_QUEUE_MAX_SIZE = 12; member in OHOS::DistributedHardware::DSpeakerClient
/foundation/distributedhardware/distributed_screen/common/include/
H A Ddscreen_constants.h232 constexpr size_t DATA_QUEUE_MAX_SIZE = 1000; member
/foundation/distributedhardware/distributed_hardware_fwk/av_transport/av_trans_engine/plugin/plugins/av_trans_input/dsoftbus_input_audio/
H A Ddsoftbus_input_audio_plugin.cpp297 while (dataQueue_.size() >= DATA_QUEUE_MAX_SIZE) { in DataEnqueue()
/foundation/distributedhardware/distributed_hardware_fwk/av_transport/av_trans_engine/plugin/plugins/av_trans_output/daudio_output/
H A Ddaudio_output_plugin.cpp253 while (outputBuffer_.size() >= DATA_QUEUE_MAX_SIZE) { in PushData()
/foundation/distributedhardware/distributed_audio/services/audiomanager/test/unittest/sourcedevice/src/
H A Ddmic_dev_test.cpp398 for (size_t i = 1; i <= mic_->DATA_QUEUE_MAX_SIZE + 1; i++) { in HWTEST_F()
/foundation/distributedhardware/distributed_screen/services/screentransport/test/unittest/screensinkprocessor/src/
H A Dimage_sink_decoder_test.cpp340 for (uint32_t i = 0; i < DATA_QUEUE_MAX_SIZE + 1; i++) { in HWTEST_F()
/foundation/distributedhardware/distributed_hardware_fwk/av_transport/av_trans_engine/plugin/plugins/av_trans_output/dsoftbus_output_audio/
H A Ddsoftbus_output_audio_plugin.cpp254 while (dataQueue_.size() >= DATA_QUEUE_MAX_SIZE) { in PushData()
/foundation/distributedhardware/distributed_hardware_fwk/av_transport/av_trans_engine/plugin/plugins/av_trans_output/dsoftbus_output/
H A Ddsoftbus_output_plugin.cpp272 while (dataQueue_.size() >= DATA_QUEUE_MAX_SIZE) { in PushData()
/foundation/distributedhardware/distributed_screen/services/screentransport/screensinkprocessor/decoder/src/
H A Dimage_sink_decoder.cpp396 while (videoDataQueue_.size() >= DATA_QUEUE_MAX_SIZE) { in InputScreenData()
/foundation/distributedhardware/distributed_screen/services/screentransport/test/unittest/screensourcetrans/src/
H A Dscreen_source_trans_test.cpp574 for (uint32_t i = 0; i < DATA_QUEUE_MAX_SIZE + 1; i++) { in HWTEST_F()
/foundation/distributedhardware/distributed_hardware_fwk/av_transport/av_trans_engine/plugin/plugins/av_trans_input/dsoftbus_input/
H A Ddsoftbus_input_plugin.cpp340 while (dataQueue_.size() >= DATA_QUEUE_MAX_SIZE) { in DataEnqueue()
/foundation/distributedhardware/distributed_screen/services/screentransport/screensourcetrans/src/
H A Dscreen_source_trans.cpp390 while (dataQueue_.size() >= DATA_QUEUE_MAX_SIZE) { in OnImageProcessDone()
/foundation/distributedhardware/distributed_audio/services/audiomanager/managersource/src/
H A Ddmic_dev.cpp560 (param_.captureOpts.capturerFlags == MMAP_MODE ? lowLatencyMaxfSize_ : DATA_QUEUE_MAX_SIZE); in OnDecodeTransDataDone()
/foundation/distributedhardware/distributed_audio/services/audioclient/spkclient/src/
H A Ddspeaker_client.cpp348 while (dataQueue_.size() > DATA_QUEUE_MAX_SIZE) { in OnDecodeTransDataDone()

Completed in 11 milliseconds