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

mod cursor;
mod p2p;
mod pkt;
mod tack;

pub use cursor::{Rd, SliceWr, Wr};
pub use p2p::{P2pReq, P2pResp, SubPush, SwarmPeer, decode_socket_addrs, encode_socket_addrs};
pub use pkt::{AckPkt, DataHeader, NackPkt, decode_punch, encode_punch};
pub use tack::{
  Ack, AckOut, Blocks, Items, Kind, Ranges, SessionHeader, StreamDataHeader, check_ranges,
  encode_ack, expand_pn,
};

pub use crate::s0_const::{
  ACK_BLOCKS, ACK_DELAY_US, DATA_HLEN, MAX_CNT, MAX_RANGES, RETX, SESSION_HLEN, ZSTD,
};

/// 紧凑 1 字节线协议错误类型
#[repr(u8)]
#[derive(Debug, Clone, Copy, PartialEq, Eq, thiserror::Error)]
pub enum WireError {
  #[error("帧数据截断")]
  Truncated = 1,
  #[error("魔数不匹配")]
  BadMagic = 2,
  #[error("协议版本不支持")]
  BadVersion = 3,
  #[error("未知操作码")]
  BadOp = 4,
  #[error("未知状态码")]
  BadStatus = 5,
  #[error("非法 UTF-8 编码")]
  InvalidUtf8 = 6,
  #[error("字段长度超出 u15 上限")]
  Overflow = 7,
  #[error("包头 CRC16 校验失败")]
  CrcMismatch = 8,
}