udp_prague 0.1.1

A Rust implementation of the Prague congestion control protocol for UDP-based applications.
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

use crate::core::{
    PragueRecvAckEvent, PragueRecvDataEvent, PragueRecvRfc8888AckEvent, PragueSendAckEvent,
    PragueSendDataEvent, PragueSendFrameDataEvent, PragueSendRfc8888AckEvent, Reporter,
    RunnerConfig,
};

use super::AppStuff;

impl From<&AppStuff> for RunnerConfig {
    fn from(app: &AppStuff) -> Self {
        Self {
            rcv_addr: app.rcv_addr.clone(),
            rcv_port: app.rcv_port,
            connect: app.connect,
            startup_wait_timeout_us: app.startup_wait_timeout_us,
            max_pkt: app.max_pkt,
            max_rate: app.max_rate,
            rfc8888_ack: app.rfc8888_ack,
            rfc8888_ackperiod: app.rfc8888_ackperiod,
            rt_mode: app.rt_mode,
            rt_fps: app.rt_fps,
            rt_frameduration: app.rt_frameduration,
        }
    }
}

impl Reporter for AppStuff {
    fn LogSendData(&mut self, event: &PragueSendDataEvent) {
        AppStuff::LogSendData(self, event);
    }

    fn LogSendFrameData(&mut self, event: &PragueSendFrameDataEvent) {
        AppStuff::LogSendFrameData(self, event);
    }

    fn LogRecvData(&mut self, event: &PragueRecvDataEvent) {
        AppStuff::LogRecvData(self, event);
    }

    fn LogSendACK(&mut self, event: &PragueSendAckEvent) {
        AppStuff::LogSendACK(self, event);
    }

    fn LogSendRFC8888ACK(&mut self, event: &PragueSendRfc8888AckEvent<'_>) {
        AppStuff::LogSendRFC8888ACK(self, event);
    }

    fn LogRecvACK(&mut self, event: &PragueRecvAckEvent) {
        AppStuff::LogRecvACK(self, event);
    }

    fn LogRecvRFC8888ACK(&mut self, event: &PragueRecvRfc8888AckEvent<'_>) {
        AppStuff::LogRecvRFC8888ACK(self, event);
    }
}