145     const size_t dataLen = 16;  in TEST_F()  local
177         ASSERT_LT(dataLen, numMessagesMax);  in TEST_F()
178         ret = testService->requestWriteFmqUnsync(dataLen);  in TEST_F()
183         ASSERT_TRUE(queue->read(&readData[0], dataLen));  in TEST_F()
184         ASSERT_TRUE(verifyData(&readData[0], dataLen));  in TEST_F()
208         std::vector<uint16_t> readData(dataLen);  in TEST_F()
209         ASSERT_FALSE(queue->read(&readData[0], dataLen));  in TEST_F()
215         auto ret = testService->requestWriteFmqUnsync(dataLen);  in TEST_F()
220         ASSERT_TRUE(queue->read(&readData[0], dataLen));  in TEST_F()
221         ASSERT_TRUE(verifyData(&readData[0], dataLen));  in TEST_F()
236     const size_t dataLen = 64;  in TEST_F()  local
237     uint16_t data[dataLen] = {0};  in TEST_F()
243     mService->requestBlockingRead(dataLen);  in TEST_F()
245                                      dataLen,  in TEST_F()
263     const size_t dataLen = 64;  in TEST_F()  local
271     mService->requestBlockingReadDefaultEventFlagBits(dataLen);  in TEST_F()
277                                      dataLen);  in TEST_F()
295     const size_t dataLen = 64;  in TEST_F()  local
296     uint16_t data[dataLen] = {0};  in TEST_F()
304     mService->requestBlockingReadRepeat(dataLen, writeCount);  in TEST_F()
307         ret = mQueue->writeBlocking(data, dataLen,  in TEST_F()
329     const size_t dataLen = 64;  in TEST_F()  local
330     uint16_t data[dataLen] = {0};  in TEST_F()
338     mService->requestBlockingReadRepeat(dataLen*2, writeCount/2);  in TEST_F()
341         ret = mQueue->writeBlocking(data, dataLen,  in TEST_F()
361     const size_t dataLen = 64;  in TEST_F()  local
362     uint16_t data[dataLen] = {0};  in TEST_F()
370     mService->requestBlockingReadRepeat(dataLen/2, writeCount*2);  in TEST_F()
373         ret = mQueue->writeBlocking(data, dataLen,  in TEST_F()
418     const size_t dataLen = 16;  in TEST_F()  local
419     ASSERT_LE(dataLen, mNumMessagesMax);  in TEST_F()
420     bool ret = mService->requestWriteFmqSync(dataLen);  in TEST_F()
422     uint16_t readData[dataLen] = {};  in TEST_F()
423     ASSERT_TRUE(mQueue->read(readData, dataLen));  in TEST_F()
424     ASSERT_TRUE(verifyData(readData, dataLen));  in TEST_F()
433     const size_t dataLen = 16;  in TEST_F()  local
434     ASSERT_LE(dataLen, mNumMessagesMax);  in TEST_F()
435     auto ret = mService->requestWriteFmqSync(dataLen);  in TEST_F()
441     ASSERT_TRUE(mQueue->beginRead(dataLen, &tx));  in TEST_F()
447     for (size_t i = 0; i < dataLen; i++) {  in TEST_F()
455     ASSERT_TRUE(mQueue->commitRead(dataLen));  in TEST_F()
463     const size_t dataLen = 16;  in TEST_F()  local
464     ASSERT_LE(dataLen, mNumMessagesMax);  in TEST_F()
466     uint16_t data[dataLen];  in TEST_F()
467     initData(data, dataLen);  in TEST_F()
468     ASSERT_TRUE(mQueue->write(data, dataLen));  in TEST_F()
469     bool ret = mService->requestReadFmqSync(dataLen);  in TEST_F()
480     const size_t dataLen = 16;  in TEST_F()  local
481     ASSERT_LE(dataLen, mNumMessagesMax);  in TEST_F()
483     uint16_t data[dataLen];  in TEST_F()
484     initData(data, dataLen);  in TEST_F()
487     ASSERT_TRUE(mQueue->beginWrite(dataLen, &tx));  in TEST_F()
496     for (size_t i = 0; i < dataLen; i++) {  in TEST_F()
504     ASSERT_TRUE(mQueue->commitWrite(dataLen));  in TEST_F()
506     auto ret = mService->requestReadFmqSync(dataLen);  in TEST_F()
693     const size_t dataLen = 16;  in TEST_F()  local
694     ASSERT_LE(dataLen, mNumMessagesMax);  in TEST_F()
695     bool ret = mService->requestWriteFmqUnsync(dataLen);  in TEST_F()
697     uint16_t readData[dataLen] = {};  in TEST_F()
698     ASSERT_TRUE(mQueue->read(readData, dataLen));  in TEST_F()
699     ASSERT_TRUE(verifyData(readData, dataLen));  in TEST_F()
707     const size_t dataLen = 16;  in TEST_F()  local
708     ASSERT_LE(dataLen, mNumMessagesMax);  in TEST_F()
709     uint16_t data[dataLen];  in TEST_F()
710     initData(data, dataLen);  in TEST_F()
711     ASSERT_TRUE(mQueue->write(data, dataLen));  in TEST_F()
712     bool ret = mService->requestReadFmqUnsync(dataLen);  in TEST_F()
866     const size_t dataLen = 16;  in TEST_F()  local
867     ASSERT_LE(dataLen, mNumMessagesMax);  in TEST_F()
869     bool ret = mService->requestWriteFmqUnsync(dataLen);  in TEST_F()
875         uint16_t readData[dataLen] = {};  in TEST_F()
876         ASSERT_TRUE(mQueue2->read(readData, dataLen));  in TEST_F()
877         ASSERT_TRUE(verifyData(readData, dataLen));  in TEST_F()
882         uint16_t readData[dataLen] = {};  in TEST_F()
883         ASSERT_TRUE(mQueue->read(readData, dataLen));  in TEST_F()
884         ASSERT_TRUE(verifyData(readData, dataLen));  in TEST_F()