Searched refs:mDataMQ (Results 1 – 2 of 2) sorted by relevance
448 if (bytes == 0 && !mDataMQ) { in write()455 if (!mDataMQ) { in write()491 size_t availableToWrite = mDataMQ->availableToWrite(); in callWriterThread()497 if (!mDataMQ->write(data, dataSize)) { in callWriterThread()583 mDataMQ = std::move(tempDataMQ); in prepareForWriting()1019 if (bytes == 0 && !mDataMQ) { in read()1025 if (!mDataMQ && (status = prepareForReading(bytes)) != OK) { in read()1034 const size_t availToRead = mDataMQ->availableToRead(); in read()1035 if (!mDataMQ->read(static_cast<uint8_t*>(buffer), std::min(bytes, availToRead))) { in read()1136 mDataMQ = std::move(tempDataMQ); in prepareForReading()
220 std::unique_ptr<DataMQ> mDataMQ; variable276 std::unique_ptr<DataMQ> mDataMQ; variable