Searched refs:mDataMQ (Results 1 – 4 of 4) sorted by relevance
| /device/generic/goldfish/audio/ |
| D | stream_in.cpp | 53 , mDataMQ(bufferSize, true /* EventFlag */) { in ReadThread()
58 if (!mDataMQ.isValid()) { in ReadThread()
70 status = EventFlag::createEventFlag(mDataMQ.getEventFlagWord(), &rawEfGroup); in ReadThread()
120 mBuffer.reset(new uint8_t[mDataMQ.getQuantumCount()]); in threadLoop()
169 const size_t bytesToRead = std::min(mDataMQ.availableToWrite(), in doRead()
176 if (!mDataMQ.write(&mBuffer[0], read)) { in doRead()
212 DataMQ mDataMQ; member
416 *(t->mDataMQ.getDesc()), in prepareForReading()
|
| D | stream_out.cpp | 56 , mDataMQ(mqBufferSize, true /* EventFlag */) { in WriteThread()
61 if (!mDataMQ.isValid()) { in WriteThread()
73 status = EventFlag::createEventFlag(mDataMQ.getEventFlagWord(), &rawEfGroup); in WriteThread()
122 mBuffer.reset(new uint8_t[mDataMQ.getQuantumCount()]); in threadLoop()
177 const size_t availToRead = mDataMQ.availableToRead(); in doWrite()
179 if (mDataMQ.read(&mBuffer[0], availToRead)) { in doWrite()
243 DataMQ mDataMQ; member
450 *(t->mDataMQ.getDesc()), in prepareForWriting()
|
| /device/google/atv/audio_proxy/ |
| D | StreamOutImpl.cpp | 64 StreamOutImpl::DataMQ* const mDataMQ; member in audio_proxy::CPP_VERSION::__anon4f1d4ef80111::WriteThread
79 mDataMQ(dataMQ), in WriteThread()
82 mBuffer(new uint8_t[mDataMQ->getQuantumCount()]) {} in WriteThread()
87 const size_t availToRead = mDataMQ->availableToRead(); in doWrite()
92 if (mDataMQ->read(&mBuffer[0], availToRead)) { in doWrite()
319 if (mDataMQ) { in prepareForWriting()
374 mDataMQ = std::move(dataMQ); in prepareForWriting()
380 _hidl_cb(Result::OK, *mCommandMQ->getDesc(), *mDataMQ->getDesc(), in prepareForWriting()
|
| D | StreamOutImpl.h | 120 std::unique_ptr<DataMQ> mDataMQ; variable
|