Lines Matching refs:outBuff
228 ZSTD_outBuffer outBuff; in basicUnitTests() local
252 outBuff.dst = (char*)(compressedBuffer); in basicUnitTests()
253 outBuff.size = compressedBufferSize; in basicUnitTests()
254 outBuff.pos = 0; in basicUnitTests()
258 CHECK_Z( ZSTD_compressStream(zc, &outBuff, &inBuff) ); in basicUnitTests()
260 { size_t const r = ZSTD_endStream(zc, &outBuff); in basicUnitTests()
262 DISPLAYLEVEL(3, "OK (%u bytes)\n", (U32)outBuff.pos); in basicUnitTests()
272 outBuff.dst = (char*)(compressedBuffer)+cSize; in basicUnitTests()
274 outBuff.size = compressedBufferSize - cSize; in basicUnitTests()
275 outBuff.pos = 0; in basicUnitTests()
279 CHECK_Z( ZSTD_compressStream(zc, &outBuff, &inBuff) ); in basicUnitTests()
281 { size_t const r = ZSTD_endStream(zc, &outBuff); in basicUnitTests()
283 cSize += outBuff.pos; in basicUnitTests()
318 outBuff.dst = decodedBuffer; in basicUnitTests()
319 outBuff.size = CNBufferSize; in basicUnitTests()
320 outBuff.pos = 0; in basicUnitTests()
321 { size_t const r = ZSTD_decompressStream(zd, &outBuff, &inBuff); in basicUnitTests()
325 if (outBuff.pos != 0) goto _output_error; /* skippable frame output len is 0 */ in basicUnitTests()
333 { size_t const remaining = ZSTD_decompressStream(zd, &outBuff, &inBuff); in basicUnitTests()
335 if (outBuff.pos != CNBufferSize) goto _output_error; /* should regenerate the same amount */ in basicUnitTests()
341 outBuff.pos = 0; in basicUnitTests()
342 { size_t const remaining = ZSTD_decompressStream(zd, &outBuff, &inBuff2); in basicUnitTests()
344 if (outBuff.pos != CNBufferSize) goto _output_error; /* should regenerate the same amount */ in basicUnitTests()
382 outBuff.dst = decodedBuffer; in basicUnitTests()
384 outBuff.pos = 0; in basicUnitTests()
389 outBuff.size = outBuff.pos + outSize; in basicUnitTests()
390 r = ZSTD_decompressStream(zd, &outBuff, &inBuff); in basicUnitTests()
400 outBuff.size = outBuff.pos + outSize; in basicUnitTests()
401 r = ZSTD_decompressStream(zd, &outBuff, &inBuff); in basicUnitTests()
405 if (outBuff.pos != CNBufferSize) goto _output_error; /* should regenerate the same amount */ in basicUnitTests()
420 outBuff.dst = (char*)(compressedBuffer); in basicUnitTests()
421 outBuff.size = compressedBufferSize; in basicUnitTests()
422 outBuff.pos = 0; in basicUnitTests()
426 CHECK_Z( ZSTD_compressStream(zc, &outBuff, &inBuff) ); in basicUnitTests()
428 { size_t const r = ZSTD_endStream(zc, &outBuff); in basicUnitTests()
430 { unsigned long long origSize = ZSTD_findDecompressedSize(outBuff.dst, outBuff.pos); in basicUnitTests()
437 outBuff.dst = (char*)(compressedBuffer); in basicUnitTests()
438 outBuff.size = compressedBufferSize; in basicUnitTests()
439 outBuff.pos = 0; in basicUnitTests()
443 CHECK_Z( ZSTD_compressStream(zc, &outBuff, &inBuff) ); in basicUnitTests()
445 { size_t const r = ZSTD_endStream(zc, &outBuff); in basicUnitTests()
452 outBuff.dst = (char*)(compressedBuffer); in basicUnitTests()
453 outBuff.size = compressedBufferSize; in basicUnitTests()
454 outBuff.pos = 0; in basicUnitTests()
458 { size_t const r = ZSTD_compressStream(zc, &outBuff, &inBuff); in basicUnitTests()
475 outBuff.dst = (char*)(compressedBuffer)+cSize; in basicUnitTests()
476 outBuff.size = ZSTD_compressBound(inSize); in basicUnitTests()
477 outBuff.pos = 0; in basicUnitTests()
479 CHECK_Z( ZSTD_compressStream(zc, &outBuff, &inBuff) ); in basicUnitTests()
482 { size_t const r = ZSTD_endStream(zc, &outBuff); in basicUnitTests()
492 outBuff.dst = (char*)(compressedBuffer)+cSize; in basicUnitTests()
493 outBuff.size = ZSTD_compressBound(inSize); in basicUnitTests()
494 outBuff.pos = 0; in basicUnitTests()
496 CHECK_Z( ZSTD_compressStream(zc, &outBuff, &inBuff) ); in basicUnitTests()
499 { size_t const r = ZSTD_endStream(zc, &outBuff); in basicUnitTests()
511 outBuff.dst = compressedBuffer; in basicUnitTests()
512 outBuff.size = compressedBufferSize; in basicUnitTests()
513 outBuff.pos = 0; in basicUnitTests()
518 CHECK_Z( ZSTD_compressStream(zc, &outBuff, &inBuff) ); in basicUnitTests()
520 { size_t const r = ZSTD_endStream(zc, &outBuff); in basicUnitTests()
524 cSize = outBuff.pos; in basicUnitTests()
546 outBuff.dst = decodedBuffer; in basicUnitTests()
547 outBuff.size = CNBufferSize; in basicUnitTests()
548 outBuff.pos = 0; in basicUnitTests()
552 { size_t const r = ZSTD_decompressStream(zd, &outBuff, &inBuff); in basicUnitTests()
554 … if (outBuff.pos != CNBufferSize) goto _output_error; /* should regenerate the same amount */ in basicUnitTests()
570 outBuff.dst = decodedBuffer; in basicUnitTests()
571 outBuff.size = CNBufferSize; in basicUnitTests()
572 outBuff.pos = 0; in basicUnitTests()
576 { size_t const r = ZSTD_decompressStream(zd, &outBuff, &inBuff); in basicUnitTests()
594 outBuff.dst = compressedBuffer; in basicUnitTests()
595 outBuff.size = compressedBufferSize; in basicUnitTests()
596 outBuff.pos = 0; in basicUnitTests()
601 CHECK_Z(ZSTD_compress_generic(cctx, &outBuff, &inBuff, ZSTD_e_end)); in basicUnitTests()
604 ZSTD_inBuffer decIn = {outBuff.dst, outBuff.pos, 0}; in basicUnitTests()
626 outBuff.dst = compressedBuffer; in basicUnitTests()
627 outBuff.size = compressedBufferSize; in basicUnitTests()
628 outBuff.pos = 0; in basicUnitTests()
632 CHECK_Z( ZSTD_compressStream(zc, &outBuff, &inBuff) ); in basicUnitTests()
634 { size_t const r = ZSTD_endStream(zc, &outBuff); in basicUnitTests()
636 cSize = outBuff.pos; in basicUnitTests()
655 outBuff.dst = compressedBuffer; in basicUnitTests()
656 outBuff.size = compressedBufferSize; in basicUnitTests()
657 outBuff.pos = 0; in basicUnitTests()
661 CHECK_Z( ZSTD_compress_generic(zc, &outBuff, &inBuff, ZSTD_e_end) ); in basicUnitTests()
663 cSize = outBuff.pos; in basicUnitTests()
668 outBuff.dst = decodedBuffer; in basicUnitTests()
669 outBuff.size = CNBufferSize; in basicUnitTests()
670 outBuff.pos = 0; in basicUnitTests()
674 CHECK_Z( ZSTD_decompress_generic(zd, &outBuff, &inBuff) ); in basicUnitTests()
676 if (outBuff.pos != CNBufferSize) goto _output_error; /* must regenerate whole input */ in basicUnitTests()
686 outBuff.dst = compressedBuffer; in basicUnitTests()
687 outBuff.size = compressedBufferSize; in basicUnitTests()
688 outBuff.pos = 0; in basicUnitTests()
692 CHECK_Z( ZSTD_compress_generic(zc, &outBuff, &inBuff, ZSTD_e_end) ); in basicUnitTests()
694 cSize = outBuff.pos; in basicUnitTests()
707 outBuff.dst = compressedBuffer; in basicUnitTests()
708 outBuff.size = compressedBufferSize; in basicUnitTests()
709 outBuff.pos = 0; in basicUnitTests()
713 CHECK_Z( ZSTD_compressStream(zc, &outBuff, &inBuff) ); in basicUnitTests()
714 if (ZSTD_endStream(zc, &outBuff) != 0) goto _output_error; in basicUnitTests()
715 cSize = outBuff.pos; in basicUnitTests()
727 outBuff.dst = compressedBuffer; in basicUnitTests()
728 outBuff.size = compressedBufferSize; in basicUnitTests()
729 outBuff.pos = 0; in basicUnitTests()
730 CHECK_Z( ZSTD_compressStream(zc, &outBuff, &inBuff) ); in basicUnitTests()
731 if (ZSTD_endStream(zc, &outBuff) != 0) goto _output_error; in basicUnitTests()
732 cSize = outBuff.pos; in basicUnitTests()
736 outBuff.dst = compressedBuffer; in basicUnitTests()
737 outBuff.size = compressedBufferSize; in basicUnitTests()
738 outBuff.pos = 0; in basicUnitTests()
742 CHECK_Z( ZSTD_compressStream(zc, &outBuff, &inBuff) ); in basicUnitTests()
743 if (ZSTD_endStream(zc, &outBuff) != 0) goto _output_error; in basicUnitTests()
744 cSize = outBuff.pos; in basicUnitTests()
753 outBuff.dst = compressedBuffer; in basicUnitTests()
754 outBuff.size = compressedBufferSize; in basicUnitTests()
755 outBuff.pos = 0; in basicUnitTests()
759 …{ size_t const compressResult = ZSTDMT_compressStream_generic(mtctx, &outBuff, &inBuff, ZSTD_e_e… in basicUnitTests()
763 { size_t const compressedSize = ZSTD_findFrameCompressedSize(compressedBuffer, outBuff.pos); in basicUnitTests()
764 if (compressedSize != outBuff.pos) goto _output_error; /* must be a full valid frame */ in basicUnitTests()
784 outBuff.dst = compressedBuffer; in basicUnitTests()
785 outBuff.size = compressedBufferSize; in basicUnitTests()
786 outBuff.pos = 0; in basicUnitTests()
795 CHECK_Z( ZSTD_compress_generic(zc, &outBuff, &inBuff, ZSTD_e_end) ); in basicUnitTests()
800 cSize = outBuff.pos; in basicUnitTests()
808 outBuff.dst = decodedBuffer; in basicUnitTests()
809 outBuff.size = CNBufferSize; in basicUnitTests()
810 outBuff.pos = 0; in basicUnitTests()
815 CHECK_Z( ZSTD_decompressStream(dstream, &outBuff, &inBuff) ); in basicUnitTests()
817 CHECK_Z( ZSTD_decompressStream(dstream, &outBuff, &inBuff) ); in basicUnitTests()
892 outBuff.dst = decodedBuffer; in basicUnitTests()
893 outBuff.size = CNBufferSize; in basicUnitTests()
894 outBuff.pos = 0; in basicUnitTests()
897 CHECK_Z( ZSTD_decompressStream(zds, &outBuff, &inBuff) ); in basicUnitTests()
1097 { ZSTD_outBuffer outBuff = { cBuffer, cBufferSize, 0 } ; in fuzzerTests() local
1107 outBuff.size = outBuff.pos + dstBuffSize; in fuzzerTests()
1109 CHECK_Z( ZSTD_compressStream(zc, &outBuff, &inBuff) ); in fuzzerTests()
1120 outBuff.size = outBuff.pos + adjustedDstSize; in fuzzerTests()
1121 CHECK_Z( ZSTD_flushStream(zc, &outBuff) ); in fuzzerTests()
1129 outBuff.size = outBuff.pos + adjustedDstSize; in fuzzerTests()
1130 remainingToFlush = ZSTD_endStream(zc, &outBuff); in fuzzerTests()
1134 cSize = outBuff.pos; in fuzzerTests()
1145 ZSTD_outBuffer outBuff= { dstBuffer, dstBufferSize, 0 }; in fuzzerTests() local
1151 outBuff.size = outBuff.pos + dstBuffSize; in fuzzerTests()
1152 decompressionResult = ZSTD_decompressStream(zd, &outBuff, &inBuff); in fuzzerTests()
1161 CHECK (outBuff.pos != totalTestSize, "decompressed data : wrong size (%u != %u)", in fuzzerTests()
1162 (U32)outBuff.pos, (U32)totalTestSize); in fuzzerTests()
1184 ZSTD_outBuffer outBuff= { dstBuffer, dstBufferSize, 0 }; in fuzzerTests() local
1185 while (outBuff.pos < dstBufferSize) { in fuzzerTests()
1188 size_t const adjustedDstSize = MIN(dstBufferSize - outBuff.pos, randomDstSize); in fuzzerTests()
1190 outBuff.size = outBuff.pos + adjustedDstSize; in fuzzerTests()
1192 { size_t const decompressError = ZSTD_decompressStream(zd, &outBuff, &inBuff); in fuzzerTests()
1195 if (outBuff.pos < outBuff.size && inBuff.pos == cSize) break; in fuzzerTests()
1353 { ZSTD_outBuffer outBuff = { cBuffer, cBufferSize, 0 } ; in fuzzerTests_MT() local
1363 outBuff.size = outBuff.pos + dstBuffSize; in fuzzerTests_MT()
1366 CHECK_Z( ZSTDMT_compressStream(zc, &outBuff, &inBuff) ); in fuzzerTests_MT()
1378 size_t const previousPos = outBuff.pos; in fuzzerTests_MT()
1379 outBuff.size = outBuff.pos + adjustedDstSize; in fuzzerTests_MT()
1381 CHECK_Z( ZSTDMT_flushStream(zc, &outBuff) ); in fuzzerTests_MT()
1382 assert(outBuff.pos >= previousPos); in fuzzerTests_MT()
1383 … DISPLAYLEVEL(6, "%u bytes flushed by ZSTDMT_flushStream \n", (U32)(outBuff.pos-previousPos)); in fuzzerTests_MT()
1391 size_t const previousPos = outBuff.pos; in fuzzerTests_MT()
1392 outBuff.size = outBuff.pos + adjustedDstSize; in fuzzerTests_MT()
1394 remainingToFlush = ZSTDMT_endStream(zc, &outBuff); in fuzzerTests_MT()
1396 assert(outBuff.pos >= previousPos); in fuzzerTests_MT()
1397 … DISPLAYLEVEL(6, "%u bytes flushed by ZSTDMT_endStream \n", (U32)(outBuff.pos-previousPos)); in fuzzerTests_MT()
1401 cSize = outBuff.pos; in fuzzerTests_MT()
1416 ZSTD_outBuffer outBuff= { dstBuffer, dstBufferSize, 0 }; in fuzzerTests_MT() local
1422 outBuff.size = outBuff.pos + dstBuffSize; in fuzzerTests_MT()
1425 decompressionResult = ZSTD_decompressStream(zd, &outBuff, &inBuff); in fuzzerTests_MT()
1432 (U32)inBuff.pos, (U32)outBuff.pos); in fuzzerTests_MT()
1434 …CHECK (outBuff.pos != totalTestSize, "decompressed data : wrong size (%u != %u)", (U32)outBuff.pos… in fuzzerTests_MT()
1456 ZSTD_outBuffer outBuff= { dstBuffer, dstBufferSize, 0 }; in fuzzerTests_MT() local
1457 while (outBuff.pos < dstBufferSize) { in fuzzerTests_MT()
1460 size_t const adjustedDstSize = MIN(dstBufferSize - outBuff.pos, randomDstSize); in fuzzerTests_MT()
1462 outBuff.size = outBuff.pos + adjustedDstSize; in fuzzerTests_MT()
1464 { size_t const decompressError = ZSTD_decompressStream(zd, &outBuff, &inBuff); in fuzzerTests_MT()
1467 if (outBuff.pos < outBuff.size && inBuff.pos == cSize) break; in fuzzerTests_MT()
1727 { ZSTD_outBuffer outBuff = { cBuffer, cBufferSize, 0 } ; in fuzzerTests_newAPI() local
1737 outBuff.size = outBuff.pos + dstBuffSize; in fuzzerTests_newAPI()
1739 CHECK_Z( ZSTD_compress_generic(zc, &outBuff, &inBuff, flush) ); in fuzzerTests_newAPI()
1741 … testNb, (U32)inBuff.pos, (U32)(totalTestSize + inBuff.pos), (U32)flush, (U32)outBuff.pos); in fuzzerTests_newAPI()
1754 outBuff.size = outBuff.pos + adjustedDstSize; in fuzzerTests_newAPI()
1756 remainingToFlush = ZSTD_compress_generic(zc, &outBuff, &inBuff, ZSTD_e_end); in fuzzerTests_newAPI()
1757 … DISPLAYLEVEL(6, "t%u: Total flushed so far : %u bytes \n", testNb, (U32)outBuff.pos); in fuzzerTests_newAPI()
1763 cSize = outBuff.pos; in fuzzerTests_newAPI()
1777 ZSTD_outBuffer outBuff= { dstBuffer, dstBufferSize, 0 }; in fuzzerTests_newAPI() local
1783 outBuff.size = outBuff.pos + dstBuffSize; in fuzzerTests_newAPI()
1786 decompressionResult = ZSTD_decompressStream(zd, &outBuff, &inBuff); in fuzzerTests_newAPI()
1788 (U32)inBuff.pos, (U32)outBuff.pos); in fuzzerTests_newAPI()
1797 …CHECK (outBuff.pos != totalTestSize, "decompressed data : wrong size (%u != %u)", (U32)outBuff.pos… in fuzzerTests_newAPI()
1818 ZSTD_outBuffer outBuff= { dstBuffer, dstBufferSize, 0 }; in fuzzerTests_newAPI() local
1819 while (outBuff.pos < dstBufferSize) { in fuzzerTests_newAPI()
1822 size_t const adjustedDstSize = MIN(dstBufferSize - outBuff.pos, randomDstSize); in fuzzerTests_newAPI()
1824 outBuff.size = outBuff.pos + adjustedDstSize; in fuzzerTests_newAPI()
1826 { size_t const decompressError = ZSTD_decompressStream(zd, &outBuff, &inBuff); in fuzzerTests_newAPI()
1829 if (outBuff.pos < outBuff.size && inBuff.pos == cSize) break; in fuzzerTests_newAPI()