Lines Matching refs:mNumMessagesMax
84 mNumMessagesMax = mQueue->getQuantumCount(); in SetUp()
92 size_t mNumMessagesMax = 0; member in SynchronizedReadWriteClient
112 mNumMessagesMax = mQueue->getQuantumCount(); in SetUp()
117 size_t mNumMessagesMax = 0; member in UnsynchronizedWriteClient
249 ret = mQueue->writeBlocking(data, mNumMessagesMax, in TEST_F()
263 std::vector<uint16_t> data(mNumMessagesMax); in TEST_F()
283 ret = mQueue->writeBlocking(&data[0], mNumMessagesMax, 5000000000 /* timeOutNanos */); in TEST_F()
313 ret = mQueue->writeBlocking(data, mNumMessagesMax, in TEST_F()
347 ret = mQueue->writeBlocking(data, mNumMessagesMax, in TEST_F()
378 ret = mQueue->writeBlocking(data, mNumMessagesMax, in TEST_F()
418 ASSERT_LE(dataLen, mNumMessagesMax); in TEST_F()
433 ASSERT_LE(dataLen, mNumMessagesMax); in TEST_F()
463 ASSERT_LE(dataLen, mNumMessagesMax); in TEST_F()
480 ASSERT_LE(dataLen, mNumMessagesMax); in TEST_F()
518 ASSERT_LE(numMessages, mNumMessagesMax); in TEST_F()
533 std::vector<uint16_t> data(mNumMessagesMax); in TEST_F()
534 initData(&data[0], mNumMessagesMax); in TEST_F()
535 ASSERT_TRUE(mQueue->write(&data[0], mNumMessagesMax)); in TEST_F()
538 bool ret = mService->requestReadFmqSync(mNumMessagesMax); in TEST_F()
548 bool ret = mService->requestWriteFmqSync(mNumMessagesMax); in TEST_F()
550 std::vector<uint16_t> readData(mNumMessagesMax); in TEST_F()
551 ASSERT_TRUE(mQueue->read(&readData[0], mNumMessagesMax)); in TEST_F()
552 ASSERT_TRUE(verifyData(&readData[0], mNumMessagesMax)); in TEST_F()
563 ASSERT_GT(numMessages, mNumMessagesMax); in TEST_F()
580 std::vector<uint16_t> data(mNumMessagesMax); in TEST_F()
581 initData(&data[0], mNumMessagesMax); in TEST_F()
582 ASSERT_TRUE(mQueue->write(&data[0], mNumMessagesMax)); in TEST_F()
586 bool ret = mService->requestReadFmqSync(mNumMessagesMax); in TEST_F()
598 ASSERT_LE(numMessages, mNumMessagesMax); in TEST_F()
619 ASSERT_LE(numMessages, mNumMessagesMax); in TEST_F()
637 size_t numMessages = mNumMessagesMax / 2; in TEST_F()
638 std::vector<uint16_t> data(mNumMessagesMax); in TEST_F()
639 initData(&data[0], mNumMessagesMax); in TEST_F()
643 ASSERT_TRUE(mQueue->write(&data[0], mNumMessagesMax)); in TEST_F()
644 ret = mService->requestReadFmqSync(mNumMessagesMax); in TEST_F()
657 size_t numMessages = mNumMessagesMax / 2; in TEST_F()
658 std::vector<uint16_t> data(mNumMessagesMax); in TEST_F()
659 initData(&data[0], mNumMessagesMax); in TEST_F()
670 ASSERT_TRUE(mQueue->beginWrite(mNumMessagesMax, &tx)); in TEST_F()
672 ASSERT_EQ(tx.getFirstRegion().getLength() + tx.getSecondRegion().getLength(), mNumMessagesMax); in TEST_F()
674 for (size_t i = 0; i < mNumMessagesMax; i++) { in TEST_F()
679 ASSERT_TRUE(mQueue->commitWrite(mNumMessagesMax)); in TEST_F()
681 ret = mService->requestReadFmqSync(mNumMessagesMax); in TEST_F()
693 ASSERT_LE(dataLen, mNumMessagesMax); in TEST_F()
707 ASSERT_LE(dataLen, mNumMessagesMax); in TEST_F()
721 ASSERT_LE(numMessages, mNumMessagesMax); in TEST_F()
736 std::vector<uint16_t> data(mNumMessagesMax); in TEST_F()
737 initData(&data[0], mNumMessagesMax); in TEST_F()
738 ASSERT_TRUE(mQueue->write(&data[0], mNumMessagesMax)); in TEST_F()
741 bool ret = mService->requestReadFmqUnsync(mNumMessagesMax); in TEST_F()
751 bool ret = mService->requestWriteFmqUnsync(mNumMessagesMax); in TEST_F()
753 std::vector<uint16_t> data(mNumMessagesMax); in TEST_F()
754 ASSERT_TRUE(mQueue->read(&data[0], mNumMessagesMax)); in TEST_F()
755 ASSERT_TRUE(verifyData(&data[0], mNumMessagesMax)); in TEST_F()
765 const size_t numMessages = mNumMessagesMax + 1; in TEST_F()
783 std::vector<uint16_t> data(mNumMessagesMax); in TEST_F()
784 initData(&data[0], mNumMessagesMax); in TEST_F()
785 ASSERT_TRUE(mQueue->write(&data[0], mNumMessagesMax)); in TEST_F()
789 bool ret = mService->requestReadFmqUnsync(mNumMessagesMax); in TEST_F()
791 ASSERT_TRUE(mQueue->write(&data[0], mNumMessagesMax)); in TEST_F()
793 ret = mService->requestReadFmqUnsync(mNumMessagesMax); in TEST_F()
805 ASSERT_LE(numMessages, mNumMessagesMax); in TEST_F()
826 ASSERT_LE(numMessages, mNumMessagesMax); in TEST_F()
843 size_t numMessages = mNumMessagesMax / 2; in TEST_F()
844 std::vector<uint16_t> data(mNumMessagesMax); in TEST_F()
845 initData(&data[0], mNumMessagesMax); in TEST_F()
849 ASSERT_TRUE(mQueue->write(&data[0], mNumMessagesMax)); in TEST_F()
850 ret = mService->requestReadFmqUnsync(mNumMessagesMax); in TEST_F()
866 ASSERT_LE(dataLen, mNumMessagesMax); in TEST_F()
898 bool ret = mService->requestWriteFmqUnsync(mNumMessagesMax); in TEST_F()
906 std::vector<uint16_t> readData(mNumMessagesMax); in TEST_F()
907 ASSERT_FALSE(mQueue2->read(&readData[0], mNumMessagesMax)); in TEST_F()
911 std::vector<uint16_t> readData(mNumMessagesMax); in TEST_F()
912 ASSERT_FALSE(mQueue->read(&readData[0], mNumMessagesMax)); in TEST_F()