Lines Matching refs:mQueue
186 if (mQueue->isValid()) in newQueue()
187 return new (std::nothrow) AidlMessageQueueUnsync(mQueue->dupeDesc()); in newQueue()
193 AidlMessageQueueUnsync* mQueue = nullptr; member in ClientUnsyncTestBase
237 return new (std::nothrow) MessageQueueUnsync(*mQueue->getDesc()); in newQueue()
241 MessageQueueUnsync* mQueue = nullptr; member in ClientUnsyncTestBase
253 delete mQueue; in TearDown()
267 mQueue = new (std::nothrow) typename T::MQType( in SetUp()
270 ASSERT_NE(nullptr, mQueue); in SetUp()
271 ASSERT_TRUE(mQueue->isValid()); in SetUp()
272 ASSERT_EQ(mQueue->getQuantumCount(), kNumElementsInSyncQueue); in SetUp()
275 ASSERT_TRUE(this->configureFmqSyncReadWrite(mQueue)); in SetUp()
278 typename T::MQType* mQueue = nullptr; member in SynchronizedReadWriteClient
285 virtual void TearDown() { delete this->mQueue; } in TearDown()
291 this->getFmqUnsyncWrite(true, false, this->mService, &this->mQueue); in SetUp()
292 ASSERT_NE(nullptr, this->mQueue); in SetUp()
293 ASSERT_TRUE(this->mQueue->isValid()); in SetUp()
294 mNumMessagesMax = this->mQueue->getQuantumCount(); in SetUp()
418 ret = this->mQueue->writeBlocking( in TYPED_TEST()
427 ret = this->mQueue->writeBlocking( in TYPED_TEST()
456 ret = this->mQueue->writeBlocking(data.data(), data.size()); in TYPED_TEST()
466 ret = this->mQueue->writeBlocking(data.data(), data.size(), 5000000000 /* timeOutNanos */); in TYPED_TEST()
493 ret = this->mQueue->writeBlocking( in TYPED_TEST()
507 ret = this->mQueue->writeBlocking( in TYPED_TEST()
539 ret = this->mQueue->writeBlocking( in TYPED_TEST()
553 ret = this->mQueue->writeBlocking( in TYPED_TEST()
584 ret = this->mQueue->writeBlocking( in TYPED_TEST()
598 ret = this->mQueue->writeBlocking( in TYPED_TEST()
617 bool ret = this->mQueue->writeBlocking( in TYPED_TEST()
625 ret = this->mQueue->readBlocking( in TYPED_TEST()
641 ASSERT_TRUE(this->mQueue->read(readData, dataLen)); in TYPED_TEST()
663 ASSERT_TRUE(this->mQueue->beginRead(dataLen, &tx)); in TYPED_TEST()
674 *(writeCntr) = this->mQueue->getQuantumCount() * this->mQueue->getQuantumSize() - 1; in TYPED_TEST()
678 this->mQueue->commitRead(dataLen); in TYPED_TEST()
698 ASSERT_TRUE(this->mQueue->beginRead(dataLen, &tx)); in TYPED_TEST()
712 ASSERT_TRUE(this->mQueue->commitRead(dataLen)); in TYPED_TEST()
722 size_t originalCount = this->mQueue->availableToWrite(); in TYPED_TEST()
725 ASSERT_TRUE(this->mQueue->write(data, dataLen)); in TYPED_TEST()
728 size_t availableCount = this->mQueue->availableToWrite(); in TYPED_TEST()
739 size_t originalCount = this->mQueue->availableToWrite(); in TYPED_TEST()
744 ASSERT_TRUE(this->mQueue->beginWrite(dataLen, &tx)); in TYPED_TEST()
761 ASSERT_TRUE(this->mQueue->commitWrite(dataLen)); in TYPED_TEST()
766 size_t availableCount = this->mQueue->availableToWrite(); in TYPED_TEST()
774 ASSERT_EQ(0UL, this->mQueue->availableToRead()); in TYPED_TEST()
778 ASSERT_FALSE(this->mQueue->read(readData, numMessages)); in TYPED_TEST()
792 ASSERT_TRUE(this->mQueue->write(data.data(), data.size())); in TYPED_TEST()
793 ASSERT_EQ(0UL, this->mQueue->availableToWrite()); in TYPED_TEST()
794 ASSERT_FALSE(this->mQueue->write(&data[0], 1)); in TYPED_TEST()
808 ASSERT_TRUE(this->mQueue->read(&readData[0], kNumElementsInSyncQueue)); in TYPED_TEST()
818 ASSERT_EQ(0UL, this->mQueue->availableToRead()); in TYPED_TEST()
824 ASSERT_EQ(0UL, this->mQueue->availableToRead()); in TYPED_TEST()
825 ASSERT_FALSE(this->mQueue->read(&readData, 1)); in TYPED_TEST()
839 ASSERT_TRUE(this->mQueue->write(data.data(), data.size())); in TYPED_TEST()
840 ASSERT_EQ(0UL, this->mQueue->availableToWrite()); in TYPED_TEST()
841 ASSERT_FALSE(this->mQueue->write(data.data(), 1)); in TYPED_TEST()
856 size_t availableToRead = this->mQueue->availableToRead(); in TYPED_TEST()
863 ASSERT_TRUE(this->mQueue->read(readData + i * chunkSize, chunkSize)); in TYPED_TEST()
881 ASSERT_TRUE(this->mQueue->write(data + i * chunkSize, chunkSize)); in TYPED_TEST()
897 ASSERT_TRUE(this->mQueue->write(&data[0], numMessages)); in TYPED_TEST()
900 ASSERT_TRUE(this->mQueue->write(data.data(), data.size())); in TYPED_TEST()
917 ASSERT_TRUE(this->mQueue->write(&data[0], numMessages)); in TYPED_TEST()
925 ASSERT_TRUE(this->mQueue->beginWrite(data.size(), &tx)); in TYPED_TEST()
934 ASSERT_TRUE(this->mQueue->commitWrite(data.size())); in TYPED_TEST()
950 ASSERT_TRUE(this->mQueue->read(readData, dataLen)); in TYPED_TEST()
963 ASSERT_TRUE(this->mQueue->write(data, dataLen)); in TYPED_TEST()
972 ASSERT_EQ(0UL, this->mQueue->availableToRead()); in TYPED_TEST()
976 ASSERT_FALSE(this->mQueue->read(readData, numMessages)); in TYPED_TEST()
991 ASSERT_TRUE(this->mQueue->write(&data[0], this->mNumMessagesMax)); in TYPED_TEST()
992 ASSERT_EQ(0UL, this->mQueue->availableToWrite()); in TYPED_TEST()
993 ASSERT_TRUE(this->mQueue->write(&data[0], 1)); in TYPED_TEST()
1007 ASSERT_TRUE(this->mQueue->read(&data[0], this->mNumMessagesMax)); in TYPED_TEST()
1017 ASSERT_EQ(0UL, this->mQueue->availableToRead()); in TYPED_TEST()
1022 ASSERT_EQ(0UL, this->mQueue->availableToRead()); in TYPED_TEST()
1023 ASSERT_FALSE(this->mQueue->read(&readData, 1)); in TYPED_TEST()
1038 ASSERT_TRUE(this->mQueue->write(&data[0], this->mNumMessagesMax)); in TYPED_TEST()
1039 ASSERT_EQ(0UL, this->mQueue->availableToWrite()); in TYPED_TEST()
1040 ASSERT_TRUE(this->mQueue->write(&data[0], 1)); in TYPED_TEST()
1044 ASSERT_TRUE(this->mQueue->write(&data[0], this->mNumMessagesMax)); in TYPED_TEST()
1059 size_t availableToRead = this->mQueue->availableToRead(); in TYPED_TEST()
1066 ASSERT_TRUE(this->mQueue->read(readData + i * chunkSize, chunkSize)); in TYPED_TEST()
1083 ASSERT_TRUE(this->mQueue->write(data + i * chunkSize, chunkSize)); in TYPED_TEST()
1099 ASSERT_TRUE(this->mQueue->write(&data[0], numMessages)); in TYPED_TEST()
1102 ASSERT_TRUE(this->mQueue->write(&data[0], this->mNumMessagesMax)); in TYPED_TEST()
1134 ASSERT_TRUE(this->mQueue->read(readData, dataLen)); in TYPED_TEST()
1162 ASSERT_FALSE(this->mQueue->read(&readData[0], this->mNumMessagesMax)); in TYPED_TEST()