triglav 0.2.0

High-performance multi-path networking tool with intelligent uplink management
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

//! Wire protocol for Triglav.
//!
//! Defines the packet format, message types, and serialization.
//!
//! ## Packet Format
//!
//! ```text
//! ┌─────────────────────────────────────────────────────────────────┐
//! │ Version (1) │ Type (1) │ Flags (2) │ Sequence (8) │ Timestamp (8) │
//! ├─────────────────────────────────────────────────────────────────┤
//! │                        Session ID (32)                          │
//! ├─────────────────────────────────────────────────────────────────┤
//! │ Uplink ID (2) │ Payload Length (2) │ Checksum (4) │ Payload ... │
//! └─────────────────────────────────────────────────────────────────┘
//! ```

mod codec;
mod message;
mod packet;

pub use codec::{decode_packet, encode_packet, PacketCodec};
pub use message::{ControlMessage, DataMessage, Message, MessageType};
pub use packet::{Packet, PacketFlags, PacketHeader, PacketType};

use crate::PROTOCOL_VERSION;

/// Header size in bytes.
pub const HEADER_SIZE: usize = 60;

/// Maximum payload size.
pub const MAX_PAYLOAD_SIZE: usize = 1400;

/// Minimum packet size (header only).
pub const MIN_PACKET_SIZE: usize = HEADER_SIZE;

/// Calculate CRC32 checksum.
pub fn checksum(data: &[u8]) -> u32 {
    let mut hasher = crc32fast::Hasher::new();
    hasher.update(data);
    hasher.finalize()
}

/// Verify protocol version compatibility.
pub fn is_compatible_version(version: u8) -> bool {
    version == PROTOCOL_VERSION
}