feat(compress): move CCtx zstd parameter setter to Rust

Keep the C helper's ZSTD_checkCParams assertion at the call boundary while
moving its three field assignments into the existing repr(C) Rust CCtx
parameter module. The Rust leaf updates cParams and fParams, resets the
compression-level marker to NO_CLEVEL, and leaves unrelated CCtx state intact.

Test Plan:
- `cargo test --manifest-path rust/Cargo.toml --no-default-features --features compression set_zstd_params_updates_only_zstd_parameter_fields` -- passed
- `make -B -C lib -j2 lib` -- passed
- `make -C tests -j2 fuzzer` -- passed
- `tests/fuzzer -s4560 -t47 -i48 -v` -- passed
- required clippy trio, nightly fmt, post-format clippy trio, and `git diff --check` -- passed
This commit is contained in:
2026-07-18 09:00:15 +02:00
parent 934a589500
commit 7ef97f97a9
2 changed files with 73 additions and 6 deletions
+3 -6
View File
@@ -137,6 +137,8 @@ ZSTD_CCtx_params* ZSTD_rust_createCCtxParams(ZSTD_customMem customMem);
size_t ZSTD_rust_freeCCtxParams(ZSTD_CCtx_params* params);
size_t ZSTD_rust_CCtxParams_init_advanced(ZSTD_CCtx_params* cctxParams,
ZSTD_parameters params);
void ZSTD_rust_CCtxParams_setZstdParams(ZSTD_CCtx_params* cctxParams,
const ZSTD_parameters* params);
int ZSTD_rust_useTargetCBlockSize(const ZSTD_CCtx_params* cctxParams);
int ZSTD_rust_blockSplitterEnabled(ZSTD_CCtx_params* cctxParams);
@@ -711,12 +713,7 @@ static void ZSTD_CCtxParams_setZstdParams(
ZSTD_CCtx_params* cctxParams, const ZSTD_parameters* params)
{
assert(!ZSTD_checkCParams(params->cParams));
cctxParams->cParams = params->cParams;
cctxParams->fParams = params->fParams;
/* Should not matter, as all cParams are presumed properly defined.
* But, set it for tracing anyway.
*/
cctxParams->compressionLevel = ZSTD_NO_CLEVEL;
ZSTD_rust_CCtxParams_setZstdParams(cctxParams, params);
}
ZSTD_bounds ZSTD_cParam_getBounds(ZSTD_cParameter param)
+70
View File
@@ -488,6 +488,26 @@ pub unsafe extern "C" fn ZSTD_rust_CCtxParams_init_advanced(
unsafe { init_advanced_impl(params, zstd_params) }
}
#[inline]
unsafe fn set_zstd_params_impl(
cctx_params: *mut ZSTD_CCtx_params,
zstd_params: *const ZSTD_parameters,
) {
unsafe {
(*cctx_params).cParams = (*zstd_params).cParams;
(*cctx_params).fParams = (*zstd_params).fParams;
(*cctx_params).compressionLevel = NO_CLEVEL;
}
}
#[no_mangle]
pub unsafe extern "C" fn ZSTD_rust_CCtxParams_setZstdParams(
cctx_params: *mut ZSTD_CCtx_params,
zstd_params: *const ZSTD_parameters,
) {
unsafe { set_zstd_params_impl(cctx_params, zstd_params) }
}
unsafe fn custom_calloc(size: usize, custom_mem: ZSTD_customMem) -> *mut c_void {
if let Some(custom_alloc) = custom_mem.customAlloc {
let allocation = unsafe { custom_alloc(custom_mem.opaque, size) };
@@ -1343,6 +1363,56 @@ mod tests {
assert_eq!(value, -1);
}
#[test]
fn set_zstd_params_updates_only_zstd_parameter_fields() {
let zstd_params = ZSTD_parameters {
cParams: ZSTD_compressionParameters {
windowLog: 20,
chainLog: 19,
hashLog: 18,
searchLog: 5,
minMatch: 4,
targetLength: 32,
strategy: STRATEGY_GREEDY,
},
fParams: ZSTD_frameParameters {
contentSizeFlag: 1,
checksumFlag: 1,
noDictIDFlag: 1,
},
};
let mut storage = MaybeUninit::<ZSTD_CCtx_params>::zeroed();
let params = storage.as_mut_ptr();
unsafe {
(*params).format = 1;
(*params).compressionLevel = 99;
(*params).forceWindow = 1;
(*params).targetCBlockSize = 4096;
(*params).ldmParams.enableLdm = 1;
(*params).customMem.opaque = ptr::dangling_mut::<c_void>();
(*params).extSeqProdState = ptr::dangling_mut::<c_void>();
(*params).searchForExternalRepcodes = 1;
let before = *params;
ZSTD_rust_CCtxParams_setZstdParams(params, &zstd_params);
assert_eq!((*params).cParams, zstd_params.cParams);
assert_eq!((*params).fParams, zstd_params.fParams);
assert_eq!((*params).compressionLevel, NO_CLEVEL);
assert_eq!((*params).format, before.format);
assert_eq!((*params).forceWindow, before.forceWindow);
assert_eq!((*params).targetCBlockSize, before.targetCBlockSize);
assert_eq!((*params).ldmParams.enableLdm, before.ldmParams.enableLdm);
assert_eq!((*params).customMem.opaque, before.customMem.opaque);
assert_eq!((*params).extSeqProdState, before.extSeqProdState);
assert_eq!(
(*params).searchForExternalRepcodes,
before.searchForExternalRepcodes
);
}
}
#[test]
fn advanced_init_resolves_policy_and_resets_internal_fields() {
let cases = [