Method check_memory_pressure

src/protocol/memory_monitor.rs:196–228

Check current memory pressure and take action if needed

(&self)

    
    /// Check current memory pressure and take action if needed
    pub fn check_memory_pressure(&self) {
        if !self.monitoring_active.load(Ordering::Relaxed) {
            return;
        }
        
        let current_memory = self.get_current_memory_usage();
        let pressure = self.calculate_pressure_level(current_memory);
        
        // Update stats
        {
            let mut stats = self.stats.lock();
            stats.buffer_pool_bytes = self.buffer_pool_bytes.load(Ordering::Relaxed);
            stats.message_bytes = self.message_bytes.load(Ordering::Relaxed);
            stats.query_bytes = self.query_bytes.load(Ordering::Relaxed);
            stats.pressure_level = pressure;
            
            if current_memory > stats.peak_memory_bytes {
                stats.peak_memory_bytes = current_memory;
            }
            
            stats.cleanup_events = self.cleanup_events.load(Ordering::Relaxed);
        }
        
        // Take action based on pressure level
        if pressure != MemoryPressure::Low && self.config.enable_auto_cleanup {
            self.trigger_cleanup(pressure);
        }
        
        // Log memory status if detailed monitoring is enabled
        if self.config.enable_detailed_monitoring {
            self.log_memory_status(current_memory, pressure);
        }
    }
    
    /// Get current total memory usage
    fn get_current_memory_usage(&self) -> u64 {