Lines Matching refs:data
240 inline void initData(uint8_t* data, size_t count) { in initData() argument
242 data[i] = i & 0xFF; in initData()
254 uint8_t data[dataLen]; in ReaderThreadBlocking() local
270 if ((efState & kFmqNotEmpty) && fmq->read(data, dataLen)) { in ReaderThreadBlocking()
287 uint8_t data[dataLen]; in ReaderThreadBlocking2() local
292 bool ret = fmq->readBlocking(data, in ReaderThreadBlocking2()
329 handle->data[0] = ashmemFd; in TEST_F()
346 handle->data[0] = ashmemFd; in TEST_F()
366 handle->data[0] = ashmemFd; in TEST_F()
416 uint8_t data[dataLen] = {12, 11, 10, 9}; in TEST_F() local
417 fmq->write(data, dataLen); in TEST_F()
422 ASSERT_EQ(data[0], readData[0]); in TEST_F()
423 ASSERT_EQ(data[1], readData[1]); in TEST_F()
424 ASSERT_EQ(data[2], readData[2]); in TEST_F()
425 ASSERT_EQ(data[3], readData[3]); in TEST_F()
455 uint8_t data[dataLen] = {12, 11, 10, 9}; in TEST_F() local
456 fmq->write(data, dataLen); in TEST_F()
463 ASSERT_EQ(data[0], readData[0]); in TEST_F()
464 ASSERT_EQ(data[1], readData[1]); in TEST_F()
465 ASSERT_EQ(data[2], readData[2]); in TEST_F()
466 ASSERT_EQ(data[3], readData[3]); in TEST_F()
467 ASSERT_EQ(data[0], readData2[0]); in TEST_F()
468 ASSERT_EQ(data[1], readData2[1]); in TEST_F()
469 ASSERT_EQ(data[2], readData2[2]); in TEST_F()
470 ASSERT_EQ(data[3], readData2[3]); in TEST_F()
478 mqHandle->data[0] = 12; in TEST_F()
479 mqHandle->data[1] = 5; in TEST_F()
500 mqHandle->data[0] = ::ashmem_create_region("ConvertMultipleFds", 8); in TEST_F()
501 mqHandle->data[1] = ::ashmem_create_region("ConvertMultipleFds2", 8); in TEST_F()
623 uint8_t data[dataLen] = {0}; in TYPED_TEST() local
643 ASSERT_TRUE(this->mQueue->write(data, dataLen)); in TYPED_TEST()
660 uint8_t data[dataLen] = {0}; in TYPED_TEST() local
674 bool ret = this->mQueue->writeBlocking(data, dataLen, static_cast<uint32_t>(kFmqNotFull), in TYPED_TEST()
714 uint8_t data[dataLen] = {0}; in TYPED_TEST() local
716 bool ret = this->mQueue->writeBlocking(data, dataLen, static_cast<uint32_t>(kFmqNotFull), in TYPED_TEST()
728 uint8_t data[dataLen]; in TYPED_TEST() local
730 initData(data, dataLen); in TYPED_TEST()
732 ASSERT_TRUE(this->mQueue->write(data, dataLen)); in TYPED_TEST()
735 ASSERT_EQ(0, memcmp(data, readData, dataLen)); in TYPED_TEST()
745 uint8_t data[dataLen]; in TYPED_TEST() local
747 initData(data, dataLen); in TYPED_TEST()
752 ASSERT_TRUE(tx.copyTo(data, 0 /* startIdx */, dataLen)); in TYPED_TEST()
764 ASSERT_EQ(0, memcmp(data, readData, dataLen)); in TYPED_TEST()
774 uint8_t data[dataLen]; in TYPED_TEST() local
776 initData(data, dataLen); in TYPED_TEST()
786 *ptr = data[i]; in TYPED_TEST()
807 ASSERT_EQ(0, memcmp(data, readData, dataLen)); in TYPED_TEST()
846 std::vector<uint8_t> data(this->mNumMessagesMax); in TYPED_TEST() local
848 initData(&data[0], this->mNumMessagesMax); in TYPED_TEST()
849 ASSERT_TRUE(this->mQueue->write(&data[0], this->mNumMessagesMax)); in TYPED_TEST()
851 ASSERT_FALSE(this->mQueue->write(&data[0], 1)); in TYPED_TEST()
855 ASSERT_EQ(data, readData); in TYPED_TEST()
864 std::vector<uint8_t> data(this->mNumMessagesMax); in TYPED_TEST() local
866 initData(&data[0], this->mNumMessagesMax); in TYPED_TEST()
867 ASSERT_TRUE(this->mQueue->write(&data[0], this->mNumMessagesMax)); in TYPED_TEST()
886 std::vector<uint8_t> data(this->mNumMessagesMax); in TYPED_TEST() local
887 initData(&data[0], this->mNumMessagesMax); in TYPED_TEST()
888 ASSERT_TRUE(this->mQueue->write(&data[0], this->mNumMessagesMax)); in TYPED_TEST()
891 ASSERT_EQ(data, readData); in TYPED_TEST()
903 std::vector<uint8_t> data(dataLen); in TYPED_TEST() local
905 initData(&data[0], dataLen); in TYPED_TEST()
906 ASSERT_FALSE(this->mQueue->write(&data[0], dataLen)); in TYPED_TEST()
909 ASSERT_NE(data, readData); in TYPED_TEST()
919 std::vector<uint8_t> data(this->mNumMessagesMax); in TYPED_TEST() local
920 initData(&data[0], this->mNumMessagesMax); in TYPED_TEST()
921 ASSERT_TRUE(this->mQueue->write(&data[0], this->mNumMessagesMax)); in TYPED_TEST()
922 ASSERT_FALSE(this->mQueue->write(&data[0], 1)); in TYPED_TEST()
925 ASSERT_EQ(data, readData); in TYPED_TEST()
956 uint8_t data[dataLen]; in TYPED_TEST() local
958 initData(data, dataLen); in TYPED_TEST()
959 ASSERT_TRUE(this->mQueue->write(data, dataLen)); in TYPED_TEST()
964 ASSERT_EQ(0, memcmp(readData, data, dataLen)); in TYPED_TEST()
975 uint8_t data[dataLen]; in TYPED_TEST() local
977 initData(data, dataLen); in TYPED_TEST()
979 ASSERT_TRUE(this->mQueue->write(data + i * chunkSize, chunkSize)); in TYPED_TEST()
983 ASSERT_EQ(0, memcmp(readData, data, dataLen)); in TYPED_TEST()
994 std::vector<uint8_t> data(this->mNumMessagesMax); in TYPED_TEST() local
996 initData(&data[0], this->mNumMessagesMax); in TYPED_TEST()
997 ASSERT_TRUE(this->mQueue->write(&data[0], numMessages)); in TYPED_TEST()
999 ASSERT_TRUE(this->mQueue->write(&data[0], this->mNumMessagesMax)); in TYPED_TEST()
1001 ASSERT_EQ(data, readData); in TYPED_TEST()
1014 std::vector<uint8_t> data(this->mNumMessagesMax); in TYPED_TEST() local
1016 initData(&data[0], this->mNumMessagesMax); in TYPED_TEST()
1017 ASSERT_TRUE(this->mQueue->write(&data[0], dataLen)); in TYPED_TEST()
1031 ASSERT_TRUE(tx.copyTo(&data[0], 0 /* startIdx */, this->mNumMessagesMax)); in TYPED_TEST()
1045 ASSERT_EQ(data, readData); in TYPED_TEST()
1054 uint8_t data[dataLen]; in TYPED_TEST() local
1056 initData(data, dataLen); in TYPED_TEST()
1057 ASSERT_TRUE(this->mQueue->write(data, dataLen)); in TYPED_TEST()
1060 ASSERT_EQ(0, memcmp(data, readData, dataLen)); in TYPED_TEST()
1080 std::vector<uint8_t> data(this->mNumMessagesMax); in TYPED_TEST() local
1082 initData(&data[0], this->mNumMessagesMax); in TYPED_TEST()
1083 ASSERT_TRUE(this->mQueue->write(&data[0], this->mNumMessagesMax)); in TYPED_TEST()
1085 ASSERT_TRUE(this->mQueue->write(&data[0], 1)); in TYPED_TEST()
1098 std::vector<uint8_t> data(this->mNumMessagesMax); in TYPED_TEST() local
1099 ASSERT_TRUE(this->mQueue->write(&data[0], this->mNumMessagesMax)); in TYPED_TEST()
1106 ASSERT_TRUE(tx.copyTo(&data[0], 0 /* startIdx */)); in TYPED_TEST()
1120 std::vector<uint8_t> data(this->mNumMessagesMax); in TYPED_TEST() local
1121 initData(&data[0], this->mNumMessagesMax); in TYPED_TEST()
1122 ASSERT_TRUE(this->mQueue->write(&data[0], this->mNumMessagesMax)); in TYPED_TEST()
1125 ASSERT_EQ(data, readData); in TYPED_TEST()
1137 std::vector<uint8_t> data(dataLen); in TYPED_TEST() local
1138 initData(&data[0], dataLen); in TYPED_TEST()
1139 ASSERT_FALSE(this->mQueue->write(&data[0], dataLen)); in TYPED_TEST()
1142 ASSERT_NE(data, readData); in TYPED_TEST()
1152 std::vector<uint8_t> data(this->mNumMessagesMax); in TYPED_TEST() local
1153 initData(&data[0], this->mNumMessagesMax); in TYPED_TEST()
1154 ASSERT_TRUE(this->mQueue->write(&data[0], this->mNumMessagesMax)); in TYPED_TEST()
1155 ASSERT_TRUE(this->mQueue->write(&data[0], 1)); in TYPED_TEST()
1168 uint8_t data[dataLen]; in TYPED_TEST() local
1169 initData(data, dataLen); in TYPED_TEST()
1170 ASSERT_TRUE(this->mQueue->write(data, dataLen)); in TYPED_TEST()
1175 ASSERT_EQ(0, memcmp(readData, data, dataLen)); in TYPED_TEST()
1186 uint8_t data[dataLen]; in TYPED_TEST() local
1188 initData(data, dataLen); in TYPED_TEST()
1190 ASSERT_TRUE(this->mQueue->write(data + i * chunkSize, chunkSize)); in TYPED_TEST()
1195 ASSERT_EQ(0, memcmp(readData, data, dataLen)); in TYPED_TEST()
1206 std::vector<uint8_t> data(this->mNumMessagesMax); in TYPED_TEST() local
1209 initData(&data[0], this->mNumMessagesMax); in TYPED_TEST()
1210 ASSERT_TRUE(this->mQueue->write(&data[0], numMessages)); in TYPED_TEST()
1212 ASSERT_TRUE(this->mQueue->write(&data[0], this->mNumMessagesMax)); in TYPED_TEST()
1214 ASSERT_EQ(data, readData); in TYPED_TEST()