_gpak_compressor_deflate _gpak_compressor_generate_dictionary _gpak_compressor_none _gpak_compressor_zstd _gpak_decompressor_inflate _gpak_decompressor_none _gpak_decompressor_zstd

_gpak_compressor_zstd() GPAK_API uint32_t _gpak_compressor_zstd ( gpak_t *  _pak, FILE *  _infile, FILE *  _outfile  ) Brief Description:\n Compresses the input file using the Zstandard (zstd) algorithm. This function compresses the input file using the Zstandard (zstd) algorithm and writes the compressed data to the output file. Parameters _pak A pointer to the gpak_t. _infile A pointer to the input FILE. _outfile A pointer to the output FILE. Returns The number of bytes written to the output file. Definition at line 227 of file gpak_compressors.c. { size_t const buffInSize = ZSTD_CStreamInSize(); void* const buffIn = malloc(buffInSize); size_t const buffOutSize = ZSTD_CStreamOutSize(); void* const buffOut = malloc(buffOutSize); fseek(_infile, 0, SEEK_END); size_t _total_size = ftell(_infile); fseek(_infile, 0, SEEK_SET); uint32_t _crc32 = crc32(0L, Z_NULL, 0); /* Create the context. */ ZSTD_CCtx* const cctx = ZSTD_createCCtx(); uint32_t thread_count = get_num_threads(); /* Set parameters. */ ZSTD_CCtx_setParameter(cctx, ZSTD_c_compressionLevel, _pak->header_.compression_level_); ZSTD_CCtx_setParameter(cctx, ZSTD_c_checksumFlag, 1); ZSTD_CCtx_setParameter(cctx, ZSTD_c_enableLongDistanceMatching, 1); ZSTD_CCtx_setParameter(cctx, ZSTD_c_windowLog, 27); ZSTD_CCtx_setParameter(cctx, ZSTD_c_nbWorkers, thread_count); ZSTD_CCtx_setParameter(cctx, ZSTD_c_jobSize, buffInSize * thread_count); if (_pak->dictionary_ && _pak->header_.dictionary_size_ > 0) ZSTD_CCtx_loadDictionary(cctx, _pak->dictionary_, _pak->header_.dictionary_size_); size_t _total_readed = 0ull; size_t const toRead = buffInSize; for (;;) { size_t read = _freadb(buffIn, 1, toRead, _infile); _total_readed += read; _crc32 = crc32(_crc32, buffIn, read); _gpak_pass_progress(_pak, _total_readed, _total_size, GPAK_STAGE_COMPRESSION); int const lastChunk = (read < toRead); ZSTD_EndDirective const mode = lastChunk ? ZSTD_e_end : ZSTD_e_continue; ZSTD_inBuffer input = { buffIn, read, 0 }; int finished; do { ZSTD_outBuffer output = { buffOut, buffOutSize, 0 }; size_t const remaining = ZSTD_compressStream2(cctx, &output, &input, mode); //CHECK_ZSTD(remaining); _fwriteb(buffOut, 1, output.pos, _outfile); finished = lastChunk ? (remaining == 0) : (input.pos == input.size); } while (!finished); assert(input.pos == input.size && "Impossible: zstd only returns 0 when the input is completely consumed!"); if (lastChunk) break; } ZSTD_freeCCtx(cctx); free(buffIn); free(buffOut); return _crc32; } References gpak_header::compression_level_, gpak::dictionary_, gpak_header::dictionary_size_, GPAK_STAGE_COMPRESSION, and gpak::header_.