Home
last modified time | relevance | path

Searched refs:tempCommandMQ (Results 1 – 4 of 4) sorted by relevance

/aosp12/frameworks/av/media/libaudiohal/impl/
H A DStreamHalHidl.cpp481 std::unique_ptr<CommandMQ> tempCommandMQ; in prepareForWriting() local
495 tempCommandMQ.reset(new CommandMQ(commandMQ)); in prepareForWriting()
512 if (!tempCommandMQ || !tempCommandMQ->isValid() || in prepareForWriting()
516 ALOGE_IF(!tempCommandMQ, "Failed to obtain command message queue for writing"); in prepareForWriting()
517 ALOGE_IF(tempCommandMQ && !tempCommandMQ->isValid(), in prepareForWriting()
534 mCommandMQ = std::move(tempCommandMQ); in prepareForWriting()
913 std::unique_ptr<CommandMQ> tempCommandMQ; in prepareForReading() local
927 tempCommandMQ.reset(new CommandMQ(commandMQ)); in prepareForReading()
944 if (!tempCommandMQ || !tempCommandMQ->isValid() || in prepareForReading()
949 ALOGE_IF(tempCommandMQ && !tempCommandMQ->isValid(), in prepareForReading()
[all …]
/aosp12/hardware/interfaces/audio/core/all-versions/vts/functional/
H A DAudioPrimaryHidlHalTest.h907 std::unique_ptr<CommandMQ> tempCommandMQ; in workerInit() local
918 tempCommandMQ.reset(new CommandMQ(commandMQ)); in workerInit()
934 if (!tempCommandMQ || !tempCommandMQ->isValid() || !tempDataMQ || !tempDataMQ->isValid() || in workerInit()
936 ALOGE_IF(!tempCommandMQ, "Failed to obtain command message queue for writing"); in workerInit()
937 ALOGE_IF(tempCommandMQ && !tempCommandMQ->isValid(), in workerInit()
948 mCommandMQ = std::move(tempCommandMQ); in workerInit()
1092 std::unique_ptr<CommandMQ> tempCommandMQ; in workerInit() local
1103 tempCommandMQ.reset(new CommandMQ(commandMQ)); in workerInit()
1119 if (!tempCommandMQ || !tempCommandMQ->isValid() || !tempDataMQ || !tempDataMQ->isValid() || in workerInit()
1122 ALOGE_IF(tempCommandMQ && !tempCommandMQ->isValid(), in workerInit()
[all …]
/aosp12/hardware/interfaces/audio/core/all-versions/default/
H A DStreamIn.cpp379 std::unique_ptr<CommandMQ> tempCommandMQ(new CommandMQ(1)); in prepareForReading() local
397 if (!tempCommandMQ->isValid() || !tempDataMQ->isValid() || !tempStatusMQ->isValid()) { in prepareForReading()
398 ALOGE_IF(!tempCommandMQ->isValid(), "command MQ is invalid"); in prepareForReading()
416 sp<ReadThread>::make(&mStopReadThread, mStream, tempCommandMQ.get(), tempDataMQ.get(), in prepareForReading()
430 mCommandMQ = std::move(tempCommandMQ); in prepareForReading()
H A DStreamOut.cpp366 std::unique_ptr<CommandMQ> tempCommandMQ(new CommandMQ(1)); in prepareForWriting() local
383 if (!tempCommandMQ->isValid() || !tempDataMQ->isValid() || !tempStatusMQ->isValid()) { in prepareForWriting()
384 ALOGE_IF(!tempCommandMQ->isValid(), "command MQ is invalid"); in prepareForWriting()
402 sp<WriteThread>::make(&mStopWriteThread, mStream, tempCommandMQ.get(), tempDataMQ.get(), in prepareForWriting()
416 mCommandMQ = std::move(tempCommandMQ); in prepareForWriting()