Lines Matching refs:data
128 inline void initData(uint8_t* data, size_t count) { in initData() argument
130 data[i] = i & 0xFF; in initData()
144 uint8_t data[dataLen]; in ReaderThreadBlocking() local
160 if ((efState & kFmqNotEmpty) && fmq->read(data, dataLen)) { in ReaderThreadBlocking()
179 uint8_t data[dataLen]; in ReaderThreadBlocking2() local
184 bool ret = fmq->readBlocking(data, in ReaderThreadBlocking2()
214 uint8_t data[dataLen] = {0}; in TEST_F() local
233 ASSERT_TRUE(mQueue->write(data, dataLen)); in TEST_F()
250 uint8_t data[dataLen] = {0}; in TEST_F() local
263 bool ret = mQueue->writeBlocking(data, in TEST_F()
306 uint8_t data[dataLen] = {0}; in TEST_F() local
308 bool ret = mQueue->writeBlocking(data, in TEST_F()
322 uint8_t data[dataLen]; in TEST_F() local
324 initData(data, dataLen); in TEST_F()
326 ASSERT_TRUE(mQueue->write(data, dataLen)); in TEST_F()
329 ASSERT_EQ(0, memcmp(data, readData, dataLen)); in TEST_F()
339 uint8_t data[dataLen]; in TEST_F() local
341 initData(data, dataLen); in TEST_F()
346 ASSERT_TRUE(tx.copyTo(data, 0 /* startIdx */, dataLen)); in TEST_F()
358 ASSERT_EQ(0, memcmp(data, readData, dataLen)); in TEST_F()
368 uint8_t data[dataLen]; in TEST_F() local
370 initData(data, dataLen); in TEST_F()
380 *ptr = data[i]; in TEST_F()
401 ASSERT_EQ(0, memcmp(data, readData, dataLen)); in TEST_F()
440 std::vector<uint8_t> data(mNumMessagesMax); in TEST_F() local
442 initData(&data[0], mNumMessagesMax); in TEST_F()
443 ASSERT_TRUE(mQueue->write(&data[0], mNumMessagesMax)); in TEST_F()
445 ASSERT_FALSE(mQueue->write(&data[0], 1)); in TEST_F()
449 ASSERT_EQ(data, readData); in TEST_F()
458 std::vector<uint8_t> data(mNumMessagesMax); in TEST_F() local
460 initData(&data[0], mNumMessagesMax); in TEST_F()
461 ASSERT_TRUE(mQueue->write(&data[0], mNumMessagesMax)); in TEST_F()
480 std::vector<uint8_t> data(mNumMessagesMax); in TEST_F() local
481 initData(&data[0], mNumMessagesMax); in TEST_F()
482 ASSERT_TRUE(mQueue->write(&data[0], mNumMessagesMax)); in TEST_F()
485 ASSERT_EQ(data, readData); in TEST_F()
497 std::vector<uint8_t> data(dataLen); in TEST_F() local
499 initData(&data[0], dataLen); in TEST_F()
500 ASSERT_FALSE(mQueue->write(&data[0], dataLen)); in TEST_F()
503 ASSERT_NE(data, readData); in TEST_F()
513 std::vector<uint8_t> data(mNumMessagesMax); in TEST_F() local
514 initData(&data[0], mNumMessagesMax); in TEST_F()
515 ASSERT_TRUE(mQueue->write(&data[0], mNumMessagesMax)); in TEST_F()
516 ASSERT_FALSE(mQueue->write(&data[0], 1)); in TEST_F()
519 ASSERT_EQ(data, readData); in TEST_F()
550 uint8_t data[dataLen]; in TEST_F() local
552 initData(data, dataLen); in TEST_F()
553 ASSERT_TRUE(mQueue->write(data, dataLen)); in TEST_F()
558 ASSERT_EQ(0, memcmp(readData, data, dataLen)); in TEST_F()
569 uint8_t data[dataLen]; in TEST_F() local
571 initData(data, dataLen); in TEST_F()
573 ASSERT_TRUE(mQueue->write(data + i * chunkSize, chunkSize)); in TEST_F()
577 ASSERT_EQ(0, memcmp(readData, data, dataLen)); in TEST_F()
588 std::vector<uint8_t> data(mNumMessagesMax); in TEST_F() local
590 initData(&data[0], mNumMessagesMax); in TEST_F()
591 ASSERT_TRUE(mQueue->write(&data[0], numMessages)); in TEST_F()
593 ASSERT_TRUE(mQueue->write(&data[0], mNumMessagesMax)); in TEST_F()
595 ASSERT_EQ(data, readData); in TEST_F()
608 std::vector<uint8_t> data(mNumMessagesMax); in TEST_F() local
610 initData(&data[0], mNumMessagesMax); in TEST_F()
611 ASSERT_TRUE(mQueue->write(&data[0], dataLen)); in TEST_F()
625 ASSERT_TRUE(tx.copyTo(&data[0], 0 /* startIdx */, mNumMessagesMax)); in TEST_F()
639 ASSERT_EQ(data, readData); in TEST_F()
648 uint8_t data[dataLen]; in TEST_F() local
650 initData(data, dataLen); in TEST_F()
651 ASSERT_TRUE(mQueue->write(data, dataLen)); in TEST_F()
654 ASSERT_EQ(0, memcmp(data, readData, dataLen)); in TEST_F()
674 std::vector<uint8_t> data(mNumMessagesMax); in TEST_F() local
676 initData(&data[0], mNumMessagesMax); in TEST_F()
677 ASSERT_TRUE(mQueue->write(&data[0], mNumMessagesMax)); in TEST_F()
679 ASSERT_TRUE(mQueue->write(&data[0], 1)); in TEST_F()
692 std::vector<uint8_t> data(mNumMessagesMax); in TEST_F() local
693 ASSERT_TRUE(mQueue->write(&data[0], mNumMessagesMax)); in TEST_F()
700 ASSERT_TRUE(tx.copyTo(&data[0], 0 /* startIdx */)); in TEST_F()
714 std::vector<uint8_t> data(mNumMessagesMax); in TEST_F() local
715 initData(&data[0], mNumMessagesMax); in TEST_F()
716 ASSERT_TRUE(mQueue->write(&data[0], mNumMessagesMax)); in TEST_F()
719 ASSERT_EQ(data, readData); in TEST_F()
731 std::vector<uint8_t> data(dataLen); in TEST_F() local
732 initData(&data[0], dataLen); in TEST_F()
733 ASSERT_FALSE(mQueue->write(&data[0], dataLen)); in TEST_F()
736 ASSERT_NE(data, readData); in TEST_F()
746 std::vector<uint8_t> data(mNumMessagesMax); in TEST_F() local
747 initData(&data[0], mNumMessagesMax); in TEST_F()
748 ASSERT_TRUE(mQueue->write(&data[0], mNumMessagesMax)); in TEST_F()
749 ASSERT_TRUE(mQueue->write(&data[0], 1)); in TEST_F()
762 uint8_t data[dataLen]; in TEST_F() local
763 initData(data, dataLen); in TEST_F()
764 ASSERT_TRUE(mQueue->write(data, dataLen)); in TEST_F()
769 ASSERT_EQ(0, memcmp(readData, data, dataLen)); in TEST_F()
780 uint8_t data[dataLen]; in TEST_F() local
782 initData(data, dataLen); in TEST_F()
784 ASSERT_TRUE(mQueue->write(data + i * chunkSize, chunkSize)); in TEST_F()
789 ASSERT_EQ(0, memcmp(readData, data, dataLen)); in TEST_F()
800 std::vector<uint8_t> data(mNumMessagesMax); in TEST_F() local
803 initData(&data[0], mNumMessagesMax); in TEST_F()
804 ASSERT_TRUE(mQueue->write(&data[0], numMessages)); in TEST_F()
806 ASSERT_TRUE(mQueue->write(&data[0], mNumMessagesMax)); in TEST_F()
808 ASSERT_EQ(data, readData); in TEST_F()