Struct DecompressionMonitor 

pub struct DecompressionMonitor {
    pub max_size: u64,
    pub max_time: Duration,
    pub start_time: Instant,
    pub bytes_decompressed: Arc<AtomicU64>,
    pub should_cancel: Arc<AtomicU64>,
}

Decompression monitor for tracking progress during decompression

Fields

max_size: u64

Maximum allowed decompressed size

max_time: Duration

Maximum allowed decompression time

start_time: Instant

Start time of decompression

bytes_decompressed: Arc<AtomicU64>

Current bytes decompressed (updated during decompression)

should_cancel: Arc<AtomicU64>

Whether decompression should be cancelled

Implementations

impl DecompressionMonitor

pub fn new(max_size: u64, max_time: Duration) -> Self

Create a new decompression monitor

pub fn check_progress(&self, current_output_size: u64) -> Result<()>

Check if decompression should continue

pub fn request_cancellation(&self)

Request cancellation of decompression

pub fn get_stats(&self) -> (u64, Duration)

Get current statistics

Trait Implementations

impl Debug for DecompressionMonitor

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.