Lines Matching refs:queue
119 * Utility function to verify data read from the fast message queue.
148 MessageQueueUnsync* queue = nullptr;
149 getQueue(&queue, &testService, true /* setupQueue */);
152 ASSERT_NE(queue, nullptr);
153 ASSERT_TRUE(queue->isValid());
155 size_t numMessagesMax = queue->getQuantumCount();
168 ASSERT_FALSE(queue->read(&readData[0], numMessagesMax));
180 ASSERT_TRUE(queue->read(&readData[0], dataLen));
183 delete queue;
196 MessageQueueUnsync* queue = nullptr;
198 getQueue(&queue, &testService, false /* setupQueue */);
201 ASSERT_NE(queue, nullptr);
202 ASSERT_TRUE(queue->isValid());
206 ASSERT_FALSE(queue->read(&readData[0], dataLen));
217 ASSERT_TRUE(queue->read(&readData[0], dataLen));
220 delete queue;
522 * Request mService to write data equal to queue size.
611 * Write mNumMessagesMax messages into the queue. This should cause a
631 * Write mNumMessagesMax messages into the queue. This will cause a
725 * Request mService to write data equal to queue size.
817 * Write mNumMessagesMax messages into the queue. This should cause a