Use disunityff encode parameters

Author: yungcomputerchair

Cargo.lock

@@ -17,6 +17,7 @@ clap = { version = "4.5.20", features = ["derive"], optional = true }
 indicatif = { version = "0.17.9", features = ["tokio", "improved_unicode"], optional = true }
 futures-util = "0.3.31"
 countio = { version = "0.2.19", optional = true }
+num_cpus = "1.16.0"
 
 [lib]
 name = "ffbuildtool"

Cargo.toml

@@ -6,14 +6,39 @@ use std::{
 };
 
 use countio::Counter;
-use liblzma::{read::XzDecoder, write::XzEncoder};
+use liblzma::{
+    read::XzDecoder,
+    stream::{Check, Filters, LzmaOptions, MtStreamBuilder},
+    write::XzEncoder,
+};
 use log::*;
 
 use crate::{util, Error, FileInfo};
 
 // level index, file index, total files, file name
 pub type CompressionCallback = fn(usize, usize, usize, String);
 
+fn get_lzma_encoder<W: Write>(writer: &mut W, level: u32) -> Result<XzEncoder<&mut W>, Error> {
+    let mut options = LzmaOptions::new_preset(level)?;
+    options
+        .literal_context_bits(3)
+        .literal_position_bits(0)
+        .position_bits(2)
+        .dict_size(1 << 19);
+
+    let mut filters = Filters::new();
+    filters.lzma2(&options);
+
+    let stream = MtStreamBuilder::new()
+        .preset(level)
+        .check(Check::Crc64)
+        .threads(num_cpus::get() as u32)
+        .filters(filters)
+        .encoder()
+        .unwrap();
+    Ok(XzEncoder::new_stream(writer, stream))
+}
+
 fn read_u32<T: Read>(reader: &mut T) -> Result<u32, Error> {
     let mut buf = [0; 4];
     reader.read_exact(&mut buf)?;
@@ -351,7 +376,7 @@ impl Level {
         level_idx: usize,
         callback: Option<CompressionCallback>,
     ) -> Result<usize, Error> {
-        let mut writer = Counter::new(XzEncoder::new_parallel(writer, compression));
+        let mut writer = Counter::new(get_lzma_encoder(writer, compression)?);
         let header = self.gen_header();
         header.write(&mut writer)?;