Home
last modified time | relevance | path

Searched refs:mDataMQ (Results 1 – 10 of 10) sorted by relevance

/device/google/atv/audio_proxy/
DOutputStreamImpl.cpp61 OutputStreamImpl::DataMQ* const mDataMQ; member in audio_proxy::__anon31df340b0111::WriteThread
74 mDataMQ(dataMQ), in WriteThread()
77 mBuffer(new int8_t[mDataMQ->getQuantumCount()]) {} in WriteThread()
82 const size_t availToRead = mDataMQ->availableToRead(); in doWrite()
87 if (!mDataMQ->read(&mBuffer[0], availToRead)) { in doWrite()
166 if (mDataMQ) { in prepareForWriting()
220 mDataMQ = std::move(dataMQ); in prepareForWriting()
225 *dataMQDesc = mDataMQ->dupeDesc(); in prepareForWriting()
DOutputStreamImpl.h77 std::unique_ptr<DataMQ> mDataMQ; variable
/device/generic/goldfish/audio/
Dstream_in.cpp56 , mDataMQ(bufferSize, true /* EventFlag */) { in ReadThread()
61 if (!mDataMQ.isValid()) { in ReadThread()
73 status = EventFlag::createEventFlag(mDataMQ.getEventFlagWord(), &rawEfGroup); in ReadThread()
121 mSource = DevicePortSource::create(mDataMQ.getQuantumCount(), in threadLoop()
186 const size_t bytesToRead = std::min(mDataMQ.availableToWrite(), in doRead()
189 MQWriter writer(mDataMQ); in doRead()
215 DataMQ mDataMQ; member
385 *(t->mDataMQ.getDesc()), in prepareForReading()
Dstream_out.cpp59 , mDataMQ(mqBufferSize, true /* EventFlag */) { in WriteThread()
64 if (!mDataMQ.isValid()) { in WriteThread()
76 status = EventFlag::createEventFlag(mDataMQ.getEventFlagWord(), &rawEfGroup); in WriteThread()
120 mCommandMQ.getDesc(), mDataMQ.getDesc(), mStatusMQ.getDesc()); in getDescriptors()
145 auto sink = DevicePortSink::create(mDataMQ.getQuantumCount(), in threadLoop()
216 MQReader reader(mDataMQ); in doWrite()
217 mSink->write(mStream->getEffectiveVolume(), mDataMQ.availableToRead(), reader); in doWrite()
263 DataMQ mDataMQ; member in android::hardware::audio::CPP_VERSION::implementation::__anond3c31e630111::WriteThread
/device/google/atv/audio_proxy/service/
DRemoteBusOutputStream.cpp72 return mDataMQ->availableToWrite(); in availableToWrite()
79 DCHECK(mDataMQ); in writeRingBuffer()
84 if (!mDataMQ->beginWrite(firstLength + secondLength, &tx)) { in writeRingBuffer()
96 if (!mDataMQ->commitWrite(firstLength + secondLength)) { in writeRingBuffer()
155 mDataMQ = std::move(dataMQ); in prepareForWritingImpl()
DWriteThread.cpp34 mDataMQ(dataMQ), in WriteThread()
72 const size_t availToRead = mDataMQ->availableToRead(); in doWrite()
79 if (mDataMQ->beginRead(availToRead, &tx)) { in doWrite()
94 mDataMQ->commitRead(writeStatus.written); in doWrite()
DStreamOutImpl.cpp263 if (mDataMQ) { in prepareForWriting()
325 mDataMQ = std::move(dataMQ); in prepareForWriting()
337 _hidl_cb(Result::OK, *mCommandMQ->getDesc(), *mDataMQ->getDesc(), in prepareForWriting()
DRemoteBusOutputStream.h70 std::unique_ptr<DataMQ> mDataMQ; variable
DWriteThread.h95 DataMQ* const mDataMQ; variable
DStreamOutImpl.h177 std::unique_ptr<DataMQ> mDataMQ; variable