Lines Matching refs:ress
985 cRess_t ress; in FIO_createCResources() local
986 memset(&ress, 0, sizeof(ress)); in FIO_createCResources()
989 ress.cctx = ZSTD_createCCtx(); in FIO_createCResources()
990 if (ress.cctx == NULL) in FIO_createCResources()
993 ress.srcBufferSize = ZSTD_CStreamInSize(); in FIO_createCResources()
994 ress.srcBuffer = malloc(ress.srcBufferSize); in FIO_createCResources()
995 ress.dstBufferSize = ZSTD_CStreamOutSize(); in FIO_createCResources()
1003 ress.dstBuffer = malloc(ress.dstBufferSize); in FIO_createCResources()
1004 …ress.dictBufferSize = FIO_createDictBuffer(&ress.dictBuffer, dictFileName, prefs); /* works with… in FIO_createCResources()
1005 if (!ress.srcBuffer || !ress.dstBuffer) in FIO_createCResources()
1009 if (dictFileName && (ress.dictBuffer==NULL)) in FIO_createCResources()
1011 ress.dictFileName = dictFileName; in FIO_createCResources()
1016 …CHECK( ZSTD_CCtx_setParameter(ress.cctx, ZSTD_c_contentSizeFlag, prefs->contentSize) ); /* always… in FIO_createCResources()
1017 CHECK( ZSTD_CCtx_setParameter(ress.cctx, ZSTD_c_dictIDFlag, prefs->dictIDFlag) ); in FIO_createCResources()
1018 CHECK( ZSTD_CCtx_setParameter(ress.cctx, ZSTD_c_checksumFlag, prefs->checksumFlag) ); in FIO_createCResources()
1020 CHECK( ZSTD_CCtx_setParameter(ress.cctx, ZSTD_c_compressionLevel, cLevel) ); in FIO_createCResources()
1022 … CHECK( ZSTD_CCtx_setParameter(ress.cctx, ZSTD_c_targetCBlockSize, (int)prefs->targetCBlockSize) ); in FIO_createCResources()
1024 CHECK( ZSTD_CCtx_setParameter(ress.cctx, ZSTD_c_srcSizeHint, (int)prefs->srcSizeHint) ); in FIO_createCResources()
1026 CHECK( ZSTD_CCtx_setParameter(ress.cctx, ZSTD_c_enableLongDistanceMatching, prefs->ldmFlag) ); in FIO_createCResources()
1027 CHECK( ZSTD_CCtx_setParameter(ress.cctx, ZSTD_c_ldmHashLog, prefs->ldmHashLog) ); in FIO_createCResources()
1028 CHECK( ZSTD_CCtx_setParameter(ress.cctx, ZSTD_c_ldmMinMatch, prefs->ldmMinMatch) ); in FIO_createCResources()
1030 … CHECK( ZSTD_CCtx_setParameter(ress.cctx, ZSTD_c_ldmBucketSizeLog, prefs->ldmBucketSizeLog) ); in FIO_createCResources()
1033 CHECK( ZSTD_CCtx_setParameter(ress.cctx, ZSTD_c_ldmHashRateLog, prefs->ldmHashRateLog) ); in FIO_createCResources()
1035 CHECK( ZSTD_CCtx_setParameter(ress.cctx, ZSTD_c_useRowMatchFinder, prefs->useRowMatchFinder)); in FIO_createCResources()
1037 CHECK( ZSTD_CCtx_setParameter(ress.cctx, ZSTD_c_windowLog, (int)comprParams.windowLog) ); in FIO_createCResources()
1038 CHECK( ZSTD_CCtx_setParameter(ress.cctx, ZSTD_c_chainLog, (int)comprParams.chainLog) ); in FIO_createCResources()
1039 CHECK( ZSTD_CCtx_setParameter(ress.cctx, ZSTD_c_hashLog, (int)comprParams.hashLog) ); in FIO_createCResources()
1040 CHECK( ZSTD_CCtx_setParameter(ress.cctx, ZSTD_c_searchLog, (int)comprParams.searchLog) ); in FIO_createCResources()
1041 CHECK( ZSTD_CCtx_setParameter(ress.cctx, ZSTD_c_minMatch, (int)comprParams.minMatch) ); in FIO_createCResources()
1042 CHECK( ZSTD_CCtx_setParameter(ress.cctx, ZSTD_c_targetLength, (int)comprParams.targetLength) ); in FIO_createCResources()
1043 CHECK( ZSTD_CCtx_setParameter(ress.cctx, ZSTD_c_strategy, (int)comprParams.strategy) ); in FIO_createCResources()
1044 …CHECK( ZSTD_CCtx_setParameter(ress.cctx, ZSTD_c_literalCompressionMode, (int)prefs->literalCompres… in FIO_createCResources()
1045 CHECK( ZSTD_CCtx_setParameter(ress.cctx, ZSTD_c_enableDedicatedDictSearch, 1) ); in FIO_createCResources()
1049 CHECK( ZSTD_CCtx_setParameter(ress.cctx, ZSTD_c_nbWorkers, prefs->nbWorkers) ); in FIO_createCResources()
1050 CHECK( ZSTD_CCtx_setParameter(ress.cctx, ZSTD_c_jobSize, prefs->blockSize) ); in FIO_createCResources()
1053 CHECK( ZSTD_CCtx_setParameter(ress.cctx, ZSTD_c_overlapLog, prefs->overlapLog) ); in FIO_createCResources()
1055 CHECK( ZSTD_CCtx_setParameter(ress.cctx, ZSTD_c_rsyncable, prefs->rsyncable) ); in FIO_createCResources()
1059 CHECK( ZSTD_CCtx_refPrefix(ress.cctx, ress.dictBuffer, ress.dictBufferSize) ); in FIO_createCResources()
1061 CHECK( ZSTD_CCtx_loadDictionary(ress.cctx, ress.dictBuffer, ress.dictBufferSize) ); in FIO_createCResources()
1064 return ress; in FIO_createCResources()
1067 static void FIO_freeCResources(const cRess_t* const ress) in FIO_freeCResources() argument
1069 free(ress->srcBuffer); in FIO_freeCResources()
1070 free(ress->dstBuffer); in FIO_freeCResources()
1071 free(ress->dictBuffer); in FIO_freeCResources()
1072 ZSTD_freeCStream(ress->cctx); /* never fails */ in FIO_freeCResources()
1078 FIO_compressGzFrame(const cRess_t* ress, /* buffers & handlers are used, but not changed */ in FIO_compressGzFrame() argument
1101 strm.next_out = (Bytef*)ress->dstBuffer; in FIO_compressGzFrame()
1102 strm.avail_out = (uInt)ress->dstBufferSize; in FIO_compressGzFrame()
1107 size_t const inSize = fread(ress->srcBuffer, 1, ress->srcBufferSize, ress->srcFile); in FIO_compressGzFrame()
1110 strm.next_in = (z_const unsigned char*)ress->srcBuffer; in FIO_compressGzFrame()
1116 { size_t const cSize = ress->dstBufferSize - strm.avail_out; in FIO_compressGzFrame()
1118 if (fwrite(ress->dstBuffer, 1, cSize, ress->dstFile) != cSize) in FIO_compressGzFrame()
1121 strm.next_out = (Bytef*)ress->dstBuffer; in FIO_compressGzFrame()
1122 strm.avail_out = (uInt)ress->dstBufferSize; in FIO_compressGzFrame()
1136 { size_t const cSize = ress->dstBufferSize - strm.avail_out; in FIO_compressGzFrame()
1138 if (fwrite(ress->dstBuffer, 1, cSize, ress->dstFile) != cSize) in FIO_compressGzFrame()
1141 strm.next_out = (Bytef*)ress->dstBuffer; in FIO_compressGzFrame()
1142 strm.avail_out = (uInt)ress->dstBufferSize; in FIO_compressGzFrame()
1161 FIO_compressLzmaFrame(cRess_t* ress, in FIO_compressLzmaFrame() argument
1188 strm.next_out = (BYTE*)ress->dstBuffer; in FIO_compressLzmaFrame()
1189 strm.avail_out = ress->dstBufferSize; in FIO_compressLzmaFrame()
1193 size_t const inSize = fread(ress->srcBuffer, 1, ress->srcBufferSize, ress->srcFile); in FIO_compressLzmaFrame()
1196 strm.next_in = (BYTE const*)ress->srcBuffer; in FIO_compressLzmaFrame()
1204 { size_t const compBytes = ress->dstBufferSize - strm.avail_out; in FIO_compressLzmaFrame()
1206 if (fwrite(ress->dstBuffer, 1, compBytes, ress->dstFile) != compBytes) in FIO_compressLzmaFrame()
1209 strm.next_out = (BYTE*)ress->dstBuffer; in FIO_compressLzmaFrame()
1210 strm.avail_out = ress->dstBufferSize; in FIO_compressLzmaFrame()
1240 FIO_compressLz4Frame(cRess_t* ress, in FIO_compressLz4Frame() argument
1257 assert(blockSize <= ress->srcBufferSize); in FIO_compressLz4Frame()
1267 assert(LZ4F_compressBound(blockSize, &prefs) <= ress->dstBufferSize); in FIO_compressLz4Frame()
1271 size_t headerSize = LZ4F_compressBegin(ctx, ress->dstBuffer, ress->dstBufferSize, &prefs); in FIO_compressLz4Frame()
1275 if (fwrite(ress->dstBuffer, 1, headerSize, ress->dstFile) != headerSize) in FIO_compressLz4Frame()
1280 readSize = fread(ress->srcBuffer, (size_t)1, (size_t)blockSize, ress->srcFile); in FIO_compressLz4Frame()
1286 ress->dstBuffer, ress->dstBufferSize, in FIO_compressLz4Frame()
1287 ress->srcBuffer, readSize, NULL); in FIO_compressLz4Frame()
1303 { size_t const sizeCheck = fwrite(ress->dstBuffer, 1, outSize, ress->dstFile); in FIO_compressLz4Frame()
1309 readSize = fread(ress->srcBuffer, (size_t)1, (size_t)blockSize, ress->srcFile); in FIO_compressLz4Frame()
1312 if (ferror(ress->srcFile)) EXM_THROW(37, "Error reading %s ", srcFileName); in FIO_compressLz4Frame()
1315 headerSize = LZ4F_compressEnd(ctx, ress->dstBuffer, ress->dstBufferSize, NULL); in FIO_compressLz4Frame()
1320 { size_t const sizeCheck = fwrite(ress->dstBuffer, 1, headerSize, ress->dstFile); in FIO_compressLz4Frame()
1343 cRess_t const ress = *ressPtr; in FIO_compressZstdFrame() local
1344 FILE* const srcFile = ress.srcFile; in FIO_compressZstdFrame()
1345 FILE* const dstFile = ress.dstFile; in FIO_compressZstdFrame()
1366 CHECK(ZSTD_CCtx_setPledgedSrcSize(ress.cctx, fileSize)); in FIO_compressZstdFrame()
1370 CHECK( ZSTD_CCtx_setPledgedSrcSize(ress.cctx, prefs->streamSrcSize) ); in FIO_compressZstdFrame()
1376 CHECK(ZSTD_CCtx_getParameter(ress.cctx, ZSTD_c_windowLog, &windowLog)); in FIO_compressZstdFrame()
1390 size_t const inSize = fread(ress.srcBuffer, (size_t)1, ress.srcBufferSize, srcFile); in FIO_compressZstdFrame()
1391 ZSTD_inBuffer inBuff = { ress.srcBuffer, inSize, 0 }; in FIO_compressZstdFrame()
1403 ZSTD_outBuffer outBuff = { ress.dstBuffer, ress.dstBufferSize, 0 }; in FIO_compressZstdFrame()
1404 size_t const toFlushNow = ZSTD_toFlushNow(ress.cctx); in FIO_compressZstdFrame()
1405 CHECK_V(stillToFlush, ZSTD_compressStream2(ress.cctx, &outBuff, &inBuff, directive)); in FIO_compressZstdFrame()
1416 size_t const sizeCheck = fwrite(ress.dstBuffer, 1, outBuff.pos, dstFile); in FIO_compressZstdFrame()
1425 ZSTD_frameProgression const zfp = ZSTD_getFrameProgression(ress.cctx); in FIO_compressZstdFrame()
1533 … ZSTD_CCtx_setParameter(ress.cctx, ZSTD_c_compressionLevel, compressionLevel); in FIO_compressZstdFrame()
1540 … ZSTD_CCtx_setParameter(ress.cctx, ZSTD_c_compressionLevel, compressionLevel); in FIO_compressZstdFrame()
1570 cRess_t ress, in FIO_compressFilename_internal() argument
1585 …compressedfilesize = FIO_compressZstdFrame(fCtx, prefs, &ress, srcFileName, fileSize, compressionL… in FIO_compressFilename_internal()
1590 …compressedfilesize = FIO_compressGzFrame(&ress, srcFileName, fileSize, compressionLevel, &readsize… in FIO_compressFilename_internal()
1601 …compressedfilesize = FIO_compressLzmaFrame(&ress, srcFileName, fileSize, compressionLevel, &readsi… in FIO_compressFilename_internal()
1611 …compressedfilesize = FIO_compressLz4Frame(&ress, srcFileName, fileSize, compressionLevel, prefs->c… in FIO_compressFilename_internal()
1669 cRess_t ress, in FIO_compressFilename_dstFile() argument
1678 assert(ress.srcFile != NULL); in FIO_compressFilename_dstFile()
1679 if (ress.dstFile == NULL) { in FIO_compressFilename_dstFile()
1691 ress.dstFile = FIO_openDstFile(fCtx, prefs, srcFileName, dstFileName, dstFilePermissions); in FIO_compressFilename_dstFile()
1692 if (ress.dstFile==NULL) return 1; /* could not open dstFileName */ in FIO_compressFilename_dstFile()
1700 …result = FIO_compressFilename_internal(fCtx, prefs, ress, dstFileName, srcFileName, compressionLev… in FIO_compressFilename_dstFile()
1703 FILE* const dstFile = ress.dstFile; in FIO_compressFilename_dstFile()
1704 ress.dstFile = NULL; in FIO_compressFilename_dstFile()
1749 cRess_t ress, in FIO_compressFilename_srcFile() argument
1764 if (ress.dictFileName != NULL && UTIL_isSameFile(srcFileName, ress.dictFileName)) { in FIO_compressFilename_srcFile()
1778 ress.srcFile = FIO_openSrcFile(prefs, srcFileName); in FIO_compressFilename_srcFile()
1779 if (ress.srcFile == NULL) return 1; /* srcFile could not be opened */ in FIO_compressFilename_srcFile()
1781 …result = FIO_compressFilename_dstFile(fCtx, prefs, ress, dstFileName, srcFileName, compressionLeve… in FIO_compressFilename_srcFile()
1783 fclose(ress.srcFile); in FIO_compressFilename_srcFile()
1784 ress.srcFile = NULL; in FIO_compressFilename_srcFile()
1847 …cRess_t const ress = FIO_createCResources(prefs, dictFileName, UTIL_getFileSize(srcFileName), comp… in FIO_compressFilename() local
1848 …int const result = FIO_compressFilename_srcFile(fCtx, prefs, ress, dstFileName, srcFileName, compr… in FIO_compressFilename()
1852 FIO_freeCResources(&ress); in FIO_compressFilename()
1924 cRess_t ress = FIO_createCResources(prefs, dictFileName, in FIO_compressMultipleFilenames() local
1932 FIO_freeCResources(&ress); in FIO_compressMultipleFilenames()
1935 ress.dstFile = FIO_openDstFile(fCtx, prefs, NULL, outFileName, DEFAULT_FILE_PERMISSIONS); in FIO_compressMultipleFilenames()
1936 if (ress.dstFile == NULL) { /* could not open outFileName */ in FIO_compressMultipleFilenames()
1940 …status = FIO_compressFilename_srcFile(fCtx, prefs, ress, outFileName, inFileNamesTable[fCtx->currF… in FIO_compressMultipleFilenames()
1944 if (fclose(ress.dstFile)) in FIO_compressMultipleFilenames()
1947 ress.dstFile = NULL; in FIO_compressMultipleFilenames()
1969 …status = FIO_compressFilename_srcFile(fCtx, prefs, ress, dstFileName, srcFileName, compressionLeve… in FIO_compressMultipleFilenames()
1990 FIO_freeCResources(&ress); in FIO_compressMultipleFilenames()
2015 dRess_t ress; in FIO_createDResources() local
2016 memset(&ress, 0, sizeof(ress)); in FIO_createDResources()
2022 ress.dctx = ZSTD_createDStream(); in FIO_createDResources()
2023 if (ress.dctx==NULL) in FIO_createDResources()
2025 CHECK( ZSTD_DCtx_setMaxWindowSize(ress.dctx, prefs->memLimit) ); in FIO_createDResources()
2026 CHECK( ZSTD_DCtx_setParameter(ress.dctx, ZSTD_d_forceIgnoreChecksum, !prefs->checksumFlag)); in FIO_createDResources()
2028 ress.srcBufferSize = ZSTD_DStreamInSize(); in FIO_createDResources()
2029 ress.srcBuffer = malloc(ress.srcBufferSize); in FIO_createDResources()
2030 ress.dstBufferSize = ZSTD_DStreamOutSize(); in FIO_createDResources()
2031 ress.dstBuffer = malloc(ress.dstBufferSize); in FIO_createDResources()
2032 if (!ress.srcBuffer || !ress.dstBuffer) in FIO_createDResources()
2038 CHECK( ZSTD_initDStream_usingDict(ress.dctx, dictBuffer, dictBufferSize) ); in FIO_createDResources()
2042 return ress; in FIO_createDResources()
2045 static void FIO_freeDResources(dRess_t ress) in FIO_freeDResources() argument
2047 CHECK( ZSTD_freeDStream(ress.dctx) ); in FIO_freeDResources()
2048 free(ress.srcBuffer); in FIO_freeDResources()
2049 free(ress.dstBuffer); in FIO_freeDResources()
2188 const dRess_t* ress, in FIO_zstdErrorHelp() argument
2198 err = ZSTD_getFrameHeader(&header, ress->srcBuffer, ress->srcBufferLoaded); in FIO_zstdErrorHelp()
2221 FIO_decompressZstdFrame(FIO_ctx_t* const fCtx, dRess_t* ress, FILE* finput, in FIO_decompressZstdFrame() argument
2234 ZSTD_DCtx_reset(ress->dctx, ZSTD_reset_session_only); in FIO_decompressZstdFrame()
2238 if (ress->srcBufferLoaded < toDecode) { in FIO_decompressZstdFrame()
2239 size_t const toRead = toDecode - ress->srcBufferLoaded; in FIO_decompressZstdFrame()
2240 void* const startPosition = (char*)ress->srcBuffer + ress->srcBufferLoaded; in FIO_decompressZstdFrame()
2241 ress->srcBufferLoaded += fread(startPosition, 1, toRead, finput); in FIO_decompressZstdFrame()
2246 ZSTD_inBuffer inBuff = { ress->srcBuffer, ress->srcBufferLoaded, 0 }; in FIO_decompressZstdFrame()
2247 ZSTD_outBuffer outBuff= { ress->dstBuffer, ress->dstBufferSize, 0 }; in FIO_decompressZstdFrame()
2248 size_t const readSizeHint = ZSTD_decompressStream(ress->dctx, &outBuff, &inBuff); in FIO_decompressZstdFrame()
2254 FIO_zstdErrorHelp(prefs, ress, readSizeHint, srcFileName); in FIO_decompressZstdFrame()
2259 … storedSkips = FIO_fwriteSparse(ress->dstFile, ress->dstBuffer, outBuff.pos, prefs, storedSkips); in FIO_decompressZstdFrame()
2277 memmove(ress->srcBuffer, (char*)ress->srcBuffer + inBuff.pos, inBuff.size - inBuff.pos); in FIO_decompressZstdFrame()
2278 ress->srcBufferLoaded -= inBuff.pos; in FIO_decompressZstdFrame()
2284 …{ size_t const toDecode = MIN(readSizeHint, ress->srcBufferSize); /* support large skippable fr… in FIO_decompressZstdFrame()
2285 if (ress->srcBufferLoaded < toDecode) { in FIO_decompressZstdFrame()
2286 size_t const toRead = toDecode - ress->srcBufferLoaded; /* > 0 */ in FIO_decompressZstdFrame()
2287 void* const startPosition = (char*)ress->srcBuffer + ress->srcBufferLoaded; in FIO_decompressZstdFrame()
2294 ress->srcBufferLoaded += readSize; in FIO_decompressZstdFrame()
2297 FIO_fwriteSparseEnd(prefs, ress->dstFile, storedSkips); in FIO_decompressZstdFrame()
2305 FIO_decompressGzFrame(dRess_t* ress, FILE* srcFile, in FIO_decompressGzFrame() argument
2324 strm.next_out = (Bytef*)ress->dstBuffer; in FIO_decompressGzFrame()
2325 strm.avail_out = (uInt)ress->dstBufferSize; in FIO_decompressGzFrame()
2326 strm.avail_in = (uInt)ress->srcBufferLoaded; in FIO_decompressGzFrame()
2327 strm.next_in = (z_const unsigned char*)ress->srcBuffer; in FIO_decompressGzFrame()
2332 ress->srcBufferLoaded = fread(ress->srcBuffer, 1, ress->srcBufferSize, srcFile); in FIO_decompressGzFrame()
2333 if (ress->srcBufferLoaded == 0) flush = Z_FINISH; in FIO_decompressGzFrame()
2334 strm.next_in = (z_const unsigned char*)ress->srcBuffer; in FIO_decompressGzFrame()
2335 strm.avail_in = (uInt)ress->srcBufferLoaded; in FIO_decompressGzFrame()
2346 { size_t const decompBytes = ress->dstBufferSize - strm.avail_out; in FIO_decompressGzFrame()
2348 … storedSkips = FIO_fwriteSparse(ress->dstFile, ress->dstBuffer, decompBytes, prefs, storedSkips); in FIO_decompressGzFrame()
2350 strm.next_out = (Bytef*)ress->dstBuffer; in FIO_decompressGzFrame()
2351 strm.avail_out = (uInt)ress->dstBufferSize; in FIO_decompressGzFrame()
2358 memmove(ress->srcBuffer, strm.next_in, strm.avail_in); in FIO_decompressGzFrame()
2359 ress->srcBufferLoaded = strm.avail_in; in FIO_decompressGzFrame()
2365 FIO_fwriteSparseEnd(prefs, ress->dstFile, storedSkips); in FIO_decompressGzFrame()
2373 FIO_decompressLzmaFrame(dRess_t* ress, FILE* srcFile, in FIO_decompressLzmaFrame() argument
2399 strm.next_out = (BYTE*)ress->dstBuffer; in FIO_decompressLzmaFrame()
2400 strm.avail_out = ress->dstBufferSize; in FIO_decompressLzmaFrame()
2401 strm.next_in = (BYTE const*)ress->srcBuffer; in FIO_decompressLzmaFrame()
2402 strm.avail_in = ress->srcBufferLoaded; in FIO_decompressLzmaFrame()
2407 ress->srcBufferLoaded = fread(ress->srcBuffer, 1, ress->srcBufferSize, srcFile); in FIO_decompressLzmaFrame()
2408 if (ress->srcBufferLoaded == 0) action = LZMA_FINISH; in FIO_decompressLzmaFrame()
2409 strm.next_in = (BYTE const*)ress->srcBuffer; in FIO_decompressLzmaFrame()
2410 strm.avail_in = ress->srcBufferLoaded; in FIO_decompressLzmaFrame()
2423 { size_t const decompBytes = ress->dstBufferSize - strm.avail_out; in FIO_decompressLzmaFrame()
2425 … storedSkips = FIO_fwriteSparse(ress->dstFile, ress->dstBuffer, decompBytes, prefs, storedSkips); in FIO_decompressLzmaFrame()
2427 strm.next_out = (BYTE*)ress->dstBuffer; in FIO_decompressLzmaFrame()
2428 strm.avail_out = ress->dstBufferSize; in FIO_decompressLzmaFrame()
2434 memmove(ress->srcBuffer, strm.next_in, strm.avail_in); in FIO_decompressLzmaFrame()
2435 ress->srcBufferLoaded = strm.avail_in; in FIO_decompressLzmaFrame()
2437 FIO_fwriteSparseEnd(prefs, ress->dstFile, storedSkips); in FIO_decompressLzmaFrame()
2444 FIO_decompressLz4Frame(dRess_t* ress, FILE* srcFile, in FIO_decompressLz4Frame() argument
2463 MEM_writeLE32(ress->srcBuffer, LZ4_MAGICNUMBER); in FIO_decompressLz4Frame()
2464 … nextToLoad = LZ4F_decompress(dCtx, ress->dstBuffer, &outSize, ress->srcBuffer, &inSize, NULL); in FIO_decompressLz4Frame()
2476 size_t decodedBytes = ress->dstBufferSize; in FIO_decompressLz4Frame()
2479 if (nextToLoad > ress->srcBufferSize) nextToLoad = ress->srcBufferSize; in FIO_decompressLz4Frame()
2480 readSize = fread(ress->srcBuffer, 1, nextToLoad, srcFile); in FIO_decompressLz4Frame()
2483 …while ((pos < readSize) || (decodedBytes == ress->dstBufferSize)) { /* still to read, or still to… in FIO_decompressLz4Frame()
2486 decodedBytes = ress->dstBufferSize; in FIO_decompressLz4Frame()
2487 …nextToLoad = LZ4F_decompress(dCtx, ress->dstBuffer, &decodedBytes, (char*)(ress->srcBuffer)+pos, &… in FIO_decompressLz4Frame()
2498 … storedSkips = FIO_fwriteSparse(ress->dstFile, ress->dstBuffer, decodedBytes, prefs, storedSkips); in FIO_decompressLz4Frame()
2519 ress->srcBufferLoaded = 0; /* LZ4F will reach exact frame boundary */ in FIO_decompressLz4Frame()
2520 FIO_fwriteSparseEnd(prefs, ress->dstFile, storedSkips); in FIO_decompressLz4Frame()
2535 dRess_t ress, FILE* srcFile, in FIO_decompressFrames() argument
2547 const BYTE* const buf = (const BYTE*)ress.srcBuffer; in FIO_decompressFrames()
2548 if (ress.srcBufferLoaded < toRead) /* load up to 4 bytes for header */ in FIO_decompressFrames()
2549 ress.srcBufferLoaded += fread((char*)ress.srcBuffer + ress.srcBufferLoaded, in FIO_decompressFrames()
2550 (size_t)1, toRead - ress.srcBufferLoaded, srcFile); in FIO_decompressFrames()
2551 if (ress.srcBufferLoaded==0) { in FIO_decompressFrames()
2559 if (ress.srcBufferLoaded < toRead) { in FIO_decompressFrames()
2563 if (ZSTD_isFrame(buf, ress.srcBufferLoaded)) { in FIO_decompressFrames()
2564 …unsigned long long const frameSize = FIO_decompressZstdFrame(fCtx, &ress, srcFile, prefs, srcFileN… in FIO_decompressFrames()
2569 … unsigned long long const frameSize = FIO_decompressGzFrame(&ress, srcFile, prefs, srcFileName); in FIO_decompressFrames()
2579 …unsigned long long const frameSize = FIO_decompressLzmaFrame(&ress, srcFile, prefs, srcFileName, b… in FIO_decompressFrames()
2588 … unsigned long long const frameSize = FIO_decompressLz4Frame(&ress, srcFile, prefs, srcFileName); in FIO_decompressFrames()
2597 ress.dstFile, srcFile, in FIO_decompressFrames()
2598 ress.srcBuffer, ress.srcBufferSize, in FIO_decompressFrames()
2599 ress.srcBufferLoaded); in FIO_decompressFrames()
2627 dRess_t ress, FILE* srcFile, in FIO_decompressDstFile() argument
2635 if ((ress.dstFile == NULL) && (prefs->testMode==0)) { in FIO_decompressDstFile()
2647 ress.dstFile = FIO_openDstFile(fCtx, prefs, srcFileName, dstFileName, dstFilePermissions); in FIO_decompressDstFile()
2648 if (ress.dstFile==NULL) return 1; in FIO_decompressDstFile()
2657 result = FIO_decompressFrames(fCtx, ress, srcFile, prefs, dstFileName, srcFileName); in FIO_decompressDstFile()
2660 FILE* const dstFile = ress.dstFile; in FIO_decompressDstFile()
2662 ress.dstFile = NULL; in FIO_decompressDstFile()
2688 static int FIO_decompressSrcFile(FIO_ctx_t* const fCtx, FIO_prefs_t* const prefs, dRess_t ress, con… in FIO_decompressSrcFile() argument
2700 ress.srcBufferLoaded = 0; in FIO_decompressSrcFile()
2702 result = FIO_decompressDstFile(fCtx, prefs, ress, srcFile, dstFileName, srcFileName); in FIO_decompressSrcFile()
2730 dRess_t const ress = FIO_createDResources(prefs, dictFileName); in FIO_decompressFilename() local
2732 int const decodingError = FIO_decompressSrcFile(fCtx, prefs, ress, dstFileName, srcFileName); in FIO_decompressFilename()
2734 FIO_freeDResources(ress); in FIO_decompressFilename()
2869 dRess_t ress = FIO_createDResources(prefs, dictFileName); in FIO_decompressMultipleFilenames() local
2873 FIO_freeDResources(ress); in FIO_decompressMultipleFilenames()
2877 … ress.dstFile = FIO_openDstFile(fCtx, prefs, NULL, outFileName, DEFAULT_FILE_PERMISSIONS); in FIO_decompressMultipleFilenames()
2878 if (ress.dstFile == 0) EXM_THROW(19, "cannot open %s", outFileName); in FIO_decompressMultipleFilenames()
2881 … status = FIO_decompressSrcFile(fCtx, prefs, ress, outFileName, srcNamesTable[fCtx->currFileIdx]); in FIO_decompressMultipleFilenames()
2885 if ((!prefs->testMode) && (fclose(ress.dstFile))) in FIO_decompressMultipleFilenames()
2907 status = FIO_decompressSrcFile(fCtx, prefs, ress, dstFileName, srcFileName); in FIO_decompressMultipleFilenames()
2918 FIO_freeDResources(ress); in FIO_decompressMultipleFilenames()