Lines Matching refs:mDvrMQ
50 *out_queue = mDvrMQ->dupeDesc(); in getQueueDesc()
175 mDvrMQ = std::move(tmpDvrMQ); in createDvrMQ()
177 if (EventFlag::createEventFlag(mDvrMQ->getEventFlagWord(), &mDvrEventFlag) != ::android::OK) { in createDvrMQ()
241 int availableToRead = mDvrMQ->availableToRead(); in maySendIptvPlaybackStatusCallback()
242 int availableToWrite = mDvrMQ->availableToWrite(); in maySendIptvPlaybackStatusCallback()
260 int availableToRead = mDvrMQ->availableToRead(); in maySendPlaybackStatusCallback()
261 int availableToWrite = mDvrMQ->availableToWrite(); in maySendPlaybackStatusCallback()
289 size_t size = mDvrMQ->availableToRead(); in readPlaybackFMQ()
295 if (!mDvrMQ->read(dataOutputBuffer.data(), playbackPacketSize)) { in readPlaybackFMQ()
316 int size = mDvrMQ->availableToRead(); in processEsDataOnPlayback()
319 if (!mDvrMQ->read(dataOutputBuffer.data(), size)) { in processEsDataOnPlayback()
472 ALOGI("availableToWrite before: %zu", mDvrMQ->availableToWrite()); in writePlaybackFMQ()
473 if (mDvrMQ->write((int8_t*)buf, size)) { in writePlaybackFMQ()
475 ALOGI("availableToWrite: %zu", mDvrMQ->availableToWrite()); in writePlaybackFMQ()
489 if (mDvrMQ->write(data.data(), data.size())) { in writeRecordFMQ()
501 int availableToRead = mDvrMQ->availableToRead(); in maySendRecordStatusCallback()
502 int availableToWrite = mDvrMQ->availableToWrite(); in maySendRecordStatusCallback()