Lines Matching refs:data
305 bool verifyData(int32_t* data, size_t count) { in verifyData() argument
307 if (data[i] != i) return false; in verifyData()
315 inline void initData(int32_t* data, size_t count) { in initData() argument
317 data[i] = i; in initData()
419 std::array<int32_t, dataLen> data = {0}; in TYPED_TEST() local
421 data.data(), data.size(), in TYPED_TEST()
428 std::array<int32_t, kNumElementsInSyncQueue> data = {0}; in TYPED_TEST() local
430 data.data(), data.size(), in TYPED_TEST()
457 std::array<int32_t, dataLen> data = {0}; in TYPED_TEST() local
458 ret = this->mQueue->writeBlocking(data.data(), data.size()); in TYPED_TEST()
467 std::array<int32_t, kNumElementsInSyncQueue> data = {0}; in TYPED_TEST() local
468 ret = this->mQueue->writeBlocking(data.data(), data.size(), 5000000000 /* timeOutNanos */); in TYPED_TEST()
493 std::array<int32_t, dataLen> data = {0}; in TYPED_TEST() local
496 data.data(), data.size(), in TYPED_TEST()
508 std::array<int32_t, kNumElementsInSyncQueue> data = {0}; in TYPED_TEST() local
510 data.data(), data.size(), in TYPED_TEST()
539 std::array<int32_t, dataLen> data = {0}; in TYPED_TEST() local
542 data.data(), data.size(), in TYPED_TEST()
554 std::array<int32_t, kNumElementsInSyncQueue> data = {0}; in TYPED_TEST() local
556 data.data(), data.size(), in TYPED_TEST()
584 std::array<int32_t, dataLen> data = {0}; in TYPED_TEST() local
587 data.data(), data.size(), in TYPED_TEST()
599 std::array<int32_t, kNumElementsInSyncQueue> data = {0}; in TYPED_TEST() local
601 data.data(), data.size(), in TYPED_TEST()
614 int32_t data = 0; in TYPED_TEST() local
620 &data, 0, static_cast<uint32_t>(ITestMsgQ::EventFlagBits::FMQ_NOT_FULL), in TYPED_TEST()
628 &data, 0, static_cast<uint32_t>(ITestMsgQ::EventFlagBits::FMQ_NOT_FULL), in TYPED_TEST()
725 int32_t data[dataLen]; in TYPED_TEST() local
726 initData(data, dataLen); in TYPED_TEST()
727 ASSERT_TRUE(this->mQueue->write(data, dataLen)); in TYPED_TEST()
742 int32_t data[dataLen]; in TYPED_TEST() local
743 initData(data, dataLen); in TYPED_TEST()
792 std::array<int32_t, kNumElementsInSyncQueue> data = {0}; in TYPED_TEST() local
793 initData(data.data(), data.size()); in TYPED_TEST()
794 ASSERT_TRUE(this->mQueue->write(data.data(), data.size())); in TYPED_TEST()
796 ASSERT_FALSE(this->mQueue->write(&data[0], 1)); in TYPED_TEST()
797 bool ret = this->requestReadFmqSync(data.size()); in TYPED_TEST()
839 std::array<int32_t, kNumElementsInSyncQueue> data = {0}; in TYPED_TEST() local
840 initData(data.data(), data.size()); in TYPED_TEST()
841 ASSERT_TRUE(this->mQueue->write(data.data(), data.size())); in TYPED_TEST()
843 ASSERT_FALSE(this->mQueue->write(data.data(), 1)); in TYPED_TEST()
845 bool ret = this->requestReadFmqSync(data.size()); in TYPED_TEST()
879 int32_t data[numMessages]; in TYPED_TEST() local
880 initData(&data[0], numMessages); in TYPED_TEST()
883 ASSERT_TRUE(this->mQueue->write(data + i * chunkSize, chunkSize)); in TYPED_TEST()
897 std::array<int32_t, kNumElementsInSyncQueue> data = {0}; in TYPED_TEST() local
898 initData(data.data(), data.size()); in TYPED_TEST()
899 ASSERT_TRUE(this->mQueue->write(&data[0], numMessages)); in TYPED_TEST()
902 ASSERT_TRUE(this->mQueue->write(data.data(), data.size())); in TYPED_TEST()
903 ret = this->requestReadFmqSync(data.size()); in TYPED_TEST()
917 std::array<int32_t, kNumElementsInSyncQueue> data = {0}; in TYPED_TEST() local
918 initData(data.data(), data.size()); in TYPED_TEST()
919 ASSERT_TRUE(this->mQueue->write(&data[0], numMessages)); in TYPED_TEST()
927 ASSERT_TRUE(this->mQueue->beginWrite(data.size(), &tx)); in TYPED_TEST()
929 ASSERT_EQ(tx.getFirstRegion().getLength() + tx.getSecondRegion().getLength(), data.size()); in TYPED_TEST()
931 for (size_t i = 0; i < data.size(); i++) { in TYPED_TEST()
933 *ptr = data[i]; in TYPED_TEST()
936 ASSERT_TRUE(this->mQueue->commitWrite(data.size())); in TYPED_TEST()
938 ret = this->requestReadFmqSync(data.size()); in TYPED_TEST()
963 int32_t data[dataLen]; in TYPED_TEST() local
964 initData(data, dataLen); in TYPED_TEST()
965 ASSERT_TRUE(this->mQueue->write(data, dataLen)); in TYPED_TEST()
991 std::vector<int32_t> data(this->mNumMessagesMax); in TYPED_TEST() local
992 initData(&data[0], this->mNumMessagesMax); in TYPED_TEST()
993 ASSERT_TRUE(this->mQueue->write(&data[0], this->mNumMessagesMax)); in TYPED_TEST()
995 ASSERT_TRUE(this->mQueue->write(&data[0], 1)); in TYPED_TEST()
1008 std::vector<int32_t> data(this->mNumMessagesMax); in TYPED_TEST() local
1009 ASSERT_TRUE(this->mQueue->read(&data[0], this->mNumMessagesMax)); in TYPED_TEST()
1010 ASSERT_TRUE(verifyData(&data[0], this->mNumMessagesMax)); in TYPED_TEST()
1038 std::vector<int32_t> data(this->mNumMessagesMax); in TYPED_TEST() local
1039 initData(&data[0], this->mNumMessagesMax); in TYPED_TEST()
1040 ASSERT_TRUE(this->mQueue->write(&data[0], this->mNumMessagesMax)); in TYPED_TEST()
1042 ASSERT_TRUE(this->mQueue->write(&data[0], 1)); in TYPED_TEST()
1046 ASSERT_TRUE(this->mQueue->write(&data[0], this->mNumMessagesMax)); in TYPED_TEST()
1082 int32_t data[numMessages]; in TYPED_TEST() local
1083 initData(data, numMessages); in TYPED_TEST()
1085 ASSERT_TRUE(this->mQueue->write(data + i * chunkSize, chunkSize)); in TYPED_TEST()
1099 std::vector<int32_t> data(this->mNumMessagesMax); in TYPED_TEST() local
1100 initData(&data[0], this->mNumMessagesMax); in TYPED_TEST()
1101 ASSERT_TRUE(this->mQueue->write(&data[0], numMessages)); in TYPED_TEST()
1104 ASSERT_TRUE(this->mQueue->write(&data[0], this->mNumMessagesMax)); in TYPED_TEST()