fumble 0.6.1

an oxidized implementation of the original clumsy tool, designed to simulate adverse network conditions on Windows systems.
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41

use crate::network::modules::stats::util::ewma::Ewma;

pub struct ReorderStats {
    pub(crate) total_packets: usize,
    pub(crate) reordered_packets: usize,
    pub(crate) delayed_packets: usize,
    ewma: Ewma,
}

impl ReorderStats {
    pub fn new(alpha: f64) -> Self {
        ReorderStats {
            total_packets: 0,
            reordered_packets: 0,
            delayed_packets: 0,
            ewma: Ewma::new(alpha),
        }
    }

    pub fn record(&mut self, reordered: bool) {
        self.total_packets += 1;
        if reordered {
            self.reordered_packets += 1;
        }

        let current_reorder_rate = if reordered { 1.0 } else { 0.0 };
        self.ewma.update(current_reorder_rate);
    }

    pub fn total_reorder_rate(&self) -> f64 {
        if self.total_packets == 0 {
            0.0
        } else {
            self.reordered_packets as f64 / self.total_packets as f64
        }
    }

    pub fn recent_reorder_rate(&self) -> f64 {
        self.ewma.get().unwrap_or(0.0)
    }
}