sosistab 0.5.43

An obfuscated datagram transport for horrible networks
Documentation 
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
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62

use std::time::Instant;

use super::CongestionControl;

/// CUBIC-style congestion control
pub struct Cubic {
    cwnd: f64,
    beta: f64,
    cee: f64,
    last_loss: Option<Instant>,
    cwnd_max: f64,
    bdp: f64,
}

impl Cubic {
    /// Creates a new Cubic instance
    pub fn new(beta: f64, cee: f64) -> Self {
        Self {
            cwnd: 16.0,
            beta,
            cee,
            last_loss: None,
            cwnd_max: 1000.0,
            bdp: 0.0,
        }
    }

    fn recalculate_cwnd(&mut self) {
        if let Some(last_loss) = self.last_loss {
            let kay = (self.cwnd_max * (1.0 - self.beta) / self.cee).powf(0.3333);
            self.cwnd = (self.cee * (last_loss.elapsed().as_secs_f64() * 3.0 - kay).powi(3)
                + self.cwnd_max)
                .max(4.0);
        }
    }
}

impl CongestionControl for Cubic {
    fn cwnd(&self) -> usize {
        (self.cwnd).max(self.bdp) as usize
    }

    fn mark_ack(&mut self, current_bdp: usize, _: usize) {
        // tracing::debug!("ack => {:.2}", self.cwnd);
        // if no last_loss, just exponentially increase
        let max_cwnd = self.cwnd + (1.0f64).min(32.0 / self.cwnd);
        self.cwnd = max_cwnd;
        // recalculate; if there's a last loss this will fix things
        self.recalculate_cwnd();
        self.cwnd = self.cwnd.min(max_cwnd);
        self.bdp = current_bdp as f64
    }

    fn mark_loss(&mut self) {
        if self.cwnd >= self.bdp {
            tracing::debug!("loss!!!!!!!!!!!!!!! => {:.2}", self.cwnd());
            self.last_loss = Some(Instant::now());
            self.cwnd_max = self.cwnd;
            self.recalculate_cwnd()
        }
    }
}