237                            AidlMessageQueueUnsync** queue) {  in getFmqUnsyncWrite()  argument
241         *queue = new (std::nothrow) AidlMessageQueueUnsync(desc, false);  in getFmqUnsyncWrite()
290                            cppAidlMessageQueueUnsync** queue) {  in getFmqUnsyncWrite()  argument
294         *queue = new (std::nothrow) cppAidlMessageQueueUnsync(desc, false);  in getFmqUnsyncWrite()
345                            MessageQueueUnsync** queue) {  in getFmqUnsyncWrite()  argument
350                                    [queue](bool ret, const MQDescriptorUnsync<int32_t>& in) {  in getFmqUnsyncWrite()
352                                        *queue = new (std::nothrow) MessageQueueUnsync(in, false);  in getFmqUnsyncWrite()
402         // create a queue on the client side  in SetUp()
410         // tell server to set up the queue on its end  in SetUp()
436  * Utility function to verify data read from the fast message queue.
464         typename TypeParam::MQType* queue = nullptr;  in TYPED_TEST()  local
466                 this->getQueue(&queue, true /* setupQueue */, TypeParam::UserFd /* userFd */);  in TYPED_TEST()
468         ASSERT_NE(queue, nullptr);  in TYPED_TEST()
469         ASSERT_TRUE(queue->isValid());  in TYPED_TEST()
471         size_t numMessagesMax = queue->getQuantumCount();  in TYPED_TEST()
482         ASSERT_FALSE(queue->read(&readData[0], numMessagesMax));  in TYPED_TEST()
493         ASSERT_TRUE(queue->read(&readData[0], dataLen));  in TYPED_TEST()
495         delete queue;  in TYPED_TEST()
507         typename TypeParam::MQType* queue = nullptr;  in TYPED_TEST()  local
508         auto service = this->getQueue(&queue, false /* setupQueue */, false /* userFd */);  in TYPED_TEST()
510         ASSERT_NE(queue, nullptr);  in TYPED_TEST()
511         ASSERT_TRUE(queue->isValid());  in TYPED_TEST()
515         ASSERT_FALSE(queue->read(&readData[0], dataLen));  in TYPED_TEST()
525         ASSERT_TRUE(queue->read(&readData[0], dataLen));  in TYPED_TEST()
527         delete queue;  in TYPED_TEST()
619      * Write 64 elements into the queue for the service to consume  in TYPED_TEST()
633      * The queue should be totally empty now, so filling it up entirely with one  in TYPED_TEST()
665      * Write 64 elements into the queue writeCount times  in TYPED_TEST()
679      * The queue should be totally empty now, so filling it up entirely with one  in TYPED_TEST()
710      * Write 64 elements into the queue writeCount times  in TYPED_TEST()
724      * The queue should be totally empty now, so filling it up entirely with one  in TYPED_TEST()
777  * Request mService to write a message to the queue followed by a beginRead().
792     // begin read and get a MemTransaction object for the first object in the queue  in TYPED_TEST()
864  * Write a message to the queue, get a pointer to the memory region for that
888     // begin write and get a MemTransaction object for the first object in the queue  in TYPED_TEST()
995  * Request mService to write data equal to queue size.
1084  * Write mNumMessagesMax messages into the queue. This should cause a
1104  * Write mNumMessagesMax messages into the queue. This will cause a
1191  * Request this->mService to write data equal to queue size.
1286  * Write this->mNumMessagesMax messages into the queue. This should cause a
1357  * Make sure a valid queue can be created with different supported types.
1372     android::AidlMessageQueue<TypeParam, UnsynchronizedWrite> queue =  in TYPED_TEST()  local
1374     ASSERT_TRUE(queue.isValid());  in TYPED_TEST()
1378     EXPECT_TRUE(queue.write(writeData, 1));  in TYPED_TEST()
1379     EXPECT_TRUE(queue.read(readData, 1));  in TYPED_TEST()