Lines Matching refs:dstBuff

646 …buffer_t dstBuff;                    /* set by worker (or mtctx), then read by worker & mtctx, the…  member
673 buffer_t dstBuff = job->dstBuff; in ZSTDMT_compressionJob() local
678 if (dstBuff.start == NULL) { /* streaming job : doesn't provide a dstBuffer */ in ZSTDMT_compressionJob()
679 dstBuff = ZSTDMT_getBuffer(job->bufPool); in ZSTDMT_compressionJob()
680 if (dstBuff.start==NULL) JOB_ERROR(ERROR(memory_allocation)); in ZSTDMT_compressionJob()
681 …job->dstBuff = dstBuff; /* this value can be read in ZSTDMT_flush, when it copies the whole job … in ZSTDMT_compressionJob()
722 …size_t const hSize = ZSTD_compressContinue(cctx, dstBuff.start, dstBuff.capacity, job->src.start, … in ZSTDMT_compressionJob()
732 BYTE* const ostart = (BYTE*)dstBuff.start; in ZSTDMT_compressionJob()
734 BYTE* oend = op + dstBuff.capacity; in ZSTDMT_compressionJob()
984 …GLOG(4, "job%02u: release dst address %08X", jobID, (U32)(size_t)mtctx->jobs[jobID].dstBuff.start); in ZSTDMT_releaseAllJobResources()
985 ZSTDMT_releaseBuffer(mtctx->bufPool, mtctx->jobs[jobID].dstBuff); in ZSTDMT_releaseAllJobResources()
1338 …assert(job->dstBuff.start == NULL); /* invoked from streaming variant only (otherwise, dstBuff m… in ZSTDMT_writeLastEmptyBlock()
1339 job->dstBuff = ZSTDMT_getBuffer(job->bufPool); in ZSTDMT_writeLastEmptyBlock()
1340 if (job->dstBuff.start == NULL) { in ZSTDMT_writeLastEmptyBlock()
1344 … assert(job->dstBuff.capacity >= ZSTD_blockHeaderSize); /* no buffer should ever be that small */ in ZSTDMT_writeLastEmptyBlock()
1346 job->cSize = ZSTD_writeLastEmptyBlock(job->dstBuff.start, job->dstBuff.capacity); in ZSTDMT_writeLastEmptyBlock()
1375 mtctx->jobs[jobID].dstBuff = g_nullBuffer; in ZSTDMT_createCompressionJob()
1476 … MEM_writeLE32((char*)mtctx->jobs[wJobID].dstBuff.start + mtctx->jobs[wJobID].cSize, checksum); in ZSTDMT_flushProduced()
1488 assert(mtctx->jobs[wJobID].dstBuff.start != NULL); in ZSTDMT_flushProduced()
1491 (const char*)mtctx->jobs[wJobID].dstBuff.start + mtctx->jobs[wJobID].dstFlushed, in ZSTDMT_flushProduced()
1501 ZSTDMT_releaseBuffer(mtctx->bufPool, mtctx->jobs[wJobID].dstBuff); in ZSTDMT_flushProduced()
1503 mtctx->jobs[wJobID].dstBuff = g_nullBuffer; in ZSTDMT_flushProduced()