30 using aidl::android::hardware::common::fmq::SynchronizedReadWrite;
31 using aidl::android::hardware::common::fmq::UnsynchronizedWrite;
50 typedef aidl::android::hardware::common::fmq::MQDescriptor<int8_t, SynchronizedReadWrite>
55 typedef aidl::android::hardware::common::fmq::MQDescriptor<int8_t, UnsynchronizedWrite>
90     static void ReaderThreadBlocking(typename T::MQType* fmq, std::atomic<uint32_t>* fwAddr);
91     static void ReaderThreadBlocking2(typename T::MQType* fmq, std::atomic<uint32_t>* fwAddr);
250 void TestBase<T>::ReaderThreadBlocking(typename T::MQType* fmq, std::atomic<uint32_t>* fwAddr) {  in ReaderThreadBlocking()  argument
268         if ((efState & kFmqNotEmpty) && fmq->read(data, dataLen)) {  in ReaderThreadBlocking()
283 void TestBase<T>::ReaderThreadBlocking2(typename T::MQType* fmq, std::atomic<uint32_t>* fwAddr) {  in ReaderThreadBlocking2()  argument
290     bool ret = fmq->readBlocking(data,  in ReaderThreadBlocking2()
303     typename TypeParam::MQType* fmq =  in TYPED_TEST()  local
305     ASSERT_NE(nullptr, fmq);  in TYPED_TEST()
309     ASSERT_FALSE(fmq->isValid());  in TYPED_TEST()
318         android::AidlMessageQueue<uint32_t, SynchronizedReadWrite> fmq(numElementsInQueue);  in TEST_F()  local
319         ASSERT_FALSE(fmq.isValid());  in TEST_F()
331     MessageQueueSync8* fmq = new (std::nothrow) MessageQueueSync8(numElementsInQueue);  in TEST_F()  local
332     ASSERT_NE(nullptr, fmq);  in TEST_F()
333     ASSERT_TRUE(fmq->isValid());  in TEST_F()
334     const HidlMQDescSync8* hidlDesc = fmq->getDesc();  in TEST_F()
350     fmq->write(data, dataLen);  in TEST_F()
365     MessageQueueUnsync8* fmq = new (std::nothrow) MessageQueueUnsync8(numElementsInQueue);  in TEST_F()  local
366     ASSERT_NE(nullptr, fmq);  in TEST_F()
367     ASSERT_TRUE(fmq->isValid());  in TEST_F()
368     const HidlMQDescUnsync8* hidlDesc = fmq->getDesc();  in TEST_F()
389     fmq->write(data, dataLen);  in TEST_F()
458     AidlMessageQueueSync16* fmq = new (std::nothrow) AidlMessageQueueSync16(numElementsInQueue);  in TEST_F()  local
459     ASSERT_NE(nullptr, fmq);  in TEST_F()
463     ASSERT_FALSE(fmq->isValid());  in TEST_F()
467     aidl::android::hardware::common::fmq::MQDescriptor<uint16_t, SynchronizedReadWrite> desc;  in TEST_F()
469     AidlMessageQueueSync16* fmq = new (std::nothrow) AidlMessageQueueSync16(desc);  in TEST_F()  local
470     ASSERT_NE(nullptr, fmq);  in TEST_F()
474     ASSERT_FALSE(fmq->isValid());  in TEST_F()
478     aidl::android::hardware::common::fmq::MQDescriptor<uint16_t, SynchronizedReadWrite> desc;  in TEST_F()
482             aidl::android::hardware::common::fmq::GrantorDescriptor{.offset = 12, .extent = -10});  in TEST_F()
483     AidlMessageQueueSync16* fmq = new (std::nothrow) AidlMessageQueueSync16(desc);  in TEST_F()  local
484     ASSERT_NE(nullptr, fmq);  in TEST_F()
488     ASSERT_FALSE(fmq->isValid());  in TEST_F()
497     AidlMessageQueueSync16 fmq = AidlMessageQueueSync16(64);  in TEST_F()  local
498     aidl::android::hardware::common::fmq::MQDescriptor<uint16_t, SynchronizedReadWrite> desc =  in TEST_F()
499             fmq.dupeDesc();  in TEST_F()
530     AidlMessageQueueSync16 fmq = AidlMessageQueueSync16(  in TEST_F()  local
532     EXPECT_FALSE(fmq.isValid());  in TEST_F()
544     AidlMessageQueueSync16 fmq = AidlMessageQueueSync16(  in TEST_F()  local
546     EXPECT_TRUE(fmq.isValid());  in TEST_F()