facebook
/
zstd
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

changed to using ZSTD_compressBegin_usingDict() and fixed strange issue with ZSTD_compressContinue()

dev
Paul Cruz 2017-07-11 11:50:00 -07:00
parent 7ec5928626
commit 34afb9b23e
1 changed files with 2 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
contrib/adaptive-compression/adapt.c
View File

@ -252,13 +252,12 @@ static void* compressionThread(void* arg)
/* compress the data */
{
unsigned const cLevel = adaptCompressionLevel(ctx);
ZSTD_parameters params = ZSTD_getParams(cLevel, job->src.size, 0);
DEBUG(2, "cLevel used: %u\n", cLevel);
/* begin compression */
{
size_t const dictModeError = ZSTD_setCCtxParameter(ctx->cctx, ZSTD_p_forceRawDict, 1);
size_t const initError = ZSTD_compressBegin_advanced(ctx->cctx, job->dict.start, job->dict.size, params, 0);
size_t const initError = ZSTD_compressBegin_usingDict(ctx->cctx, job->dict.start, job->dict.size, cLevel);
size_t const windowSizeError = ZSTD_setCCtxParameter(ctx->cctx, ZSTD_p_forceWindow, 1);
if (ZSTD_isError(dictModeError) || ZSTD_isError(initError) || ZSTD_isError(windowSizeError)) {
DISPLAY("Error: something went wrong while starting compression\n");
@ -269,7 +268,7 @@ static void* compressionThread(void* arg)
/* continue compression */
if (currJob != 0) { /* not first job */
size_t const hSize = ZSTD_compressContinue(ctx->cctx, job->dst.start, job->dst.size, job->src.start, 0);
size_t const hSize = ZSTD_compressContinue(ctx->cctx, job->dst.start, job->dst.size, job->src.start, job->src.size);
if (ZSTD_isError(hSize)) {
job->compressedSize = hSize;
ctx->threadError = 1;