Lines Matching refs:queue
148 MessageQueueUnsync* queue = nullptr; in TEST_F() local
149 getQueue(&queue, &testService, true /* setupQueue */); in TEST_F()
152 ASSERT_NE(queue, nullptr); in TEST_F()
153 ASSERT_TRUE(queue->isValid()); in TEST_F()
155 size_t numMessagesMax = queue->getQuantumCount(); in TEST_F()
168 ASSERT_FALSE(queue->read(&readData[0], numMessagesMax)); in TEST_F()
180 ASSERT_TRUE(queue->read(&readData[0], dataLen)); in TEST_F()
183 delete queue; in TEST_F()
196 MessageQueueUnsync* queue = nullptr; in TEST_F() local
198 getQueue(&queue, &testService, false /* setupQueue */); in TEST_F()
201 ASSERT_NE(queue, nullptr); in TEST_F()
202 ASSERT_TRUE(queue->isValid()); in TEST_F()
206 ASSERT_FALSE(queue->read(&readData[0], dataLen)); in TEST_F()
217 ASSERT_TRUE(queue->read(&readData[0], dataLen)); in TEST_F()
220 delete queue; in TEST_F()