Lines Matching refs:mQueue
63 delete mQueue; in TearDown()
73 mQueue = new (std::nothrow) MessageQueueSync(in); in SetUp()
75 ASSERT_NE(nullptr, mQueue); in SetUp()
76 ASSERT_TRUE(mQueue->isValid()); in SetUp()
77 mNumMessagesMax = mQueue->getQuantumCount(); in SetUp()
81 MessageQueueSync* mQueue = nullptr; member in SynchronizedReadWriteClient
88 delete mQueue; in TearDown()
98 mQueue = new (std::nothrow) MessageQueueUnsync(in); in SetUp()
100 ASSERT_NE(nullptr, mQueue); in SetUp()
101 ASSERT_TRUE(mQueue->isValid()); in SetUp()
102 mNumMessagesMax = mQueue->getQuantumCount(); in SetUp()
106 MessageQueueUnsync* mQueue = nullptr; member in UnsynchronizedWriteClient
225 bool ret = mQueue->writeBlocking(data, in TEST_F()
252 bool ret = mQueue->writeBlocking(&data[0], in TEST_F()
260 ret = mQueue->writeBlocking(&data[0], mNumMessagesMax, 5000000000 /* timeOutNanos */); in TEST_F()
282 bool ret = mQueue->writeBlocking( in TEST_F()
310 bool ret = mQueue->writeBlocking( in TEST_F()
337 bool ret = mQueue->writeBlocking( in TEST_F()
357 bool ret = mQueue->writeBlocking( in TEST_F()
367 ret = mQueue->readBlocking(&data, in TEST_F()
384 ASSERT_TRUE(mQueue->read(readData, dataLen)); in TEST_F()
402 ASSERT_TRUE(mQueue->beginRead(dataLen, &tx)); in TEST_F()
416 ASSERT_TRUE(mQueue->commitRead(dataLen)); in TEST_F()
426 size_t originalCount = mQueue->availableToWrite(); in TEST_F()
429 ASSERT_TRUE(mQueue->write(data, dataLen)); in TEST_F()
432 size_t availableCount = mQueue->availableToWrite(); in TEST_F()
443 size_t originalCount = mQueue->availableToWrite(); in TEST_F()
448 ASSERT_TRUE(mQueue->beginWrite(dataLen, &tx)); in TEST_F()
465 ASSERT_TRUE(mQueue->commitWrite(dataLen)); in TEST_F()
470 size_t availableCount = mQueue->availableToWrite(); in TEST_F()
478 ASSERT_EQ(0UL, mQueue->availableToRead()); in TEST_F()
482 ASSERT_FALSE(mQueue->read(readData, numMessages)); in TEST_F()
497 ASSERT_TRUE(mQueue->write(&data[0], mNumMessagesMax)); in TEST_F()
498 ASSERT_EQ(0UL, mQueue->availableToWrite()); in TEST_F()
499 ASSERT_FALSE(mQueue->write(&data[0], 1)); in TEST_F()
513 ASSERT_TRUE(mQueue->read(&readData[0], mNumMessagesMax)); in TEST_F()
523 ASSERT_EQ(0UL, mQueue->availableToRead()); in TEST_F()
529 ASSERT_EQ(0UL, mQueue->availableToRead()); in TEST_F()
530 ASSERT_FALSE(mQueue->read(&readData, 1)); in TEST_F()
544 ASSERT_TRUE(mQueue->write(&data[0], mNumMessagesMax)); in TEST_F()
545 ASSERT_EQ(0UL, mQueue->availableToWrite()); in TEST_F()
546 ASSERT_FALSE(mQueue->write(&data[0], 1)); in TEST_F()
561 size_t availableToRead = mQueue->availableToRead(); in TEST_F()
568 ASSERT_TRUE(mQueue->read(readData + i * chunkSize, chunkSize)); in TEST_F()
586 ASSERT_TRUE(mQueue->write(data + i * chunkSize, chunkSize)); in TEST_F()
602 ASSERT_TRUE(mQueue->write(&data[0], numMessages)); in TEST_F()
605 ASSERT_TRUE(mQueue->write(&data[0], mNumMessagesMax)); in TEST_F()
622 ASSERT_TRUE(mQueue->write(&data[0], numMessages)); in TEST_F()
632 ASSERT_TRUE(mQueue->beginWrite(mNumMessagesMax, &tx)); in TEST_F()
641 ASSERT_TRUE(mQueue->commitWrite(mNumMessagesMax)); in TEST_F()
659 ASSERT_TRUE(mQueue->read(readData, dataLen)); in TEST_F()
672 ASSERT_TRUE(mQueue->write(data, dataLen)); in TEST_F()
681 ASSERT_EQ(0UL, mQueue->availableToRead()); in TEST_F()
685 ASSERT_FALSE(mQueue->read(readData, numMessages)); in TEST_F()
700 ASSERT_TRUE(mQueue->write(&data[0], mNumMessagesMax)); in TEST_F()
701 ASSERT_EQ(0UL, mQueue->availableToWrite()); in TEST_F()
702 ASSERT_TRUE(mQueue->write(&data[0], 1)); in TEST_F()
716 ASSERT_TRUE(mQueue->read(&data[0], mNumMessagesMax)); in TEST_F()
726 ASSERT_EQ(0UL, mQueue->availableToRead()); in TEST_F()
731 ASSERT_EQ(0UL, mQueue->availableToRead()); in TEST_F()
732 ASSERT_FALSE(mQueue->read(&readData, 1)); in TEST_F()
747 ASSERT_TRUE(mQueue->write(&data[0], mNumMessagesMax)); in TEST_F()
748 ASSERT_EQ(0UL, mQueue->availableToWrite()); in TEST_F()
749 ASSERT_TRUE(mQueue->write(&data[0], 1)); in TEST_F()
753 ASSERT_TRUE(mQueue->write(&data[0], mNumMessagesMax)); in TEST_F()
768 size_t availableToRead = mQueue->availableToRead(); in TEST_F()
775 ASSERT_TRUE(mQueue->read(readData + i * chunkSize, chunkSize)); in TEST_F()
792 ASSERT_TRUE(mQueue->write(data + i * chunkSize, chunkSize)); in TEST_F()
808 ASSERT_TRUE(mQueue->write(&data[0], numMessages)); in TEST_F()
811 ASSERT_TRUE(mQueue->write(&data[0], mNumMessagesMax)); in TEST_F()
822 auto desc = mQueue->getDesc(); in TEST_F()
844 ASSERT_TRUE(mQueue->read(readData, dataLen)); in TEST_F()
855 auto desc = mQueue->getDesc(); in TEST_F()
874 ASSERT_FALSE(mQueue->read(&readData[0], mNumMessagesMax)); in TEST_F()