s0_udp 0.1.0

sync0 基于 compio 的高速 UDP 传输、线协议、自适应 Zstd 与 Dragonfly P2P 引擎
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

use itoa::Buffer;

use super::BLK;
use crate::s0_const::Role;

#[derive(Default, Debug, Clone, Copy)]
pub struct Stats {
  pub bytes: u64,
  pub us: u64,
  pub packets: u64,
  pub retx: u64,
  pub blocks: u32,
  pub srtt_us: u64,
  pub rtt_min_us: u64,
}

impl Stats {
  pub const fn merge(&mut self, o: &Self) {
    self.bytes += o.bytes;
    self.us += o.us;
    self.packets += o.packets;
    self.retx += o.retx;
    self.blocks += o.blocks;
    if o.srtt_us > 0 {
      self.srtt_us = o.srtt_us;
    }
    if o.rtt_min_us > 0 && (self.rtt_min_us == 0 || o.rtt_min_us < self.rtt_min_us) {
      self.rtt_min_us = o.rtt_min_us;
    }
  }

  pub fn line(&self, role: Role) -> String {
    let mut out = String::with_capacity(128);
    let mut b = Buffer::new();
    out.push_str("{\"role\":\"");
    out.push_str(role.as_str());
    out.push_str("\",\"bytes\":");
    out.push_str(b.format(self.bytes));
    out.push_str(",\"us\":");
    out.push_str(b.format(self.us));
    out.push_str(",\"packets\":");
    out.push_str(b.format(self.packets));
    out.push_str(",\"retx\":");
    out.push_str(b.format(self.retx));
    out.push_str(",\"blocks\":");
    out.push_str(b.format(self.blocks));
    out.push_str(",\"srtt_us\":");
    out.push_str(b.format(self.srtt_us));
    out.push_str(",\"rtt_min_us\":");
    out.push_str(b.format(self.rtt_min_us));
    out.push('}');
    out
  }
}

/// 已完成字节数（按 `done_lo` 块粒度）
pub(super) const fn done_bytes(done_lo: u32, total: u64) -> u64 {
  let done = done_lo as u64 * BLK as u64;
  if done < total { done } else { total }
}