Lines Matching refs:seqPool

279 static size_t ZSTDMT_sizeof_seqPool(ZSTDMT_seqPool* seqPool)  in ZSTDMT_sizeof_seqPool()  argument
281 return ZSTDMT_sizeof_bufferPool(seqPool); in ZSTDMT_sizeof_seqPool()
300 static rawSeqStore_t ZSTDMT_getSeq(ZSTDMT_seqPool* seqPool) in ZSTDMT_getSeq() argument
302 if (seqPool->bufferSize == 0) { in ZSTDMT_getSeq()
305 return bufferToSeq(ZSTDMT_getBuffer(seqPool)); in ZSTDMT_getSeq()
309 static rawSeqStore_t ZSTDMT_resizeSeq(ZSTDMT_seqPool* seqPool, rawSeqStore_t seq) in ZSTDMT_resizeSeq() argument
311 return bufferToSeq(ZSTDMT_resizeBuffer(seqPool, seqToBuffer(seq))); in ZSTDMT_resizeSeq()
315 static void ZSTDMT_releaseSeq(ZSTDMT_seqPool* seqPool, rawSeqStore_t seq) in ZSTDMT_releaseSeq() argument
317 ZSTDMT_releaseBuffer(seqPool, seqToBuffer(seq)); in ZSTDMT_releaseSeq()
320 static void ZSTDMT_setNbSeq(ZSTDMT_seqPool* const seqPool, size_t const nbSeq) in ZSTDMT_setNbSeq() argument
322 ZSTDMT_setBufferSize(seqPool, nbSeq * sizeof(rawSeq)); in ZSTDMT_setNbSeq()
327 … ZSTDMT_seqPool* const seqPool = ZSTDMT_createBufferPool(SEQ_POOL_MAX_NB_BUFFERS(nbWorkers), cMem); in ZSTDMT_createSeqPool() local
328 if (seqPool == NULL) return NULL; in ZSTDMT_createSeqPool()
329 ZSTDMT_setNbSeq(seqPool, 0); in ZSTDMT_createSeqPool()
330 return seqPool; in ZSTDMT_createSeqPool()
333 static void ZSTDMT_freeSeqPool(ZSTDMT_seqPool* seqPool) in ZSTDMT_freeSeqPool() argument
335 ZSTDMT_freeBufferPool(seqPool); in ZSTDMT_freeSeqPool()
471 ZSTDMT_seqPool* seqPool, in ZSTDMT_serialState_reset() argument
500 ZSTDMT_setNbSeq(seqPool, ZSTD_ldm_getMaxNbSeq(params.ldmParams, jobSize)); in ZSTDMT_serialState_reset()
644 ZSTDMT_seqPool* seqPool; /* Thread-safe - used by mtctx and (all) workers */ member
672 rawSeqStore_t rawSeqStore = ZSTDMT_getSeq(job->seqPool); in ZSTDMT_compressionJob()
779 ZSTDMT_releaseSeq(job->seqPool, rawSeqStore); in ZSTDMT_compressionJob()
839 ZSTDMT_seqPool* seqPool; member
949 mtctx->seqPool = ZSTDMT_createSeqPool(nbWorkers, cMem); in ZSTDMT_createCCtx_advanced_internal()
952 …if (!mtctx->factory | !mtctx->jobs | !mtctx->bufPool | !mtctx->cctxPool | !mtctx->seqPool | initEr… in ZSTDMT_createCCtx_advanced_internal()
1021 ZSTDMT_freeSeqPool(mtctx->seqPool); in ZSTDMT_freeCCtx()
1038 + ZSTDMT_sizeof_seqPool(mtctx->seqPool) in ZSTDMT_sizeof_CCtx()
1054 mtctx->seqPool = ZSTDMT_expandSeqPool(mtctx->seqPool, nbWorkers); in ZSTDMT_resize()
1055 if (mtctx->seqPool == NULL) return ERROR(memory_allocation); in ZSTDMT_resize()
1321 if (ZSTDMT_serialState_reset(&mtctx->serial, mtctx->seqPool, params, mtctx->targetSectionSize, in ZSTDMT_initCStream_internal()
1378 mtctx->jobs[jobID].seqPool = mtctx->seqPool; in ZSTDMT_createCompressionJob()