Lines Matching refs:mQueue
100 delete mQueue; in TearDown()
107 mQueue = new (std::nothrow) typename T::MQType(kNumElementsInQueue); in SetUp()
111 mQueue = new (std::nothrow) in SetUp()
115 ASSERT_NE(nullptr, mQueue); in SetUp()
116 ASSERT_TRUE(mQueue->isValid()); in SetUp()
117 mNumMessagesMax = mQueue->getQuantumCount(); in SetUp()
121 typename T::MQType* mQueue = nullptr; member in SynchronizedReadWrites
131 delete mQueue; in TearDown()
138 mQueue = new (std::nothrow) typename T::MQType(kNumElementsInQueue); in SetUp()
142 mQueue = new (std::nothrow) in SetUp()
146 ASSERT_NE(nullptr, mQueue); in SetUp()
147 ASSERT_TRUE(mQueue->isValid()); in SetUp()
148 mNumMessagesMax = mQueue->getQuantumCount(); in SetUp()
152 typename T::MQType* mQueue = nullptr; member in UnsynchronizedWriteTest
162 delete mQueue; in TearDown()
168 mQueue = new (std::nothrow) typename T::MQType(kNumElementsInQueue); in SetUp()
172 mQueue = new (std::nothrow) in SetUp()
176 ASSERT_NE(nullptr, mQueue); in SetUp()
177 ASSERT_TRUE(mQueue->isValid()); in SetUp()
178 mNumMessagesMax = mQueue->getQuantumCount(); in SetUp()
186 typename T::MQType* mQueue; member in BlockingReadWrites
196 virtual void TearDown() { delete mQueue; } in TearDown()
201 mQueue = new (std::nothrow) in SetUp()
206 mQueue = new (std::nothrow) typename T::MQType( in SetUp()
210 ASSERT_NE(nullptr, mQueue); in SetUp()
211 ASSERT_TRUE(mQueue->isValid()); in SetUp()
212 mNumMessagesMax = mQueue->getQuantumCount(); in SetUp()
214 auto evFlagWordPtr = mQueue->getEventFlagWord(); in SetUp()
222 typename T::MQType* mQueue; member in QueueSizeOdd
566 std::thread Reader(BlockingReadWrites<TypeParam>::ReaderThreadBlocking, this->mQueue, in TYPED_TEST()
575 ASSERT_TRUE(this->mQueue->write(data, dataLen)); in TYPED_TEST()
604 std::thread Reader(BlockingReadWrites<TypeParam>::ReaderThreadBlocking2, this->mQueue, in TYPED_TEST()
606 bool ret = this->mQueue->writeBlocking(data, dataLen, static_cast<uint32_t>(kFmqNotFull), in TYPED_TEST()
648 bool ret = this->mQueue->writeBlocking(data, dataLen, static_cast<uint32_t>(kFmqNotFull), in TYPED_TEST()
664 ASSERT_TRUE(this->mQueue->write(data, dataLen)); in TYPED_TEST()
666 ASSERT_TRUE(this->mQueue->read(readData, dataLen)); in TYPED_TEST()
682 ASSERT_TRUE(this->mQueue->beginWrite(dataLen, &tx)); in TYPED_TEST()
686 ASSERT_TRUE(this->mQueue->commitWrite(dataLen)); in TYPED_TEST()
690 ASSERT_TRUE(this->mQueue->beginRead(dataLen, &tx)); in TYPED_TEST()
694 ASSERT_TRUE(this->mQueue->commitRead(dataLen)); in TYPED_TEST()
710 ASSERT_TRUE(this->mQueue->beginWrite(dataLen, &tx)); in TYPED_TEST()
721 ASSERT_TRUE(this->mQueue->commitWrite(dataLen)); in TYPED_TEST()
725 ASSERT_TRUE(this->mQueue->beginRead(dataLen, &tx)); in TYPED_TEST()
737 ASSERT_TRUE(this->mQueue->commitRead(dataLen)); in TYPED_TEST()
746 ASSERT_EQ(0UL, this->mQueue->availableToRead()); in TYPED_TEST()
750 ASSERT_FALSE(this->mQueue->read(readData, dataLen)); in TYPED_TEST()
758 ASSERT_EQ(0UL, this->mQueue->availableToRead()); in TYPED_TEST()
763 ASSERT_FALSE(this->mQueue->beginRead(dataLen, &tx)); in TYPED_TEST()
777 ASSERT_EQ(0UL, this->mQueue->availableToRead()); in TYPED_TEST()
781 ASSERT_TRUE(this->mQueue->write(&data[0], this->mNumMessagesMax)); in TYPED_TEST()
782 ASSERT_EQ(0UL, this->mQueue->availableToWrite()); in TYPED_TEST()
783 ASSERT_FALSE(this->mQueue->write(&data[0], 1)); in TYPED_TEST()
786 ASSERT_TRUE(this->mQueue->read(&readData[0], this->mNumMessagesMax)); in TYPED_TEST()
795 ASSERT_EQ(0UL, this->mQueue->availableToRead()); in TYPED_TEST()
799 ASSERT_TRUE(this->mQueue->write(&data[0], this->mNumMessagesMax)); in TYPED_TEST()
800 ASSERT_EQ(0UL, this->mQueue->availableToWrite()); in TYPED_TEST()
803 ASSERT_FALSE(this->mQueue->beginWrite(1, &tx)); in TYPED_TEST()
820 ASSERT_TRUE(this->mQueue->write(&data[0], this->mNumMessagesMax)); in TYPED_TEST()
822 ASSERT_TRUE(this->mQueue->read(&readData[0], this->mNumMessagesMax)); in TYPED_TEST()
832 ASSERT_EQ(0UL, this->mQueue->availableToRead()); in TYPED_TEST()
838 ASSERT_FALSE(this->mQueue->write(&data[0], dataLen)); in TYPED_TEST()
840 ASSERT_FALSE(this->mQueue->read(&readData[0], this->mNumMessagesMax)); in TYPED_TEST()
842 ASSERT_EQ(0UL, this->mQueue->availableToRead()); in TYPED_TEST()
853 ASSERT_TRUE(this->mQueue->write(&data[0], this->mNumMessagesMax)); in TYPED_TEST()
854 ASSERT_FALSE(this->mQueue->write(&data[0], 1)); in TYPED_TEST()
856 ASSERT_TRUE(this->mQueue->read(&readData[0], this->mNumMessagesMax)); in TYPED_TEST()
866 ASSERT_EQ(0UL, this->mQueue->availableToRead()); in TYPED_TEST()
871 ASSERT_FALSE(this->mQueue->beginWrite(dataLen, &tx)); in TYPED_TEST()
891 ASSERT_TRUE(this->mQueue->write(data, dataLen)); in TYPED_TEST()
894 ASSERT_TRUE(this->mQueue->read(readData + i * chunkSize, chunkSize)); in TYPED_TEST()
911 ASSERT_TRUE(this->mQueue->write(data + i * chunkSize, chunkSize)); in TYPED_TEST()
914 ASSERT_TRUE(this->mQueue->read(readData, dataLen)); in TYPED_TEST()
929 ASSERT_TRUE(this->mQueue->write(&data[0], numMessages)); in TYPED_TEST()
930 ASSERT_TRUE(this->mQueue->read(&readData[0], numMessages)); 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()
949 ASSERT_TRUE(this->mQueue->write(&data[0], dataLen)); in TYPED_TEST()
950 ASSERT_TRUE(this->mQueue->read(&readData[0], dataLen)); in TYPED_TEST()
956 ASSERT_TRUE(this->mQueue->beginWrite(this->mNumMessagesMax, &tx)); 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()
975 ASSERT_TRUE(this->mQueue->commitRead(this->mNumMessagesMax)); in TYPED_TEST()
989 ASSERT_TRUE(this->mQueue->write(data, dataLen)); in TYPED_TEST()
991 ASSERT_TRUE(this->mQueue->read(readData, dataLen)); in TYPED_TEST()
999 ASSERT_EQ(0UL, this->mQueue->availableToRead()); in TYPED_TEST()
1003 ASSERT_FALSE(this->mQueue->read(readData, dataLen)); in TYPED_TEST()
1011 ASSERT_EQ(0UL, this->mQueue->availableToRead()); in TYPED_TEST()
1015 ASSERT_TRUE(this->mQueue->write(&data[0], this->mNumMessagesMax)); in TYPED_TEST()
1016 ASSERT_EQ(0UL, this->mQueue->availableToWrite()); in TYPED_TEST()
1017 ASSERT_TRUE(this->mQueue->write(&data[0], 1)); in TYPED_TEST()
1020 ASSERT_FALSE(this->mQueue->read(&readData[0], this->mNumMessagesMax)); in TYPED_TEST()
1029 ASSERT_EQ(0UL, this->mQueue->availableToRead()); in TYPED_TEST()
1031 ASSERT_TRUE(this->mQueue->write(&data[0], this->mNumMessagesMax)); in TYPED_TEST()
1034 ASSERT_TRUE(this->mQueue->beginWrite(1, &tx)); in TYPED_TEST()
1040 ASSERT_TRUE(this->mQueue->commitWrite(1)); in TYPED_TEST()
1043 ASSERT_FALSE(this->mQueue->read(&readData[0], this->mNumMessagesMax)); in TYPED_TEST()
1054 ASSERT_TRUE(this->mQueue->write(&data[0], this->mNumMessagesMax)); in TYPED_TEST()
1056 ASSERT_TRUE(this->mQueue->read(&readData[0], this->mNumMessagesMax)); in TYPED_TEST()
1066 ASSERT_EQ(0UL, this->mQueue->availableToRead()); in TYPED_TEST()
1071 ASSERT_FALSE(this->mQueue->write(&data[0], dataLen)); in TYPED_TEST()
1073 ASSERT_FALSE(this->mQueue->read(&readData[0], this->mNumMessagesMax)); in TYPED_TEST()
1075 ASSERT_EQ(0UL, this->mQueue->availableToRead()); in TYPED_TEST()
1086 ASSERT_TRUE(this->mQueue->write(&data[0], this->mNumMessagesMax)); in TYPED_TEST()
1087 ASSERT_TRUE(this->mQueue->write(&data[0], 1)); in TYPED_TEST()
1089 ASSERT_FALSE(this->mQueue->read(&readData[0], this->mNumMessagesMax)); in TYPED_TEST()
1102 ASSERT_TRUE(this->mQueue->write(data, dataLen)); in TYPED_TEST()
1105 ASSERT_TRUE(this->mQueue->read(readData + i * chunkSize, chunkSize)); in TYPED_TEST()
1122 ASSERT_TRUE(this->mQueue->write(data + i * chunkSize, chunkSize)); in TYPED_TEST()
1126 ASSERT_TRUE(this->mQueue->read(readData, dataLen)); in TYPED_TEST()
1142 ASSERT_TRUE(this->mQueue->write(&data[0], numMessages)); in TYPED_TEST()
1143 ASSERT_TRUE(this->mQueue->read(&readData[0], numMessages)); 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()