diff --git a/lib/compress/zstdmt_compress.c b/lib/compress/zstdmt_compress.c index 1a280b001..29acfdb6a 100644 --- a/lib/compress/zstdmt_compress.c +++ b/lib/compress/zstdmt_compress.c @@ -1967,13 +1967,6 @@ static size_t ZSTDMT_expandJobsTable (ZSTDMT_CCtx* mtctx, U32 nbWorkers) { } -/* ZSTDMT_CCtxParam_setNbWorkers(): - * Internal use only */ -static size_t ZSTDMT_CCtxParam_setNbWorkers(ZSTD_CCtx_params* params, unsigned nbWorkers) -{ - return ZSTD_CCtxParams_setParameter(params, ZSTD_c_nbWorkers, (int)nbWorkers); -} - typedef struct { ZSTDMT_CCtx* mtctx; ZSTD_customMem cMem; @@ -1992,7 +1985,8 @@ static size_t ZSTDMT_rust_createCCtx_setWorkers(void* opaque, unsigned nbWorkers { ZSTDMT_rust_createCCtx_context* const context = (ZSTDMT_rust_createCCtx_context*)opaque; - return ZSTDMT_CCtxParam_setNbWorkers(&context->mtctx->params, nbWorkers); + return ZSTD_CCtxParams_setParameter( + &context->mtctx->params, ZSTD_c_nbWorkers, (int)nbWorkers); } static void ZSTDMT_rust_createCCtx_setInitialState(void* opaque) @@ -2297,7 +2291,7 @@ static void* ZSTDMT_rust_resizeSeqPool(void* opaque, unsigned nbWorkers) static size_t ZSTDMT_rust_resizeSetNbWorkers(void* opaque, unsigned nbWorkers) { ZSTDMT_CCtx* const mtctx = (ZSTDMT_CCtx*)opaque; - (void)ZSTDMT_CCtxParam_setNbWorkers(&mtctx->params, nbWorkers); + (void)ZSTD_CCtxParams_setParameter(&mtctx->params, ZSTD_c_nbWorkers, (int)nbWorkers); return 0; }