diff --git a/services/audiomanager/managersource/include/dmic_dev.h b/services/audiomanager/managersource/include/dmic_dev.h index 17b6ca9086a06b9e19554077d46b81f0578fcc09..0bfd1a84d19f94e9618cfef69e92197d0aac9cb9 100644 --- a/services/audiomanager/managersource/include/dmic_dev.h +++ b/services/audiomanager/managersource/include/dmic_dev.h @@ -101,8 +101,6 @@ private: const std::string DUMP_DAUDIO_MIC_READ_FROM_BUF_NAME = "dump_source_mic_read_from_trans.pcm"; const std::string DUMP_DAUDIO_LOWLATENCY_MIC_FROM_BUF_NAME = "dump_source_mic_write_to_ashmem.pcm"; const int32_t ASHMEM_MAX_LEN = 2 * 4096; - static constexpr size_t NOTIFY_WAIT_FRAMES = 5; - static constexpr uint32_t NOTIFY_WAIT_TIME_US = 20000; std::weak_ptr audioEventCallback_; std::mutex dataQueueMtx_; diff --git a/services/audiomanager/managersource/src/dmic_dev.cpp b/services/audiomanager/managersource/src/dmic_dev.cpp index fb4889b0a1713a7c7984ffca099f5874e2b55e9a..1dd07fd93c4bafbdc4b124fb762c7115f11afd72 100644 --- a/services/audiomanager/managersource/src/dmic_dev.cpp +++ b/services/audiomanager/managersource/src/dmic_dev.cpp @@ -212,13 +212,6 @@ int32_t DMicDev::NotifyEvent(const int32_t streamId, const AudioEvent &event) switch (event.type) { case AudioEventType::AUDIO_START: curStatus_ = AudioStatus::STATUS_START; - while (isTransReady_.load()) { - std::lock_guard lock(dataQueueMtx_); - if (dataQueue_.size() >= NOTIFY_WAIT_FRAMES) { - break; - } - usleep(NOTIFY_WAIT_TIME_US); - } isExistedEmpty_.store(false); break; case AudioEventType::AUDIO_STOP: diff --git a/services/audiomanager/test/unittest/sourcedevice/src/dmic_dev_test.cpp b/services/audiomanager/test/unittest/sourcedevice/src/dmic_dev_test.cpp index 55c3abfdc93a0369363c8c6cfbea2a8670467a11..5e333186ffd2ec8453574f7230b514c97da5b924 100644 --- a/services/audiomanager/test/unittest/sourcedevice/src/dmic_dev_test.cpp +++ b/services/audiomanager/test/unittest/sourcedevice/src/dmic_dev_test.cpp @@ -20,6 +20,7 @@ using namespace testing::ext; namespace OHOS { namespace DistributedHardware { constexpr int32_t DH_ID = 1; +constexpr size_t NOTIFY_WAIT_FRAMES = 5; constexpr int32_t DH_ID_MIC = 134217728; const std::string DEV_ID = "Test_Dev_Id"; const std::string CAP = "Test_Capability"; @@ -176,7 +177,7 @@ HWTEST_F(DMicDevTest, NotifyEvent_001, TestSize.Level1) EXPECT_EQ(DH_SUCCESS, mic_->NotifyEvent(streamId_, event)); mic_->isTransReady_ = true; - for (int32_t i = 0; i < DMicDev::NOTIFY_WAIT_FRAMES; i++) { + for (int32_t i = 0; i < NOTIFY_WAIT_FRAMES; i++) { size_t size = 4096; auto audioData = std::make_shared(size); mic_->dataQueue_.push(audioData);