adding zstd threadpool methods

Author: WingZer0o

Cargo.toml

@@ -1,6 +1,6 @@
 [package]
 name = "cas_core_lib"
-version = "0.1.8"
+version = "0.1.9"
 edition = "2021"
 description = "This is a Rust library providing external facing functions to performant and trusted encryption in Rust"
 license = "Apache-2.0"
@@ -14,4 +14,4 @@ crate-type = ["dylib"]
 
 [dependencies]
 libc = "0.2.146"
-cas-lib = "0.1.8"
+cas-lib = "0.1.9"

src/zstd/mod.rs

@@ -21,6 +21,20 @@ pub extern "C" fn decompress(data_to_decompress: *const c_uchar, data_to_decompr
     result
 }
 
+#[no_mangle]
+pub extern "C" fn decompress_threadpool(data_to_decompress: *const c_uchar, data_to_decompress_length: usize) -> ZstdCompressResult {
+    let data_to_decompress = unsafe { std::slice::from_raw_parts(data_to_decompress, data_to_decompress_length) }.to_vec();
+    let mut decompressed_data = zstd::decompress_threadpool(data_to_decompress);
+    let capacity = decompressed_data.capacity();
+    decompressed_data.reserve_exact(capacity);
+    let result = ZstdCompressResult {
+        data: decompressed_data.as_mut_ptr(),
+        length: decompressed_data.len()
+    };
+    std::mem::forget(decompressed_data);
+    result
+}
+
 #[no_mangle]
 pub extern "C" fn compress(data_to_compress: *const c_uchar, data_to_compress_length: usize, level: usize) -> ZstdCompressResult {
     let data_to_compress = unsafe { std::slice::from_raw_parts(data_to_compress, data_to_compress_length) }.to_vec();
@@ -33,4 +47,18 @@ pub extern "C" fn compress(data_to_compress: *const c_uchar, data_to_compress_le
     };
     std::mem::forget(compressed_data);
     result
+}
+
+#[no_mangle]
+pub extern "C" fn compress_threadpool(data_to_compress: *const c_uchar, data_to_compress_length: usize, level: usize) -> ZstdCompressResult {
+    let data_to_compress = unsafe { std::slice::from_raw_parts(data_to_compress, data_to_compress_length) }.to_vec();
+    let mut compressed_data = zstd::compress_threadpool(data_to_compress, level as i32);
+    let capacity = compressed_data.capacity();
+    compressed_data.reserve_exact(capacity);
+    let result = ZstdCompressResult {
+        data: compressed_data.as_mut_ptr(),
+        length: compressed_data.len()
+    };
+    std::mem::forget(compressed_data);
+    result
 }