Function backpressure_thresholds_per_virtual_queue

nodedb-bridge/src/wfq.rs:376–396

()

    #[test]
    fn backpressure_thresholds_per_virtual_queue() {
        let mut wfq: WeightedFairQueue<u32> = WeightedFairQueue::new(8, 100);
        wfq.set_priority(1, PriorityClass::Standard);
        wfq.set_priority(2, PriorityClass::Standard);

        // Fair share = 8 / 2 = 4 per DB.
        // Push 3 items into DB 1 → 3/4 = 75% → not throttled.
        for _ in 0..3 {
            wfq.try_enqueue(1, 0).unwrap();
        }
        assert!(!wfq.is_throttled_for(1));
        assert!(!wfq.is_suspended_for(1));

        // Push 1 more → 4/4 = 100% → throttled AND suspended.
        wfq.try_enqueue(1, 0).unwrap();
        assert!(wfq.is_throttled_for(1));
        assert!(wfq.is_suspended_for(1));

        // DB 2 is untouched → not throttled.
        assert!(!wfq.is_throttled_for(2));
    }
}