fuzzer.c - OpenGrok cross reference for /third

Lines Matching refs:messageSize
1240             U32 messageSize = (FUZ_rand(&randState) & maxMessageSizeMask) + 1;
1253             while (iNext + messageSize < testCompressedSize) {
1255                 XXH64_update(&xxhOrig, testInput + iNext, messageSize);
1258                 memcpy (ringBuffer + rNext, testInput + iNext, messageSize);
1259                 compressedSize = LZ4_compress_fast_continue(&streamingState, ringBuffer + rNext, testCompressed, (int)messageSize, testCompressedSize-ringBufferSize, 1);
1262                 { int const r = LZ4_decompress_safe_continue(&decodeStateSafe, testCompressed, testVerify + dNext, compressedSize, (int)messageSize);
1263                   FUZ_CHECKTEST(r!=(int)messageSize, "ringBuffer : LZ4_decompress_safe_continue() test failed"); }
1265                 XXH64_update(&xxhNewSafe, testVerify + dNext, messageSize);
1269                 { int const r = LZ4_decompress_fast_continue(&decodeStateFast, testCompressed, testVerify + dNext, (int)messageSize);
1272                 XXH64_update(&xxhNewFast, testVerify + dNext, messageSize);
1277                 iNext += messageSize;
1278                 rNext += messageSize;
1279                 dNext += messageSize;
1280                 messageSize = (FUZ_rand(&randState) & maxMessageSizeMask) + 1;
1281                 if (rNext + messageSize > ringBufferSize) rNext = 0;
1282                 if (dNext + messageSize > dBufferSize) dNext = 0;
1487             U32 messageSize = (FUZ_rand(&randState) & maxMessageSizeMask) + 1;
1500             while (iNext + messageSize < testCompressedSize) {
1503                 XXH64_update(&xxhOrig, testInput + iNext, messageSize);
1506                 memcpy (ringBuffer + rNext, testInput + iNext, messageSize);
1507                 assert(messageSize < INT_MAX);
1508                 compressedSize = LZ4_compress_HC_continue(&sHC, ringBuffer + rNext, testCompressed, (int)messageSize, testCompressedSize-ringBufferSize);
1512                 assert(messageSize < INT_MAX);
1513                 result = LZ4_decompress_safe_continue(&decodeStateSafe, testCompressed, testVerify + dNext, compressedSize, (int)messageSize);
1514                 FUZ_CHECKTEST(result!=(int)messageSize, "ringBuffer : LZ4_decompress_safe_continue() test failed");
1516                 XXH64_update(&xxhNewSafe, testVerify + dNext, messageSize);
1520                 assert(messageSize < INT_MAX);
1521                 result = LZ4_decompress_fast_continue(&decodeStateFast, testCompressed, testVerify + dNext, (int)messageSize);
1524                 XXH64_update(&xxhNewFast, testVerify + dNext, messageSize);
1529                 iNext += messageSize;
1530                 rNext += messageSize;
1531                 dNext += messageSize;
1532                 messageSize = (FUZ_rand(&randState) & maxMessageSizeMask) + 1;
1533                 if (rNext + messageSize > ringBufferSize) rNext = 0;
1534                 if (dNext + messageSize > dBufferSize) dNext = 0;
1551             int messageSize;
1571             messageSize = BSIZE1;   /* note : we cheat a bit here, in theory no message should be > maxMessageSize. We just want to fill the decoding ring buffer once. */
1572             XXH64_update(&xxhOrig, testInput + iNext, (size_t)messageSize);
1575             compressedSize = LZ4_compress_HC_continue(&sHC, testInput + iNext, testCompressed, messageSize, testCompressedSize-ringBufferSize);
1579             result = LZ4_decompress_safe_continue(&decodeStateSafe, testCompressed, ringBufferSafe + dNext, compressedSize, messageSize);
1580             FUZ_CHECKTEST(result!=messageSize, "64K D.ringBuffer : LZ4_decompress_safe_continue() test failed");
1582             XXH64_update(&xxhNewSafe, ringBufferSafe + dNext, (size_t)messageSize);
1586             result = LZ4_decompress_fast_continue(&decodeStateFast, testCompressed, ringBufferFast + dNext, messageSize);
1589             XXH64_update(&xxhNewFast, ringBufferFast + dNext, (size_t)messageSize);
1594             dNext += messageSize;
1595             assert(messageSize >= 0);
1596             totalMessageSize += (unsigned)messageSize;
1597             messageSize = maxMessageSize;
1600             memcpy(testInput + iNext, testInput + (BSIZE1-65535), messageSize);  /* will generate a match at max distance == 65535 */
1601             FUZ_CHECKTEST(dNext+messageSize <= dBufferSize, "Ring buffer test : second message should require restarting from beginning");
1605                 XXH64_update(&xxhOrig, testInput + iNext, (size_t)messageSize);
1608                 compressedSize = LZ4_compress_HC_continue(&sHC, testInput + iNext, testCompressed, messageSize, testCompressedSize-ringBufferSize);
1611                 DISPLAYLEVEL(5, "compressed %i bytes to %i bytes \n", messageSize, compressedSize);
1618                                                       compressedSize, dBufferSize - dNext);   /* works without knowing messageSize, under assumption that messageSize <= maxMessageSize */
1619                 FUZ_CHECKTEST(result!=messageSize, "D.ringBuffer : LZ4_decompress_safe_continue() test failed");
1620                 XXH64_update(&xxhNewSafe, ringBufferSafe + dNext, (size_t)messageSize);
1627                 result = LZ4_decompress_fast_continue(&decodeStateFast, testCompressed, ringBufferFast + dNext, messageSize);
1629                 XXH64_update(&xxhNewFast, ringBufferFast + dNext, (size_t)messageSize);
1636                 dNext += messageSize;
1637                 assert(messageSize >= 0);
1638                 totalMessageSize += (unsigned)messageSize;
1639                 messageSize = (FUZ_rand(&randState) & maxMessageSizeMask) + 1;