Searched refs:mDataMQ (Results 1 – 3 of 3) sorted by relevance
61 mDataMQ(maybeCreateDataMQ(descriptor)), in StreamContextAidl()70 mDataMQ(std::move(other.mDataMQ)), in StreamContextAidl()79 mDataMQ = std::move(other.mDataMQ);89 (mDataMQ == nullptr || ( in isValid()90 mDataMQ->isValid() && in isValid()91 mDataMQ->getQuantumCount() * mDataMQ->getQuantumSize() >= in isValid()102 DataMQ* getDataMQ() const { return mDataMQ.get(); } in getDataMQ()136 std::unique_ptr<DataMQ> mDataMQ; variable
453 if (bytes == 0 && !mDataMQ) { in write()460 if (!mDataMQ) { in write()496 size_t availableToWrite = mDataMQ->availableToWrite(); in callWriterThread()502 if (!mDataMQ->write(data, dataSize)) { in callWriterThread()588 mDataMQ = std::move(tempDataMQ); in prepareForWriting()1057 if (bytes == 0 && !mDataMQ) { in read()1063 if (!mDataMQ && (status = prepareForReading(bytes)) != OK) { in read()1072 const size_t availToRead = mDataMQ->availableToRead(); in read()1073 if (!mDataMQ->read(static_cast<uint8_t*>(buffer), std::min(bytes, availToRead))) { in read()1174 mDataMQ = std::move(tempDataMQ); in prepareForReading()
229 std::unique_ptr<DataMQ> mDataMQ; variable290 std::unique_ptr<DataMQ> mDataMQ; variable