Lines Matching refs:inBuff
278 ZSTD_inBuffer inBuff, inBuff2; in basicUnitTests() local
308 inBuff.src = CNBuffer; in basicUnitTests()
309 inBuff.size = CNBufferSize; in basicUnitTests()
310 inBuff.pos = 0; in basicUnitTests()
311 CHECK_Z( ZSTD_compressStream(zc, &outBuff, &inBuff) ); in basicUnitTests()
312 if (inBuff.pos != inBuff.size) goto _output_error; /* entire input should be consumed */ in basicUnitTests()
329 inBuff.src = CNBuffer; in basicUnitTests()
330 inBuff.size = CNBufferSize; in basicUnitTests()
331 inBuff.pos = 0; in basicUnitTests()
332 CHECK_Z( ZSTD_compressStream(zc, &outBuff, &inBuff) ); in basicUnitTests()
333 if (inBuff.pos != inBuff.size) goto _output_error; /* entire input should be consumed */ in basicUnitTests()
383 inBuff.src = compressedBuffer; in basicUnitTests()
384 inBuff.size = cSize; in basicUnitTests()
385 inBuff.pos = 0; in basicUnitTests()
389 { size_t const r = ZSTD_decompressStream(zd, &outBuff, &inBuff); in basicUnitTests()
397 inBuff2 = inBuff; in basicUnitTests()
401 { size_t const remaining = ZSTD_decompressStream(zd, &outBuff, &inBuff); in basicUnitTests()
404 if (inBuff.pos != inBuff.size) goto _output_error; /* should have read the entire frame */ in basicUnitTests()
413 if (inBuff.pos != inBuff.size) goto _output_error; /* should have read the entire frame */ in basicUnitTests()
449 inBuff.src = compressedBuffer; in basicUnitTests()
451 inBuff.pos = 0; in basicUnitTests()
456 inBuff.size = inBuff.pos + inSize; in basicUnitTests()
458 r = ZSTD_decompressStream(zd, &outBuff, &inBuff); in basicUnitTests()
468 inBuff.size = inBuff.pos + inSize; in basicUnitTests()
470 r = ZSTD_decompressStream(zd, &outBuff, &inBuff); in basicUnitTests()
477 … if (inBuff.pos != cSize) DISPLAYLEVEL(4, "inBuff.pos != cSize : should have real all input ! \n"); in basicUnitTests()
478 if (inBuff.pos != cSize) goto _output_error; /* should have read the entire frame */ in basicUnitTests()
495 inBuff.src = compressedBuffer; in basicUnitTests()
496 inBuff.size = cSize; in basicUnitTests()
497 inBuff.pos = 0; in basicUnitTests()
505 r = ZSTD_decompressStream(zd, &outBuff, &inBuff); in basicUnitTests()
514 inBuff.src = NULL; in basicUnitTests()
515 inBuff.size = 0; in basicUnitTests()
516 inBuff.pos = 0; in basicUnitTests()
520 CHECK_Z( ZSTD_compressStream(zc, &outBuff, &inBuff) ); in basicUnitTests()
521 CHECK(inBuff.pos != inBuff.size, "Entire input should be consumed"); in basicUnitTests()
529 inBuff.src = outBuff.dst; in basicUnitTests()
530 inBuff.size = outBuff.pos; in basicUnitTests()
531 inBuff.pos = 0; in basicUnitTests()
536 { size_t const ret = ZSTD_decompressStream(zd, &outBuff, &inBuff); in basicUnitTests()
546 inBuff.src = CNBuffer; in basicUnitTests()
547 inBuff.size = CNBufferSize; in basicUnitTests()
548 inBuff.pos = 0; in basicUnitTests()
549 CHECK_Z( ZSTD_compressStream(zc, &outBuff, &inBuff) ); in basicUnitTests()
550 CHECK(inBuff.pos != inBuff.size, "Entire input should be consumed"); in basicUnitTests()
566 inBuff.src = CNBuffer; in basicUnitTests()
567 inBuff.size = CNBufferSize; in basicUnitTests()
568 inBuff.pos = 0; in basicUnitTests()
569 CHECK_Z( ZSTD_compressStream(zc, &outBuff, &inBuff) ); in basicUnitTests()
570 if (inBuff.pos != inBuff.size) goto _output_error; /* entire input should be consumed */ in basicUnitTests()
581 inBuff.src = CNBuffer; in basicUnitTests()
582 inBuff.size = CNBufferSize; in basicUnitTests()
583 inBuff.pos = 0; in basicUnitTests()
584 { size_t const r = ZSTD_compressStream(zc, &outBuff, &inBuff); in basicUnitTests()
596 inBuff.src = CNBuffer; in basicUnitTests()
597 inBuff.size = CNBufferSize; in basicUnitTests()
598 inBuff.pos = 0; in basicUnitTests()
599 { size_t const r = ZSTD_compressStream(zc, &outBuff, &inBuff); in basicUnitTests()
613 inBuff.src = CNBuffer; in basicUnitTests()
614 inBuff.size = inSize; in basicUnitTests()
615 inBuff.pos = 0; in basicUnitTests()
620 CHECK_Z( ZSTD_compressStream(zc, &outBuff, &inBuff) ); in basicUnitTests()
621 if (inBuff.pos != inBuff.size) goto _output_error; /* entire input should be consumed */ in basicUnitTests()
630 inBuff.src = CNBuffer; in basicUnitTests()
631 inBuff.size = inSize; in basicUnitTests()
632 inBuff.pos = 0; in basicUnitTests()
637 CHECK_Z( ZSTD_compressStream(zc, &outBuff, &inBuff) ); in basicUnitTests()
638 if (inBuff.pos != inBuff.size) goto _output_error; /* entire input should be consumed */ in basicUnitTests()
657 inBuff.src = compressedBuffer; in basicUnitTests()
658 inBuff.size = cSize; in basicUnitTests()
659 inBuff.pos = 0; in basicUnitTests()
660 { size_t const r = ZSTD_decompressStream(dctx, &outBuff, &inBuff); in basicUnitTests()
684 inBuff.src = compressedBuffer; in basicUnitTests()
685 inBuff.size = cSize; in basicUnitTests()
686 inBuff.pos = 0; in basicUnitTests()
687 { size_t const r = ZSTD_decompressStream(dctx, &outBuff, &inBuff); in basicUnitTests()
698 inBuff.pos = 0; in basicUnitTests()
699 inBuff.size = 0; in basicUnitTests()
700 while (inBuff.pos < cSize) { in basicUnitTests()
701 inBuff.size += MIN(cSize - inBuff.pos, 1 + (FUZ_rand(&coreSeed) & 15)); in basicUnitTests()
702 CHECK_Z(ZSTD_decompressStream(dctx, &outBuff, &inBuff)); in basicUnitTests()
713 inBuff.src = compressedBuffer; in basicUnitTests()
714 inBuff.size = cSize; in basicUnitTests()
715 inBuff.pos = 0; in basicUnitTests()
718 { size_t const r = ZSTD_decompressStream(dctx, &outBuff, &inBuff); in basicUnitTests()
726 inBuff.src = compressedBuffer; in basicUnitTests()
727 inBuff.size = cSize - 1; in basicUnitTests()
728 inBuff.pos = 0; in basicUnitTests()
731 CHECK_Z(ZSTD_decompressStream(dctx, &outBuff, &inBuff)); in basicUnitTests()
732 ++inBuff.size; in basicUnitTests()
734 { size_t const r = ZSTD_decompressStream(dctx, &outBuff, &inBuff); in basicUnitTests()
743 inBuff.pos = 0; in basicUnitTests()
744 inBuff.size = 0; in basicUnitTests()
745 while (inBuff.pos < cSize) { in basicUnitTests()
746 inBuff.size += MIN(cSize - inBuff.pos, 1 + (FUZ_rand(&coreSeed) & 15)); in basicUnitTests()
747 CHECK_Z(ZSTD_decompressStream(dctx, &outBuff, &inBuff)); in basicUnitTests()
926 inBuff.src = CNBuffer; in basicUnitTests()
927 inBuff.size = CNBufferSize; in basicUnitTests()
928 inBuff.pos = 0; in basicUnitTests()
930 CHECK_Z( ZSTD_compressStream(zc, &outBuff, &inBuff) ); in basicUnitTests()
931 if (inBuff.pos != inBuff.size) goto _output_error; /* entire input should be consumed */ in basicUnitTests()
961 inBuff.src = compressedBuffer; in basicUnitTests()
962 inBuff.size = cSize; in basicUnitTests()
963 inBuff.pos = 0; in basicUnitTests()
964 { size_t const r = ZSTD_decompressStream(zd, &outBuff, &inBuff); in basicUnitTests()
967 if (inBuff.pos != inBuff.size) goto _output_error; /* should have read the entire frame */ in basicUnitTests()
979 inBuff.src = compressedBuffer; in basicUnitTests()
980 inBuff.size = cSize; in basicUnitTests()
981 inBuff.pos = 0; in basicUnitTests()
982 { size_t const r = ZSTD_decompressStream(zd, &outBuff, &inBuff); in basicUnitTests()
1005 inBuff.src = CNBuffer; in basicUnitTests()
1006 inBuff.size = size; in basicUnitTests()
1007 inBuff.pos = 0; in basicUnitTests()
1009 CHECK_Z(ZSTD_compressStream2(cctx, &outBuff, &inBuff, ZSTD_e_end)); in basicUnitTests()
1011 if (inBuff.pos != inBuff.size) goto _output_error; in basicUnitTests()
1187 inBuff.src = CNBuffer; in basicUnitTests()
1188 inBuff.size = CNBufferSize; in basicUnitTests()
1189 inBuff.pos = 0; in basicUnitTests()
1190 CHECK_Z( ZSTD_compressStream(zc, &outBuff, &inBuff) ); in basicUnitTests()
1191 if (inBuff.pos != inBuff.size) goto _output_error; /* entire input should be consumed */ in basicUnitTests()
1216 inBuff.src = CNBuffer; in basicUnitTests()
1217 inBuff.size = CNBufferSize; in basicUnitTests()
1218 inBuff.pos = 0; in basicUnitTests()
1219 CHECK_Z( ZSTD_compressStream2(zc, &outBuff, &inBuff, ZSTD_e_end) ); in basicUnitTests()
1220 if (inBuff.pos != inBuff.size) goto _output_error; /* entire input should be consumed */ in basicUnitTests()
1229 inBuff.src = compressedBuffer; in basicUnitTests()
1230 inBuff.size = cSize; in basicUnitTests()
1231 inBuff.pos = 0; in basicUnitTests()
1232 CHECK_Z( ZSTD_decompressStream(zd, &outBuff, &inBuff) ); in basicUnitTests()
1233 if (inBuff.pos != inBuff.size) goto _output_error; /* entire input should be consumed */ in basicUnitTests()
1247 inBuff.src = CNBuffer; in basicUnitTests()
1248 inBuff.size = CNBufferSize; in basicUnitTests()
1249 inBuff.pos = 0; in basicUnitTests()
1250 CHECK_Z( ZSTD_compressStream2(zc, &outBuff, &inBuff, ZSTD_e_end) ); in basicUnitTests()
1251 if (inBuff.pos != inBuff.size) goto _output_error; /* entire input should be consumed */ in basicUnitTests()
1268 inBuff.src = CNBuffer; in basicUnitTests()
1269 inBuff.size = 0; in basicUnitTests()
1270 inBuff.pos = 0; in basicUnitTests()
1271 CHECK_Z( ZSTD_compressStream(zc, &outBuff, &inBuff) ); in basicUnitTests()
1282 inBuff.src = CNBuffer; in basicUnitTests()
1283 inBuff.size = 0; in basicUnitTests()
1284 inBuff.pos = 0; in basicUnitTests()
1288 CHECK_Z( ZSTD_compressStream(zc, &outBuff, &inBuff) ); in basicUnitTests()
1297 inBuff.src = CNBuffer; in basicUnitTests()
1298 inBuff.size = 0; in basicUnitTests()
1299 inBuff.pos = 0; in basicUnitTests()
1300 CHECK_Z( ZSTD_compressStream(zc, &outBuff, &inBuff) ); in basicUnitTests()
1317 inBuff.src = CNBuffer; in basicUnitTests()
1318 inBuff.size = CNBufferSize; in basicUnitTests()
1319 inBuff.pos = 0; in basicUnitTests()
1320 { size_t const compressResult = ZSTD_compressStream2(mtctx, &outBuff, &inBuff, ZSTD_e_end); in basicUnitTests()
1323 if (inBuff.pos != inBuff.size) goto _output_error; /* entire input should be consumed */ in basicUnitTests()
1348 inBuff.src = CNBuffer; in basicUnitTests()
1349 inBuff.size = srcSize; assert(srcSize < COMPRESSIBLE_NOISE_LENGTH); in basicUnitTests()
1350 inBuff.pos = 0; in basicUnitTests()
1356 CHECK_Z( ZSTD_compressStream2(zc, &outBuff, &inBuff, ZSTD_e_end) ); in basicUnitTests()
1360 if (inBuff.pos != inBuff.size) goto _output_error; /* entire input should be consumed */ in basicUnitTests()
1372 inBuff.src = compressedBuffer; in basicUnitTests()
1373 inBuff.pos = 0; in basicUnitTests()
1375 inBuff.size = 1; /* avoid shortcut to single-pass mode */ in basicUnitTests()
1376 CHECK_Z( ZSTD_decompressStream(dstream, &outBuff, &inBuff) ); in basicUnitTests()
1377 inBuff.size = cSize; in basicUnitTests()
1378 CHECK_Z( ZSTD_decompressStream(dstream, &outBuff, &inBuff) ); in basicUnitTests()
1379 if (inBuff.pos != inBuff.size) goto _output_error; /* entire input should be consumed */ in basicUnitTests()
1480 inBuff.src = testCase; in basicUnitTests()
1481 inBuff.size = 47; in basicUnitTests()
1482 inBuff.pos = 0; in basicUnitTests()
1487 while (inBuff.pos < inBuff.size) { in basicUnitTests()
1488 CHECK_Z( ZSTD_decompressStream(zds, &outBuff, &inBuff) ); in basicUnitTests()
1529 inBuff.src = compressed; in basicUnitTests()
1530 inBuff.size = compressedSize; in basicUnitTests()
1531 inBuff.pos = 0; in basicUnitTests()
1536 CHECK(ZSTD_decompressStream(zds, &outBuff, &inBuff) != 0, in basicUnitTests()
1538 CHECK(inBuff.pos != inBuff.size, "Decompress did not fully consume input"); in basicUnitTests()
1876 ZSTD_inBuffer inBuff = { srcBuffer+srcStart, srcSize, 0 }; in fuzzerTests() local
1879 CHECK_Z( ZSTD_compressStream(zc, &outBuff, &inBuff) ); in fuzzerTests()
1881 XXH64_update(&xxhState, srcBuffer+srcStart, inBuff.pos); in fuzzerTests()
1882 memcpy(copyBuffer+totalTestSize, srcBuffer+srcStart, inBuff.pos); in fuzzerTests()
1883 totalTestSize += inBuff.pos; in fuzzerTests()
1914 ZSTD_inBuffer inBuff = { cBuffer, cSize, 0 }; in fuzzerTests() local
1920 inBuff.size = inBuff.pos + readCSrcSize; in fuzzerTests()
1922 decompressionResult = ZSTD_decompressStream(zd, &outBuff, &inBuff); in fuzzerTests()
1933 CHECK (inBuff.pos != cSize, "compressed data should be fully read") in fuzzerTests()
1953 { ZSTD_inBuffer inBuff = { cBuffer, cSize, 0 }; in fuzzerTests() local
1959 size_t const adjustedCSrcSize = MIN(cSize - inBuff.pos, randomCSrcSize); in fuzzerTests()
1961 inBuff.size = inBuff.pos + adjustedCSrcSize; in fuzzerTests()
1962 { size_t const decompressError = ZSTD_decompressStream(zd, &outBuff, &inBuff); in fuzzerTests()
1965 if (outBuff.pos < outBuff.size && inBuff.pos == cSize) break; in fuzzerTests()
2265 ZSTD_inBuffer inBuff = { srcBuffer, maxTestSize, 0 }; in fuzzerTests_newAPI() local
2266 CHECK_Z(ZSTD_compressStream2(zc, &outBuff, &inBuff, ZSTD_e_end)); in fuzzerTests_newAPI()
2268 testNb, (unsigned)inBuff.pos, (unsigned)outBuff.pos); in fuzzerTests_newAPI()
2269 CHECK(inBuff.pos != inBuff.size, "Input not consumed!"); in fuzzerTests_newAPI()
2280 ZSTD_inBuffer inBuff = { srcBuffer+srcStart, srcSize, 0 }; in fuzzerTests_newAPI() local
2283 size_t const ipos = inBuff.pos; in fuzzerTests_newAPI()
2291 CHECK_Z( ret = ZSTD_compressStream2(zc, &outBuff, &inBuff, flush) ); in fuzzerTests_newAPI()
2293 …testNb, (unsigned)inBuff.pos, (unsigned)(totalTestSize + inBuff.pos), (unsigned)flush, (unsigned)o… in fuzzerTests_newAPI()
2300 forwardProgress = (inBuff.pos != ipos) || (outBuff.pos != opos); in fuzzerTests_newAPI()
2302 assert(inBuff.pos == inBuff.size); in fuzzerTests_newAPI()
2304 XXH64_update(&xxhState, srcBuffer+srcStart, inBuff.pos); in fuzzerTests_newAPI()
2305 memcpy(copyBuffer+totalTestSize, srcBuffer+srcStart, inBuff.pos); in fuzzerTests_newAPI()
2306 totalTestSize += inBuff.pos; in fuzzerTests_newAPI()
2312 ZSTD_inBuffer inBuff = { NULL, 0, 0 }; in fuzzerTests_newAPI() local
2318 … remainingToFlush = ZSTD_compressStream2(zc, &outBuff, &inBuff, ZSTD_e_end); in fuzzerTests_newAPI()
2345 ZSTD_inBuffer inBuff = { cBuffer, cSize, 0 }; in fuzzerTests_newAPI() local
2351 inBuff.size = inBuff.pos + readCSrcSize; in fuzzerTests_newAPI()
2354 (unsigned)readCSrcSize, (unsigned)inBuff.pos, (unsigned)cSize); in fuzzerTests_newAPI()
2355 decompressionResult = ZSTD_decompressStream(zd, &outBuff, &inBuff); in fuzzerTests_newAPI()
2357 (unsigned)inBuff.pos, (unsigned)outBuff.pos); in fuzzerTests_newAPI()
2363 …CHECK (inBuff.pos > cSize, "ZSTD_decompressStream consumes too much input : %u > %u ", (unsigned)i… in fuzzerTests_newAPI()
2365 …CHECK (inBuff.pos != cSize, "compressed data should be fully read (%u != %u)", (unsigned)inBuff.po… in fuzzerTests_newAPI()
2386 { ZSTD_inBuffer inBuff = { cBuffer, cSize, 0 }; in fuzzerTests_newAPI() local
2392 size_t const adjustedCSrcSize = MIN(cSize - inBuff.pos, randomCSrcSize); in fuzzerTests_newAPI()
2394 inBuff.size = inBuff.pos + adjustedCSrcSize; in fuzzerTests_newAPI()
2395 { size_t const decompressError = ZSTD_decompressStream(zd, &outBuff, &inBuff); in fuzzerTests_newAPI()
2398 if (outBuff.pos < outBuff.size && inBuff.pos == cSize) break; in fuzzerTests_newAPI()