Lines Matching refs:dataLen
251 const size_t dataLen = 64; in ReaderThreadBlocking() local
252 uint8_t data[dataLen]; in ReaderThreadBlocking()
268 if ((efState & kFmqNotEmpty) && fmq->read(data, dataLen)) { in ReaderThreadBlocking()
284 const size_t dataLen = 64; in ReaderThreadBlocking2() local
285 uint8_t data[dataLen]; in ReaderThreadBlocking2()
291 dataLen, in ReaderThreadBlocking2()
348 constexpr size_t dataLen = 4; in TEST_F() local
349 uint8_t data[dataLen] = {12, 11, 10, 9}; in TEST_F()
350 fmq->write(data, dataLen); in TEST_F()
352 int8_t readData[dataLen]; in TEST_F()
353 ASSERT_TRUE(aidlFmq->read(readData, dataLen)); in TEST_F()
387 constexpr size_t dataLen = 4; in TEST_F() local
388 uint8_t data[dataLen] = {12, 11, 10, 9}; in TEST_F()
389 fmq->write(data, dataLen); in TEST_F()
391 int8_t readData[dataLen]; in TEST_F()
392 ASSERT_TRUE(aidlFmq->read(readData, dataLen)); in TEST_F()
393 int8_t readData2[dataLen]; in TEST_F()
394 ASSERT_TRUE(aidlFmq2->read(readData2, dataLen)); in TEST_F()
554 const size_t dataLen = 64; in TYPED_TEST() local
555 uint8_t data[dataLen] = {0}; in TYPED_TEST()
575 ASSERT_TRUE(this->mQueue->write(data, dataLen)); in TYPED_TEST()
591 const size_t dataLen = 64; in TYPED_TEST() local
592 uint8_t data[dataLen] = {0}; in TYPED_TEST()
606 bool ret = this->mQueue->writeBlocking(data, dataLen, static_cast<uint32_t>(kFmqNotFull), in TYPED_TEST()
645 const size_t dataLen = 64; in TYPED_TEST() local
646 uint8_t data[dataLen] = {0}; in TYPED_TEST()
648 bool ret = this->mQueue->writeBlocking(data, dataLen, static_cast<uint32_t>(kFmqNotFull), in TYPED_TEST()
658 const size_t dataLen = 16; in TYPED_TEST() local
659 ASSERT_LE(dataLen, this->mNumMessagesMax); in TYPED_TEST()
660 uint8_t data[dataLen]; in TYPED_TEST()
662 initData(data, dataLen); in TYPED_TEST()
664 ASSERT_TRUE(this->mQueue->write(data, dataLen)); in TYPED_TEST()
665 uint8_t readData[dataLen] = {}; in TYPED_TEST()
666 ASSERT_TRUE(this->mQueue->read(readData, dataLen)); in TYPED_TEST()
667 ASSERT_EQ(0, memcmp(data, readData, dataLen)); in TYPED_TEST()
675 const size_t dataLen = 16; in TYPED_TEST() local
676 ASSERT_LE(dataLen, this->mNumMessagesMax); in TYPED_TEST()
677 uint8_t data[dataLen]; in TYPED_TEST()
679 initData(data, dataLen); in TYPED_TEST()
682 ASSERT_TRUE(this->mQueue->beginWrite(dataLen, &tx)); in TYPED_TEST()
684 ASSERT_TRUE(tx.copyTo(data, 0 /* startIdx */, dataLen)); in TYPED_TEST()
686 ASSERT_TRUE(this->mQueue->commitWrite(dataLen)); in TYPED_TEST()
688 uint8_t readData[dataLen] = {}; in TYPED_TEST()
690 ASSERT_TRUE(this->mQueue->beginRead(dataLen, &tx)); in TYPED_TEST()
692 ASSERT_TRUE(tx.copyFrom(readData, 0 /* startIdx */, dataLen)); in TYPED_TEST()
694 ASSERT_TRUE(this->mQueue->commitRead(dataLen)); in TYPED_TEST()
696 ASSERT_EQ(0, memcmp(data, readData, dataLen)); in TYPED_TEST()
704 const size_t dataLen = 16; in TYPED_TEST() local
705 ASSERT_LE(dataLen, this->mNumMessagesMax); in TYPED_TEST()
706 uint8_t data[dataLen]; in TYPED_TEST()
708 initData(data, dataLen); in TYPED_TEST()
710 ASSERT_TRUE(this->mQueue->beginWrite(dataLen, &tx)); in TYPED_TEST()
715 ASSERT_EQ(first.getLength() + second.getLength(), dataLen); in TYPED_TEST()
716 for (size_t i = 0; i < dataLen; i++) { in TYPED_TEST()
721 ASSERT_TRUE(this->mQueue->commitWrite(dataLen)); in TYPED_TEST()
723 uint8_t readData[dataLen] = {}; in TYPED_TEST()
725 ASSERT_TRUE(this->mQueue->beginRead(dataLen, &tx)); in TYPED_TEST()
730 ASSERT_EQ(first.getLength() + second.getLength(), dataLen); in TYPED_TEST()
732 for (size_t i = 0; i < dataLen; i++) { in TYPED_TEST()
737 ASSERT_TRUE(this->mQueue->commitRead(dataLen)); in TYPED_TEST()
739 ASSERT_EQ(0, memcmp(data, readData, dataLen)); in TYPED_TEST()
747 const size_t dataLen = 2; in TYPED_TEST() local
748 ASSERT_LE(dataLen, this->mNumMessagesMax); in TYPED_TEST()
749 uint8_t readData[dataLen]; in TYPED_TEST()
750 ASSERT_FALSE(this->mQueue->read(readData, dataLen)); in TYPED_TEST()
759 const size_t dataLen = 2; in TYPED_TEST() local
760 ASSERT_LE(dataLen, this->mNumMessagesMax); in TYPED_TEST()
763 ASSERT_FALSE(this->mQueue->beginRead(dataLen, &tx)); in TYPED_TEST()
833 const size_t dataLen = 4096; in TYPED_TEST() local
834 ASSERT_GT(dataLen, this->mNumMessagesMax); in TYPED_TEST()
835 std::vector<uint8_t> data(dataLen); in TYPED_TEST()
837 initData(&data[0], dataLen); in TYPED_TEST()
838 ASSERT_FALSE(this->mQueue->write(&data[0], dataLen)); in TYPED_TEST()
867 const size_t dataLen = 4096; in TYPED_TEST() local
868 ASSERT_GT(dataLen, this->mNumMessagesMax); in TYPED_TEST()
871 ASSERT_FALSE(this->mQueue->beginWrite(dataLen, &tx)); in TYPED_TEST()
886 const size_t dataLen = chunkSize * chunkNum; in TYPED_TEST() local
887 ASSERT_LE(dataLen, this->mNumMessagesMax); in TYPED_TEST()
888 uint8_t data[dataLen]; in TYPED_TEST()
890 initData(data, dataLen); in TYPED_TEST()
891 ASSERT_TRUE(this->mQueue->write(data, dataLen)); in TYPED_TEST()
892 uint8_t readData[dataLen] = {}; in TYPED_TEST()
896 ASSERT_EQ(0, memcmp(readData, data, dataLen)); in TYPED_TEST()
905 const size_t dataLen = chunkSize * chunkNum; in TYPED_TEST() local
906 ASSERT_LE(dataLen, this->mNumMessagesMax); in TYPED_TEST()
907 uint8_t data[dataLen]; in TYPED_TEST()
909 initData(data, dataLen); in TYPED_TEST()
913 uint8_t readData[dataLen] = {}; in TYPED_TEST()
914 ASSERT_TRUE(this->mQueue->read(readData, dataLen)); in TYPED_TEST()
915 ASSERT_EQ(0, memcmp(readData, data, dataLen)); in TYPED_TEST()
945 size_t dataLen = this->mNumMessagesMax - 1; in TYPED_TEST() local
949 ASSERT_TRUE(this->mQueue->write(&data[0], dataLen)); in TYPED_TEST()
950 ASSERT_TRUE(this->mQueue->read(&readData[0], dataLen)); in TYPED_TEST()
984 const size_t dataLen = 16; in TYPED_TEST() local
985 ASSERT_LE(dataLen, this->mNumMessagesMax); in TYPED_TEST()
986 uint8_t data[dataLen]; in TYPED_TEST()
988 initData(data, dataLen); in TYPED_TEST()
989 ASSERT_TRUE(this->mQueue->write(data, dataLen)); in TYPED_TEST()
990 uint8_t readData[dataLen] = {}; in TYPED_TEST()
991 ASSERT_TRUE(this->mQueue->read(readData, dataLen)); in TYPED_TEST()
992 ASSERT_EQ(0, memcmp(data, readData, dataLen)); in TYPED_TEST()
1000 const size_t dataLen = 2; in TYPED_TEST() local
1001 ASSERT_TRUE(dataLen < this->mNumMessagesMax); in TYPED_TEST()
1002 uint8_t readData[dataLen]; in TYPED_TEST()
1003 ASSERT_FALSE(this->mQueue->read(readData, dataLen)); in TYPED_TEST()
1067 const size_t dataLen = 4096; in TYPED_TEST() local
1068 ASSERT_GT(dataLen, this->mNumMessagesMax); in TYPED_TEST()
1069 std::vector<uint8_t> data(dataLen); in TYPED_TEST()
1070 initData(&data[0], dataLen); in TYPED_TEST()
1071 ASSERT_FALSE(this->mQueue->write(&data[0], dataLen)); in TYPED_TEST()
1098 const size_t dataLen = chunkSize * chunkNum; in TYPED_TEST() local
1099 ASSERT_LE(dataLen, this->mNumMessagesMax); in TYPED_TEST()
1100 uint8_t data[dataLen]; in TYPED_TEST()
1101 initData(data, dataLen); in TYPED_TEST()
1102 ASSERT_TRUE(this->mQueue->write(data, dataLen)); in TYPED_TEST()
1103 uint8_t readData[dataLen] = {}; in TYPED_TEST()
1107 ASSERT_EQ(0, memcmp(readData, data, dataLen)); in TYPED_TEST()
1116 const size_t dataLen = chunkSize * chunkNum; in TYPED_TEST() local
1117 ASSERT_LE(dataLen, this->mNumMessagesMax); in TYPED_TEST()
1118 uint8_t data[dataLen]; in TYPED_TEST()
1120 initData(data, dataLen); in TYPED_TEST()
1125 uint8_t readData[dataLen] = {}; in TYPED_TEST()
1126 ASSERT_TRUE(this->mQueue->read(readData, dataLen)); in TYPED_TEST()
1127 ASSERT_EQ(0, memcmp(readData, data, dataLen)); in TYPED_TEST()