ddidderr/zstd-rs
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

added error message, updated copying dictionary into the input buffer

Browse Source
This commit is contained in:
Paul Cruz
2017-07-11 15:00:52 -07:00
parent 34afb9b23e
commit a3c077b8c6
1 changed files with 5 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files
contrib/adaptive-compression/adapt.c
+5 -2
View File
@@ -270,6 +270,7 @@ static void* compressionThread(void* arg)
if (currJob != 0) { /* not first job */ if (currJob != 0) { /* not first job */
size_t const hSize = ZSTD_compressContinue(ctx->cctx, job->dst.start, job->dst.size, job->src.start, job->src.size); size_t const hSize = ZSTD_compressContinue(ctx->cctx, job->dst.start, job->dst.size, job->src.start, job->src.size);
if (ZSTD_isError(hSize)) { if (ZSTD_isError(hSize)) {
DISPLAY("Error: something went wrong while continuing compression\n");
job->compressedSize = hSize; job->compressedSize = hSize;
ctx->threadError = 1; ctx->threadError = 1;
return arg; return arg;
@@ -410,8 +411,10 @@ static int createCompressionJob(adaptCCtx* ctx, size_t srcSize, int last)
/* if not on the last job, reuse data as dictionary in next job */ /* if not on the last job, reuse data as dictionary in next job */
if (!last) { if (!last) {
ctx->input.filled = srcSize; size_t const newDictSize = srcSize;
memmove(ctx->input.buffer.start, ctx->input.buffer.start + ctx->input.filled, srcSize); size_t const oldDictSize = ctx->input.filled;
memmove(ctx->input.buffer.start, ctx->input.buffer.start + oldDictSize + srcSize - newDictSize, newDictSize);
ctx->input.filled = newDictSize;
} }
return 0; return 0;
} }