Home
last modified time | relevance | path

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

/hardware/interfaces/audio/core/all-versions/vts/functional/
DAudioPrimaryHidlHalTest.h961 std::unique_ptr<CommandMQ> tempCommandMQ; in workerInit() local
972 tempCommandMQ.reset(new CommandMQ(commandMQ)); in workerInit()
988 if (!tempCommandMQ || !tempCommandMQ->isValid() || !tempDataMQ || !tempDataMQ->isValid() || in workerInit()
990 ALOGE_IF(!tempCommandMQ, "Failed to obtain command message queue for writing"); in workerInit()
991 ALOGE_IF(tempCommandMQ && !tempCommandMQ->isValid(), in workerInit()
1002 mCommandMQ = std::move(tempCommandMQ); in workerInit()
1165 std::unique_ptr<CommandMQ> tempCommandMQ; in workerInit() local
1176 tempCommandMQ.reset(new CommandMQ(commandMQ)); in workerInit()
1192 if (!tempCommandMQ || !tempCommandMQ->isValid() || !tempDataMQ || !tempDataMQ->isValid() || in workerInit()
1194 ALOGE_IF(!tempCommandMQ, "Failed to obtain command message queue for reading"); in workerInit()
[all …]
/hardware/interfaces/audio/core/all-versions/default/
DStreamIn.cpp383 std::unique_ptr<CommandMQ> tempCommandMQ(new CommandMQ(1)); in prepareForReading() local
401 if (!tempCommandMQ->isValid() || !tempDataMQ->isValid() || !tempStatusMQ->isValid()) { in prepareForReading()
402 ALOGE_IF(!tempCommandMQ->isValid(), "command MQ is invalid"); in prepareForReading()
420 sp<ReadThread>::make(&mStopReadThread, mStream, tempCommandMQ.get(), tempDataMQ.get(), in prepareForReading()
434 mCommandMQ = std::move(tempCommandMQ); in prepareForReading()
DStreamOut.cpp370 std::unique_ptr<CommandMQ> tempCommandMQ(new CommandMQ(1)); in prepareForWriting() local
387 if (!tempCommandMQ->isValid() || !tempDataMQ->isValid() || !tempStatusMQ->isValid()) { in prepareForWriting()
388 ALOGE_IF(!tempCommandMQ->isValid(), "command MQ is invalid"); in prepareForWriting()
406 sp<WriteThread>::make(&mStopWriteThread, mStream, tempCommandMQ.get(), tempDataMQ.get(), in prepareForWriting()
420 mCommandMQ = std::move(tempCommandMQ); in prepareForWriting()