Searched refs:getDataMQ (Results 1 – 3 of 3) sorted by relevance
119 StreamContext::DataMQ* const dataMQ = mContext->getDataMQ(); in init()319 StreamContext::DataMQ* const dataMQ = mContext->getDataMQ(); in read()597 StreamContext::DataMQ* const dataMQ = mContext->getDataMQ(); in write()
658 DataMQ* getDataMQ() const { return mDataMQ.get(); } in getDataMQ() function in StreamContext868 mDataMQ(context.getDataMQ()), in StreamCommonLogic()874 StreamContext::DataMQ* getDataMQ() const { return mDataMQ; } in getDataMQ() function in StreamCommonLogic973 if (static_cast<size_t>(reply.fmqByteCount) != getDataMQ()->availableToRead()) { in cycle()977 << " != " << getDataMQ()->availableToRead(); in cycle()994 if (const size_t readCount = getDataMQ()->availableToRead(); readCount > 0) { in cycle()1062 getDataMQ()->availableToWrite() != getDataMQ()->getQuantumCount()) { in cycle()1064 << "available to write " << getDataMQ()->availableToWrite() in cycle()1065 << ", total size: " << getDataMQ()->getQuantumCount(); in cycle()
114 DataMQ* getDataMQ() const { return mDataMQ.get(); } in getDataMQ() function