Lines Matching refs:queue
150 MessageQueueUnsync* queue = nullptr; in TEST_F() local
151 getQueue(&queue, &testService, true /* setupQueue */); in TEST_F()
154 ASSERT_NE(queue, nullptr); in TEST_F()
155 ASSERT_TRUE(queue->isValid()); in TEST_F()
157 size_t numMessagesMax = queue->getQuantumCount(); in TEST_F()
170 ASSERT_FALSE(queue->read(&readData[0], numMessagesMax)); in TEST_F()
182 ASSERT_TRUE(queue->read(&readData[0], dataLen)); in TEST_F()
185 delete queue; in TEST_F()
198 MessageQueueUnsync* queue = nullptr; in TEST_F() local
200 getQueue(&queue, &testService, false /* setupQueue */); in TEST_F()
203 ASSERT_NE(queue, nullptr); in TEST_F()
204 ASSERT_TRUE(queue->isValid()); in TEST_F()
208 ASSERT_FALSE(queue->read(&readData[0], dataLen)); in TEST_F()
219 ASSERT_TRUE(queue->read(&readData[0], dataLen)); in TEST_F()
222 delete queue; in TEST_F()