Searched refs:fmq (Results 1 – 3 of 3) sorted by relevance
| /system/libfmq/tests/ |
| D | mq_test.cpp | 141 android::hardware::kSynchronizedReadWrite>* fmq, in ReaderThreadBlocking() argument
160 if ((efState & kFmqNotEmpty) && fmq->read(data, dataLen)) { in ReaderThreadBlocking()
176 android::hardware::kSynchronizedReadWrite>* fmq, in ReaderThreadBlocking2() argument
184 bool ret = fmq->readBlocking(data, in ReaderThreadBlocking2()
200 MessageQueueSync16 * fmq = new (std::nothrow) MessageQueueSync16(numElementsInQueue); in TEST_F() local
201 ASSERT_NE(nullptr, fmq); in TEST_F()
205 ASSERT_FALSE(fmq->isValid()); in TEST_F()
|
| D | msgq_test_client.cpp | 55 void getQueue(MessageQueueUnsync** fmq, sp<ITestMsgQ>* service, bool setupQueue) { in getQueue() argument
57 *fmq = nullptr; in getQueue()
61 [fmq](bool ret, const MQDescriptorUnsync<uint16_t>& in) { in getQueue()
63 *fmq = new (std::nothrow) MessageQueueUnsync(in); in getQueue()
|
| /system/tools/hidl/test/hidl_test/ |
| D | hidl_test_client.cpp | 2505 pointerFmqSafeUnion, [&](const ICppSafeUnion::PointerFmqSafeUnion& fmq) { in TEST_F() argument
2506 ASSERT_EQ(pointerFmqSafeUnion.getDiscriminator(), fmq.getDiscriminator()); in TEST_F()
2507 checkMQDescriptorEquality(pointerFmqSafeUnion.fmqSync(), fmq.fmqSync()); in TEST_F()
2514 fmqSafeUnion, [&](const ICppSafeUnion::FmqSafeUnion& fmq) { in TEST_F() argument
2515 ASSERT_EQ(fmqSafeUnion.getDiscriminator(), fmq.getDiscriminator()); in TEST_F()
2516 checkMQDescriptorEquality(fmqSafeUnion.fmqUnsync(), fmq.fmqUnsync()); in TEST_F()
|