Lines Matching refs:dataLen
143 const size_t dataLen = 64; in ReaderThreadBlocking() local
144 uint8_t data[dataLen]; in ReaderThreadBlocking()
160 if ((efState & kFmqNotEmpty) && fmq->read(data, dataLen)) { in ReaderThreadBlocking()
178 const size_t dataLen = 64; in ReaderThreadBlocking2() local
179 uint8_t data[dataLen]; in ReaderThreadBlocking2()
185 dataLen, in ReaderThreadBlocking2()
213 const size_t dataLen = 64; in TEST_F() local
214 uint8_t data[dataLen] = {0}; in TEST_F()
233 ASSERT_TRUE(mQueue->write(data, dataLen)); in TEST_F()
249 const size_t dataLen = 64; in TEST_F() local
250 uint8_t data[dataLen] = {0}; in TEST_F()
264 dataLen, in TEST_F()
305 const size_t dataLen = 64; in TEST_F() local
306 uint8_t data[dataLen] = {0}; in TEST_F()
309 dataLen, in TEST_F()
320 const size_t dataLen = 16; in TEST_F() local
321 ASSERT_LE(dataLen, mNumMessagesMax); in TEST_F()
322 uint8_t data[dataLen]; in TEST_F()
324 initData(data, dataLen); in TEST_F()
326 ASSERT_TRUE(mQueue->write(data, dataLen)); in TEST_F()
327 uint8_t readData[dataLen] = {}; in TEST_F()
328 ASSERT_TRUE(mQueue->read(readData, dataLen)); in TEST_F()
329 ASSERT_EQ(0, memcmp(data, readData, dataLen)); in TEST_F()
337 const size_t dataLen = 16; in TEST_F() local
338 ASSERT_LE(dataLen, mNumMessagesMax); in TEST_F()
339 uint8_t data[dataLen]; in TEST_F()
341 initData(data, dataLen); in TEST_F()
344 ASSERT_TRUE(mQueue->beginWrite(dataLen, &tx)); in TEST_F()
346 ASSERT_TRUE(tx.copyTo(data, 0 /* startIdx */, dataLen)); in TEST_F()
348 ASSERT_TRUE(mQueue->commitWrite(dataLen)); in TEST_F()
350 uint8_t readData[dataLen] = {}; in TEST_F()
352 ASSERT_TRUE(mQueue->beginRead(dataLen, &tx)); in TEST_F()
354 ASSERT_TRUE(tx.copyFrom(readData, 0 /* startIdx */, dataLen)); in TEST_F()
356 ASSERT_TRUE(mQueue->commitRead(dataLen)); in TEST_F()
358 ASSERT_EQ(0, memcmp(data, readData, dataLen)); in TEST_F()
366 const size_t dataLen = 16; in TEST_F() local
367 ASSERT_LE(dataLen, mNumMessagesMax); in TEST_F()
368 uint8_t data[dataLen]; in TEST_F()
370 initData(data, dataLen); in TEST_F()
372 ASSERT_TRUE(mQueue->beginWrite(dataLen, &tx)); in TEST_F()
377 ASSERT_EQ(first.getLength() + second.getLength(), dataLen); in TEST_F()
378 for (size_t i = 0; i < dataLen; i++) { in TEST_F()
383 ASSERT_TRUE(mQueue->commitWrite(dataLen)); in TEST_F()
385 uint8_t readData[dataLen] = {}; in TEST_F()
387 ASSERT_TRUE(mQueue->beginRead(dataLen, &tx)); in TEST_F()
392 ASSERT_EQ(first.getLength() + second.getLength(), dataLen); in TEST_F()
394 for (size_t i = 0; i < dataLen; i++) { in TEST_F()
399 ASSERT_TRUE(mQueue->commitRead(dataLen)); in TEST_F()
401 ASSERT_EQ(0, memcmp(data, readData, dataLen)); in TEST_F()
409 const size_t dataLen = 2; in TEST_F() local
410 ASSERT_LE(dataLen, mNumMessagesMax); in TEST_F()
411 uint8_t readData[dataLen]; in TEST_F()
412 ASSERT_FALSE(mQueue->read(readData, dataLen)); in TEST_F()
421 const size_t dataLen = 2; in TEST_F() local
422 ASSERT_LE(dataLen, mNumMessagesMax); in TEST_F()
425 ASSERT_FALSE(mQueue->beginRead(dataLen, &tx)); in TEST_F()
495 const size_t dataLen = 4096; in TEST_F() local
496 ASSERT_GT(dataLen, mNumMessagesMax); in TEST_F()
497 std::vector<uint8_t> data(dataLen); in TEST_F()
499 initData(&data[0], dataLen); in TEST_F()
500 ASSERT_FALSE(mQueue->write(&data[0], dataLen)); in TEST_F()
529 const size_t dataLen = 4096; in TEST_F() local
530 ASSERT_GT(dataLen, mNumMessagesMax); in TEST_F()
533 ASSERT_FALSE(mQueue->beginWrite(dataLen, &tx)); in TEST_F()
548 const size_t dataLen = chunkSize * chunkNum; in TEST_F() local
549 ASSERT_LE(dataLen, mNumMessagesMax); in TEST_F()
550 uint8_t data[dataLen]; in TEST_F()
552 initData(data, dataLen); in TEST_F()
553 ASSERT_TRUE(mQueue->write(data, dataLen)); in TEST_F()
554 uint8_t readData[dataLen] = {}; in TEST_F()
558 ASSERT_EQ(0, memcmp(readData, data, dataLen)); in TEST_F()
567 const size_t dataLen = chunkSize * chunkNum; in TEST_F() local
568 ASSERT_LE(dataLen, mNumMessagesMax); in TEST_F()
569 uint8_t data[dataLen]; in TEST_F()
571 initData(data, dataLen); in TEST_F()
575 uint8_t readData[dataLen] = {}; in TEST_F()
576 ASSERT_TRUE(mQueue->read(readData, dataLen)); in TEST_F()
577 ASSERT_EQ(0, memcmp(readData, data, dataLen)); in TEST_F()
607 size_t dataLen = mNumMessagesMax - 1; in TEST_F() local
611 ASSERT_TRUE(mQueue->write(&data[0], dataLen)); in TEST_F()
612 ASSERT_TRUE(mQueue->read(&readData[0], dataLen)); in TEST_F()
646 const size_t dataLen = 16; in TEST_F() local
647 ASSERT_LE(dataLen, mNumMessagesMax); in TEST_F()
648 uint8_t data[dataLen]; in TEST_F()
650 initData(data, dataLen); in TEST_F()
651 ASSERT_TRUE(mQueue->write(data, dataLen)); in TEST_F()
652 uint8_t readData[dataLen] = {}; in TEST_F()
653 ASSERT_TRUE(mQueue->read(readData, dataLen)); in TEST_F()
654 ASSERT_EQ(0, memcmp(data, readData, dataLen)); in TEST_F()
662 const size_t dataLen = 2; in TEST_F() local
663 ASSERT_TRUE(dataLen < mNumMessagesMax); in TEST_F()
664 uint8_t readData[dataLen]; in TEST_F()
665 ASSERT_FALSE(mQueue->read(readData, dataLen)); in TEST_F()
729 const size_t dataLen = 4096; in TEST_F() local
730 ASSERT_GT(dataLen, mNumMessagesMax); in TEST_F()
731 std::vector<uint8_t> data(dataLen); in TEST_F()
732 initData(&data[0], dataLen); in TEST_F()
733 ASSERT_FALSE(mQueue->write(&data[0], dataLen)); in TEST_F()
760 const size_t dataLen = chunkSize * chunkNum; in TEST_F() local
761 ASSERT_LE(dataLen, mNumMessagesMax); in TEST_F()
762 uint8_t data[dataLen]; in TEST_F()
763 initData(data, dataLen); in TEST_F()
764 ASSERT_TRUE(mQueue->write(data, dataLen)); in TEST_F()
765 uint8_t readData[dataLen] = {}; in TEST_F()
769 ASSERT_EQ(0, memcmp(readData, data, dataLen)); in TEST_F()
778 const size_t dataLen = chunkSize * chunkNum; in TEST_F() local
779 ASSERT_LE(dataLen, mNumMessagesMax); in TEST_F()
780 uint8_t data[dataLen]; in TEST_F()
782 initData(data, dataLen); in TEST_F()
787 uint8_t readData[dataLen] = {}; in TEST_F()
788 ASSERT_TRUE(mQueue->read(readData, dataLen)); in TEST_F()
789 ASSERT_EQ(0, memcmp(readData, data, dataLen)); in TEST_F()