zstd-safe 8.2.0

Safe low-level bindings for the zstd compression library.
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44

#![cfg(all(feature = "with-rust-allocator", feature = "std"))]

mod support {
    pub mod rust_allocator;
}

use std::sync::atomic::Ordering::Relaxed;
use support::rust_allocator::{LIVE_BYTES, TOTAL_BYTES};

fn input() -> Vec<u8> {
    b"hello zstd hello zstd hello zstd".repeat(256)
}

#[test]
fn one_shot_functions_use_global_allocator() {
    let input = input();
    let mut compressed =
        Vec::with_capacity(zstd_safe::compress_bound(input.len()));
    let mut decompressed = Vec::with_capacity(input.len());

    // The one-shot calls allocate and free their context internally, so we
    // check the monotonic counter for the allocation and the live counter
    // for the matching free.
    let live = LIVE_BYTES.load(Relaxed);
    let total = TOTAL_BYTES.load(Relaxed);
    zstd_safe::compress(&mut compressed, &input, 3)
        .expect("compression failed");
    assert!(
        TOTAL_BYTES.load(Relaxed) - total > 1024,
        "compress() did not allocate through the global allocator"
    );
    assert_eq!(LIVE_BYTES.load(Relaxed), live, "compress() leaked");

    let live = LIVE_BYTES.load(Relaxed);
    let total = TOTAL_BYTES.load(Relaxed);
    zstd_safe::decompress(&mut decompressed, &compressed)
        .expect("decompression failed");
    assert!(
        TOTAL_BYTES.load(Relaxed) > total,
        "decompress() did not allocate through the global allocator"
    );
    assert_eq!(LIVE_BYTES.load(Relaxed), live, "decompress() leaked");
    assert_eq!(input, decompressed);
}