feat: support quic-multipath

Author: Frando

src/events/quic.rs

@@ -69,6 +69,7 @@ pub struct PacketHeader {
     pub key_phase_bit: Option<bool>,
     pub packet_number_length: Option<u8>,
     pub packet_number: Option<u64>,
+    pub path_id: Option<u64>,
 
     pub token: Option<Token>,
 
@@ -113,6 +114,7 @@ impl PacketHeader {
         PacketHeader {
             packet_type,
             packet_number,
+            path_id: None,
             token,
             length,
             version,
@@ -222,6 +224,12 @@ pub enum TransportError {
     AeadLimitReached,
     NoViablePath,
     Unknown,
+    // Multipath error codes:
+    // https://www.ietf.org/archive/id/draft-ietf-quic-multipath-17.html#name-error-codes
+    ApplicationAbandonPath,
+    PathResourceLimitReached,
+    PathUnstableOrPoor,
+    NoCidsAvailableForPath,
 }
 
 #[derive(Serialize, Deserialize, Clone, Copy, PartialEq, Eq, Debug)]
@@ -440,6 +448,15 @@ pub enum QuicFrameTypeName {
     ApplicationClose,
     HandshakeDone,
     Datagram,
+    PathAck,
+    PathAbandon,
+    PathStatusAvailable,
+    PathStatusBackup,
+    PathNewConnectionId,
+    PathRetireConnectionId,
+    MaxPathId,
+    PathsBlocked,
+    PathCidsBlocked,
     #[default]
     Unknown,
 }
@@ -583,6 +600,70 @@ pub enum QuicFrame {
         raw: Option<RawInfo>,
     },
 
+    // Extension: QUIC Multipath
+    // https://datatracker.ietf.org/doc/draft-ietf-quic-multipath/17/
+    PathAck {
+        path_id: u64,
+        ack_delay: Option<f32>,
+        acked_ranges: Option<AckedRanges>,
+
+        ect1: Option<u64>,
+        ect0: Option<u64>,
+        ce: Option<u64>,
+
+        raw: Option<RawInfo>,
+    },
+
+    PathAbandon {
+        path_id: u64,
+        error_code: u64,
+        raw: Option<RawInfo>,
+    },
+
+    PathStatusAvailable {
+        path_id: u64,
+        path_status_sequence_number: u64,
+        raw: Option<RawInfo>,
+    },
+
+    PathStatusBackup {
+        path_id: u64,
+        path_status_sequence_number: u64,
+        raw: Option<RawInfo>,
+    },
+
+    PathNewConnectionId {
+        path_id: u64,
+        sequence_number: u64,
+        retire_prior_to: u64,
+        connection_id_length: Option<u8>,
+        connection_id: Bytes,
+        stateless_reset_token: Option<StatelessResetToken>,
+        raw: Option<RawInfo>,
+    },
+
+    PathRetireConnectionId {
+        path_id: u64,
+        sequence_number: u64,
+        raw: Option<RawInfo>,
+    },
+
+    MaxPathId {
+        maximum_path_id: u64,
+        raw: Option<RawInfo>,
+    },
+
+    PathsBlocked {
+        maximum_path_id: u64,
+        raw: Option<RawInfo>,
+    },
+
+    PathCidsBlocked {
+        path_id: u64,
+        next_sequence_number: u64,
+        raw: Option<RawInfo>,
+    },
+
     Unknown {
         frame_type_bytes: Option<u64>,
         raw: Option<RawInfo>,
@@ -654,6 +735,10 @@ pub struct ParametersSet {
 
     pub preferred_address: Option<PreferredAddress>,
 
+    /// Extension: QUIC Multipath
+    /// <https://datatracker.ietf.org/doc/draft-ietf-quic-multipath/17/>
+    pub initial_max_path_id: Option<u64>,
+
     pub unknown_parameters: Vec<UnknownTransportParameter>,
 
     pub max_datagram_frame_size: Option<u64>,
@@ -972,6 +1057,8 @@ pub struct RecoveryParametersSet {
 #[serde_with::skip_serializing_none]
 #[derive(Serialize, Deserialize, Clone, PartialEq, Debug, Default)]
 pub struct RecoveryMetricsUpdated {
+    pub path_id: Option<u64>,
+
     pub min_rtt: Option<f32>,
     pub smoothed_rtt: Option<f32>,
     pub latest_rtt: Option<f32>,
@@ -993,6 +1080,8 @@ pub struct RecoveryMetricsUpdated {
 #[serde_with::skip_serializing_none]
 #[derive(Serialize, Deserialize, Clone, PartialEq, Eq, Debug, Default)]
 pub struct CongestionStateUpdated {
+    pub path_id: Option<u64>,
+
     pub old: Option<String>,
     pub new: String,
 
@@ -1002,6 +1091,8 @@ pub struct CongestionStateUpdated {
 #[serde_with::skip_serializing_none]
 #[derive(Serialize, Deserialize, Clone, PartialEq, Debug)]
 pub struct TimerUpdated {
+    pub path_id: Option<u64>,
+
     pub timer_type: Option<TimerType>,
     pub timer_id: Option<u64>,
     pub packet_number_space: Option<PacketNumberSpace>,

src/lib.rs

@@ -132,6 +132,7 @@
 //! let event_data =
 //!     qlog::events::EventData::PacketSent(qlog::events::quic::PacketSent {
 //!         header: pkt_hdr,
+//!         path_id: None,
 //!         frames: Some(frames.into()),
 //!         stateless_reset_token: None,
 //!         supported_versions: None,
@@ -337,6 +338,7 @@
 //! let event_data =
 //!     qlog::events::EventData::PacketSent(qlog::events::quic::PacketSent {
 //!         header: pkt_hdr,
+//!         path_id: None,
 //!         frames: Some(vec![ping, padding].into()),
 //!         stateless_reset_token: None,
 //!         supported_versions: None,