Lines Matching refs:dataLen
105 bool requestReadFmqSync(size_t dataLen) { in requestReadFmqSync() argument
107 auto ret = mService->requestReadFmqSync(dataLen, &result); in requestReadFmqSync()
110 bool requestWriteFmqSync(size_t dataLen) { in requestWriteFmqSync() argument
112 auto ret = mService->requestWriteFmqSync(dataLen, &result); in requestWriteFmqSync()
134 bool requestReadFmqSync(size_t dataLen) { in requestReadFmqSync() argument
135 auto ret = mService->requestReadFmqSync(dataLen); in requestReadFmqSync()
138 bool requestWriteFmqSync(size_t dataLen) { in requestWriteFmqSync() argument
139 auto ret = mService->requestWriteFmqSync(dataLen); in requestWriteFmqSync()
175 bool requestReadFmqUnsync(size_t dataLen, std::shared_ptr<ITestAidlMsgQ> service) { in requestReadFmqUnsync() argument
177 auto ret = service->requestReadFmqUnsync(dataLen, &result); in requestReadFmqUnsync()
180 bool requestWriteFmqUnsync(size_t dataLen, std::shared_ptr<ITestAidlMsgQ> service) { in requestWriteFmqUnsync() argument
182 auto ret = service->requestWriteFmqUnsync(dataLen, &result); in requestWriteFmqUnsync()
227 bool requestReadFmqUnsync(size_t dataLen, sp<ITestMsgQ> service) { in requestReadFmqUnsync() argument
228 auto ret = service->requestReadFmqUnsync(dataLen); in requestReadFmqUnsync()
231 bool requestWriteFmqUnsync(size_t dataLen, sp<ITestMsgQ> service) { in requestWriteFmqUnsync() argument
232 auto ret = service->requestWriteFmqUnsync(dataLen); in requestWriteFmqUnsync()
324 const size_t dataLen = 16; in TYPED_TEST() local
354 ASSERT_LT(dataLen, numMessagesMax); in TYPED_TEST()
355 ret = this->requestWriteFmqUnsync(dataLen, service); in TYPED_TEST()
359 ASSERT_TRUE(queue->read(&readData[0], dataLen)); in TYPED_TEST()
360 ASSERT_TRUE(verifyData(&readData[0], dataLen)); in TYPED_TEST()
382 std::vector<int32_t> readData(dataLen); in TYPED_TEST()
383 ASSERT_FALSE(queue->read(&readData[0], dataLen)); in TYPED_TEST()
389 auto ret = this->requestWriteFmqUnsync(dataLen, service); in TYPED_TEST()
393 ASSERT_TRUE(queue->read(&readData[0], dataLen)); in TYPED_TEST()
394 ASSERT_TRUE(verifyData(&readData[0], dataLen)); in TYPED_TEST()
409 const size_t dataLen = 64; in TYPED_TEST() local
415 this->mService->requestBlockingRead(dataLen); in TYPED_TEST()
417 std::array<int32_t, dataLen> data = {0}; in TYPED_TEST()
442 const size_t dataLen = 64; in TYPED_TEST() local
450 this->mService->requestBlockingReadDefaultEventFlagBits(dataLen); in TYPED_TEST()
455 std::array<int32_t, dataLen> data = {0}; in TYPED_TEST()
478 const size_t dataLen = 64; in TYPED_TEST() local
486 this->mService->requestBlockingReadRepeat(dataLen, writeCount); in TYPED_TEST()
491 std::array<int32_t, dataLen> data = {0}; in TYPED_TEST()
524 const size_t dataLen = 64; in TYPED_TEST() local
532 this->mService->requestBlockingReadRepeat(dataLen * 2, writeCount / 2); in TYPED_TEST()
537 std::array<int32_t, dataLen> data = {0}; in TYPED_TEST()
568 const size_t dataLen = 64; in TYPED_TEST() local
577 this->mService->requestBlockingReadRepeat(dataLen / 2, writeCount * 2); in TYPED_TEST()
582 std::array<int32_t, dataLen> data = {0}; in TYPED_TEST()
636 const size_t dataLen = 16; in TYPED_TEST() local
637 ASSERT_LE(dataLen, kNumElementsInSyncQueue); in TYPED_TEST()
638 bool ret = this->requestWriteFmqSync(dataLen); in TYPED_TEST()
640 int32_t readData[dataLen] = {}; in TYPED_TEST()
641 ASSERT_TRUE(this->mQueue->read(readData, dataLen)); in TYPED_TEST()
642 ASSERT_TRUE(verifyData(readData, dataLen)); in TYPED_TEST()
657 const size_t dataLen = 1; in TYPED_TEST() local
658 ASSERT_LE(dataLen, kNumElementsInSyncQueue); in TYPED_TEST()
659 bool ret = this->requestWriteFmqSync(dataLen); in TYPED_TEST()
663 ASSERT_TRUE(this->mQueue->beginRead(dataLen, &tx)); in TYPED_TEST()
678 this->mQueue->commitRead(dataLen); in TYPED_TEST()
682 ret = this->requestWriteFmqSync(dataLen); in TYPED_TEST()
692 const size_t dataLen = 16; in TYPED_TEST() local
693 ASSERT_LE(dataLen, kNumElementsInSyncQueue); in TYPED_TEST()
694 auto ret = this->requestWriteFmqSync(dataLen); in TYPED_TEST()
698 ASSERT_TRUE(this->mQueue->beginRead(dataLen, &tx)); in TYPED_TEST()
704 for (size_t i = 0; i < dataLen; i++) { in TYPED_TEST()
712 ASSERT_TRUE(this->mQueue->commitRead(dataLen)); in TYPED_TEST()
720 const size_t dataLen = 16; in TYPED_TEST() local
721 ASSERT_LE(dataLen, kNumElementsInSyncQueue); in TYPED_TEST()
723 int32_t data[dataLen]; in TYPED_TEST()
724 initData(data, dataLen); in TYPED_TEST()
725 ASSERT_TRUE(this->mQueue->write(data, dataLen)); in TYPED_TEST()
726 bool ret = this->requestReadFmqSync(dataLen); in TYPED_TEST()
737 const size_t dataLen = 16; in TYPED_TEST() local
738 ASSERT_LE(dataLen, kNumElementsInSyncQueue); in TYPED_TEST()
740 int32_t data[dataLen]; in TYPED_TEST()
741 initData(data, dataLen); in TYPED_TEST()
744 ASSERT_TRUE(this->mQueue->beginWrite(dataLen, &tx)); in TYPED_TEST()
753 for (size_t i = 0; i < dataLen; i++) { in TYPED_TEST()
761 ASSERT_TRUE(this->mQueue->commitWrite(dataLen)); in TYPED_TEST()
763 auto ret = this->requestReadFmqSync(dataLen); in TYPED_TEST()
945 const size_t dataLen = 16; in TYPED_TEST() local
946 ASSERT_LE(dataLen, this->mNumMessagesMax); in TYPED_TEST()
947 bool ret = this->requestWriteFmqUnsync(dataLen, this->mService); in TYPED_TEST()
949 int32_t readData[dataLen] = {}; in TYPED_TEST()
950 ASSERT_TRUE(this->mQueue->read(readData, dataLen)); in TYPED_TEST()
951 ASSERT_TRUE(verifyData(readData, dataLen)); in TYPED_TEST()
959 const size_t dataLen = 16; in TYPED_TEST() local
960 ASSERT_LE(dataLen, this->mNumMessagesMax); in TYPED_TEST()
961 int32_t data[dataLen]; in TYPED_TEST()
962 initData(data, dataLen); in TYPED_TEST()
963 ASSERT_TRUE(this->mQueue->write(data, dataLen)); in TYPED_TEST()
964 bool ret = this->requestReadFmqUnsync(dataLen, this->mService); in TYPED_TEST()
1117 const size_t dataLen = 16; in TYPED_TEST() local
1118 ASSERT_LE(dataLen, this->mNumMessagesMax); in TYPED_TEST()
1120 bool ret = this->requestWriteFmqUnsync(dataLen, this->mService); in TYPED_TEST()
1126 int32_t readData[dataLen] = {}; in TYPED_TEST()
1127 ASSERT_TRUE(mQueue2->read(readData, dataLen)); in TYPED_TEST()
1128 ASSERT_TRUE(verifyData(readData, dataLen)); in TYPED_TEST()
1133 int32_t readData[dataLen] = {}; in TYPED_TEST()
1134 ASSERT_TRUE(this->mQueue->read(readData, dataLen)); in TYPED_TEST()
1135 ASSERT_TRUE(verifyData(readData, dataLen)); in TYPED_TEST()