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

swap buffers instead of copying memory over

dev
Paul Cruz 2017-07-17 14:39:10 -07:00
parent 708238e07e
commit 6be22f1f84
1 changed files with 7 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -501,7 +501,12 @@ static int createCompressionJob(adaptCCtx* ctx, size_t srcSize, int last)
job->src.size = srcSize; job->src.size = srcSize;
job->jobID = nextJob; job->jobID = nextJob;
job->lastJob = last; job->lastJob = last;
memcpy(job->src.start, ctx->input.buffer.start, ctx->lastDictSize + srcSize); {
/* swap buffer */
void* const copy = job->src.start;
job->src.start = ctx->input.buffer.start;
ctx->input.buffer.start = copy;
}
job->dictSize = ctx->lastDictSize; job->dictSize = ctx->lastDictSize;
pthread_mutex_lock(&ctx->jobReady_mutex.pMutex); pthread_mutex_lock(&ctx->jobReady_mutex.pMutex);
ctx->jobReadyID++; ctx->jobReadyID++;
@ -514,7 +519,7 @@ static int createCompressionJob(adaptCCtx* ctx, size_t srcSize, int last)
if (!last) { if (!last) {
size_t const oldDictSize = ctx->lastDictSize; size_t const oldDictSize = ctx->lastDictSize;
DEBUG(3, "oldDictSize %zu\n", oldDictSize); DEBUG(3, "oldDictSize %zu\n", oldDictSize);
memmove(ctx->input.buffer.start, ctx->input.buffer.start + oldDictSize, srcSize); memcpy(ctx->input.buffer.start, job->src.start + oldDictSize, srcSize);
ctx->lastDictSize = srcSize; ctx->lastDictSize = srcSize;
ctx->input.filled = srcSize; ctx->input.filled = srcSize;
} }