Function test_memory_leak_prevention

src/cache/ttl_cache.rs:865–894

()

    #[test]
    fn test_memory_leak_prevention() {
        let cache = TtlCache::new();

        // Insert entries with explicit size
        cache.insert_with_ttl_and_size("key1".to_string(), "value1".to_string(), Duration::from_secs(1), 100);
        cache.insert_with_ttl_and_size("key2".to_string(), "value2".to_string(), Duration::from_secs(1), 200);

        let initial_stats = cache.stats();
        assert_eq!(initial_stats.total_size_bytes, 300);
        assert_eq!(initial_stats.total_entries, 2);

        // Replace entry (should deallocate old one)
        cache.insert_with_ttl_and_size("key1".to_string(), "new_value1".to_string(), Duration::from_secs(1), 150);

        let stats_after_replace = cache.stats();
        assert_eq!(stats_after_replace.total_size_bytes, 350); // 200 + 150
        assert_eq!(stats_after_replace.total_entries, 2);

        // Wait for expiration
        thread::sleep(Duration::from_millis(1100));

        // Access expired entry (should trigger deallocation)
        cache.get(&"key1".to_string());

        let stats_after_expired_access = cache.stats();
        assert_eq!(stats_after_expired_access.expired_evictions, 1);

        // Validate memory tracking consistency
        assert!(cache.validate_memory_tracking());
    }

    #[test]
    fn test_emergency_memory_eviction() {