Searched refs:getQuantumCount (Results 1 – 13 of 13) sorted by relevance
49 virtual size_t getQuantumCount() = 0;91 size_t getQuantumCount() override { return mQueue->getQuantumCount(); } in getQuantumCount() function133 size_t getQuantumCount() override { return mQueue->getQuantumCount(); } in getQuantumCount() function
94 size_t getQuantumCount() const;837 if (readNotification == 0 || (count > getQuantumCount())) { in writeBlocking()953 if (writeNotification == 0 || count > getQuantumCount()) { in readBlocking()1068 nMessages > getQuantumCount()) { in beginWrite()1245 size_t MessageQueueBase<MQDescriptorType, T, flavor>::getQuantumCount() const { in getQuantumCount() function
272 ASSERT_EQ(mQueue->getQuantumCount(), kNumElementsInSyncQueue); in SetUp()294 mNumMessagesMax = this->mQueue->getQuantumCount(); in SetUp()337 size_t numMessagesMax = queue->getQuantumCount(); in TYPED_TEST()674 *(writeCntr) = this->mQueue->getQuantumCount() * this->mQueue->getQuantumSize() - 1; in TYPED_TEST()
117 mNumMessagesMax = mQueue->getQuantumCount(); in SetUp()148 mNumMessagesMax = mQueue->getQuantumCount(); in SetUp()178 mNumMessagesMax = mQueue->getQuantumCount(); in SetUp()212 mNumMessagesMax = mQueue->getQuantumCount(); in SetUp()
112 if (mQueue && (mDataMaxSize <= mQueue->getQuantumCount())) { in writeQueue()599 auto quantumCount = mQueue->getQuantumCount(); in readQueue()
66 if (totalWrite * 4 < mPlaybackMQ->getQuantumCount()) { in playbackThreadLoop()
65 if (totalWrite * 4 < mPlaybackMQ->getQuantumCount()) { in playbackThreadLoop()
115 if (mQueue && (mDataMaxSize <= mQueue->getQuantumCount())) { in writeQueue()687 auto quantumCount = mQueue->getQuantumCount(); in readQueue()
290 int fmqSize = mFilterMQ->getQuantumCount(); in maySendFilterStatusCallback()
58 mBuffer.reset(new (std::nothrow) uint8_t[mDataMQ->getQuantumCount()]); in init()
61 mBuffer.reset(new (std::nothrow) uint8_t[mDataMQ->getQuantumCount()]); in init()
568 size_t eventQueueSize = mEventQueue->getQuantumCount(); in handlePendingWrites()
504 int fmqSize = mFilterMQ->getQuantumCount(); in maySendFilterStatusCallback()