Lines Matching refs:mNumMessagesMax
117 mNumMessagesMax = mQueue->getQuantumCount(); in SetUp()
118 ASSERT_EQ(kNumElementsInQueue, mNumMessagesMax); in SetUp()
122 size_t mNumMessagesMax = 0; member in SynchronizedReadWrites
148 mNumMessagesMax = mQueue->getQuantumCount(); in SetUp()
149 ASSERT_EQ(kNumElementsInQueue, mNumMessagesMax); in SetUp()
153 size_t mNumMessagesMax = 0; member in UnsynchronizedWriteTest
178 mNumMessagesMax = mQueue->getQuantumCount(); in SetUp()
179 ASSERT_EQ(kNumElementsInQueue, mNumMessagesMax); in SetUp()
188 size_t mNumMessagesMax = 0; member in BlockingReadWrites
212 mNumMessagesMax = mQueue->getQuantumCount(); in SetUp()
213 ASSERT_EQ(kNumElementsInQueue, mNumMessagesMax); in SetUp()
223 size_t mNumMessagesMax = 0; member in QueueSizeOdd
659 ASSERT_LE(dataLen, this->mNumMessagesMax); in TYPED_TEST()
676 ASSERT_LE(dataLen, this->mNumMessagesMax); in TYPED_TEST()
705 ASSERT_LE(dataLen, this->mNumMessagesMax); in TYPED_TEST()
748 ASSERT_LE(dataLen, this->mNumMessagesMax); in TYPED_TEST()
760 ASSERT_LE(dataLen, this->mNumMessagesMax); in TYPED_TEST()
778 std::vector<uint8_t> data(this->mNumMessagesMax); in TYPED_TEST()
780 initData(&data[0], this->mNumMessagesMax); in TYPED_TEST()
781 ASSERT_TRUE(this->mQueue->write(&data[0], this->mNumMessagesMax)); in TYPED_TEST()
785 std::vector<uint8_t> readData(this->mNumMessagesMax); in TYPED_TEST()
786 ASSERT_TRUE(this->mQueue->read(&readData[0], this->mNumMessagesMax)); in TYPED_TEST()
796 std::vector<uint8_t> data(this->mNumMessagesMax); in TYPED_TEST()
798 initData(&data[0], this->mNumMessagesMax); in TYPED_TEST()
799 ASSERT_TRUE(this->mQueue->write(&data[0], this->mNumMessagesMax)); in TYPED_TEST()
818 std::vector<uint8_t> data(this->mNumMessagesMax); in TYPED_TEST()
819 initData(&data[0], this->mNumMessagesMax); in TYPED_TEST()
820 ASSERT_TRUE(this->mQueue->write(&data[0], this->mNumMessagesMax)); in TYPED_TEST()
821 std::vector<uint8_t> readData(this->mNumMessagesMax); in TYPED_TEST()
822 ASSERT_TRUE(this->mQueue->read(&readData[0], this->mNumMessagesMax)); in TYPED_TEST()
834 ASSERT_GT(dataLen, this->mNumMessagesMax); in TYPED_TEST()
839 std::vector<uint8_t> readData(this->mNumMessagesMax); in TYPED_TEST()
840 ASSERT_FALSE(this->mQueue->read(&readData[0], this->mNumMessagesMax)); in TYPED_TEST()
851 std::vector<uint8_t> data(this->mNumMessagesMax); in TYPED_TEST()
852 initData(&data[0], this->mNumMessagesMax); in TYPED_TEST()
853 ASSERT_TRUE(this->mQueue->write(&data[0], this->mNumMessagesMax)); in TYPED_TEST()
855 std::vector<uint8_t> readData(this->mNumMessagesMax); in TYPED_TEST()
856 ASSERT_TRUE(this->mQueue->read(&readData[0], this->mNumMessagesMax)); in TYPED_TEST()
868 ASSERT_GT(dataLen, this->mNumMessagesMax); in TYPED_TEST()
887 ASSERT_LE(dataLen, this->mNumMessagesMax); in TYPED_TEST()
906 ASSERT_LE(dataLen, this->mNumMessagesMax); in TYPED_TEST()
925 size_t numMessages = this->mNumMessagesMax - 1; in TYPED_TEST()
926 std::vector<uint8_t> data(this->mNumMessagesMax); in TYPED_TEST()
927 std::vector<uint8_t> readData(this->mNumMessagesMax); in TYPED_TEST()
928 initData(&data[0], this->mNumMessagesMax); in TYPED_TEST()
931 ASSERT_TRUE(this->mQueue->write(&data[0], this->mNumMessagesMax)); in TYPED_TEST()
932 ASSERT_TRUE(this->mQueue->read(&readData[0], this->mNumMessagesMax)); in TYPED_TEST()
945 size_t dataLen = this->mNumMessagesMax - 1; in TYPED_TEST()
946 std::vector<uint8_t> data(this->mNumMessagesMax); in TYPED_TEST()
947 std::vector<uint8_t> readData(this->mNumMessagesMax); in TYPED_TEST()
948 initData(&data[0], this->mNumMessagesMax); in TYPED_TEST()
956 ASSERT_TRUE(this->mQueue->beginWrite(this->mNumMessagesMax, &tx)); in TYPED_TEST()
961 ASSERT_EQ(first.getLength() + second.getLength(), this->mNumMessagesMax); in TYPED_TEST()
963 ASSERT_TRUE(tx.copyTo(&data[0], 0 /* startIdx */, this->mNumMessagesMax)); in TYPED_TEST()
965 ASSERT_TRUE(this->mQueue->commitWrite(this->mNumMessagesMax)); in TYPED_TEST()
967 ASSERT_TRUE(this->mQueue->beginRead(this->mNumMessagesMax, &tx)); in TYPED_TEST()
972 ASSERT_EQ(first.getLength() + second.getLength(), this->mNumMessagesMax); in TYPED_TEST()
974 ASSERT_TRUE(tx.copyFrom(&readData[0], 0 /* startIdx */, this->mNumMessagesMax)); in TYPED_TEST()
975 ASSERT_TRUE(this->mQueue->commitRead(this->mNumMessagesMax)); in TYPED_TEST()
985 ASSERT_LE(dataLen, this->mNumMessagesMax); in TYPED_TEST()
1001 ASSERT_TRUE(dataLen < this->mNumMessagesMax); in TYPED_TEST()
1012 std::vector<uint8_t> data(this->mNumMessagesMax); in TYPED_TEST()
1014 initData(&data[0], this->mNumMessagesMax); in TYPED_TEST()
1015 ASSERT_TRUE(this->mQueue->write(&data[0], this->mNumMessagesMax)); in TYPED_TEST()
1019 std::vector<uint8_t> readData(this->mNumMessagesMax); in TYPED_TEST()
1020 ASSERT_FALSE(this->mQueue->read(&readData[0], this->mNumMessagesMax)); in TYPED_TEST()
1030 std::vector<uint8_t> data(this->mNumMessagesMax); in TYPED_TEST()
1031 ASSERT_TRUE(this->mQueue->write(&data[0], this->mNumMessagesMax)); in TYPED_TEST()
1042 std::vector<uint8_t> readData(this->mNumMessagesMax); in TYPED_TEST()
1043 ASSERT_FALSE(this->mQueue->read(&readData[0], this->mNumMessagesMax)); in TYPED_TEST()
1052 std::vector<uint8_t> data(this->mNumMessagesMax); in TYPED_TEST()
1053 initData(&data[0], this->mNumMessagesMax); in TYPED_TEST()
1054 ASSERT_TRUE(this->mQueue->write(&data[0], this->mNumMessagesMax)); in TYPED_TEST()
1055 std::vector<uint8_t> readData(this->mNumMessagesMax); in TYPED_TEST()
1056 ASSERT_TRUE(this->mQueue->read(&readData[0], this->mNumMessagesMax)); in TYPED_TEST()
1068 ASSERT_GT(dataLen, this->mNumMessagesMax); in TYPED_TEST()
1072 std::vector<uint8_t> readData(this->mNumMessagesMax); in TYPED_TEST()
1073 ASSERT_FALSE(this->mQueue->read(&readData[0], this->mNumMessagesMax)); in TYPED_TEST()
1084 std::vector<uint8_t> data(this->mNumMessagesMax); in TYPED_TEST()
1085 initData(&data[0], this->mNumMessagesMax); in TYPED_TEST()
1086 ASSERT_TRUE(this->mQueue->write(&data[0], this->mNumMessagesMax)); in TYPED_TEST()
1088 std::vector<uint8_t> readData(this->mNumMessagesMax); in TYPED_TEST()
1089 ASSERT_FALSE(this->mQueue->read(&readData[0], this->mNumMessagesMax)); in TYPED_TEST()
1099 ASSERT_LE(dataLen, this->mNumMessagesMax); in TYPED_TEST()
1117 ASSERT_LE(dataLen, this->mNumMessagesMax); in TYPED_TEST()
1137 size_t numMessages = this->mNumMessagesMax - 1; in TYPED_TEST()
1138 std::vector<uint8_t> data(this->mNumMessagesMax); in TYPED_TEST()
1139 std::vector<uint8_t> readData(this->mNumMessagesMax); in TYPED_TEST()
1141 initData(&data[0], this->mNumMessagesMax); in TYPED_TEST()
1144 ASSERT_TRUE(this->mQueue->write(&data[0], this->mNumMessagesMax)); in TYPED_TEST()
1145 ASSERT_TRUE(this->mQueue->read(&readData[0], this->mNumMessagesMax)); in TYPED_TEST()