Method trigger_cleanup

src/protocol/memory_monitor.rs:255–289

Trigger cleanup based on memory pressure

(&self, pressure: MemoryPressure)

    
    /// Trigger cleanup based on memory pressure
    fn trigger_cleanup(&self, pressure: MemoryPressure) {
        let mut last_check = self.last_check.lock();
        
        // Rate limit cleanup events
        if last_check.elapsed() < self.config.check_interval {
            return;
        }
        
        *last_check = Instant::now();
        
        // Increment cleanup counter
        self.cleanup_events.fetch_add(1, Ordering::Relaxed);
        
        // Update stats
        {
            let mut stats = self.stats.lock();
            stats.last_cleanup = Some(Instant::now());
        }
        
        match pressure {
            MemoryPressure::Medium => {
                debug!("Medium memory pressure detected, triggering gentle cleanup");
                self.execute_cleanup_callbacks(false);
            }
            MemoryPressure::High => {
                info!("High memory pressure detected, triggering cleanup");
                self.execute_cleanup_callbacks(false);
            }
            MemoryPressure::Critical => {
                warn!("Critical memory pressure detected, triggering aggressive cleanup");
                self.execute_cleanup_callbacks(true);
            }
            MemoryPressure::Low => {}
        }
    }
    
    /// Execute registered cleanup callbacks
    fn execute_cleanup_callbacks(&self, aggressive: bool) {