netring 0.24.0

High-performance zero-copy packet I/O for Linux (AF_PACKET TPACKET_V3 + AF_XDP)
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

//! UDP lifecycle marker.

use flowscope::driver::{DriverBuilder, SlotHandle};
use flowscope::extract::{FiveTuple, FiveTupleKey};

use crate::protocol::{Dispatch, FlowProtocol, Protocol, ProtocolInitError};

/// UDP lifecycle marker. Registering this protocol enables
/// `FlowStarted<Udp>`, `FlowEnded<Udp>` typed events — no parser
/// slot is registered on flowscope's side because the central
/// flow tracker already emits UDP lifecycle events.
#[derive(Debug, Clone, Copy)]
pub struct Udp;

impl Protocol for Udp {
    type Message = ();
    const NAME: &'static str = "udp";

    fn dispatch() -> Dispatch {
        Dispatch::AllUdp
    }

    fn register(
        _builder: &mut DriverBuilder<FiveTuple>,
    ) -> Result<SlotHandle<Self::Message, FiveTupleKey>, ProtocolInitError> {
        Err(ProtocolInitError(
            "Udp marker is lifecycle-only — no parser; \
             handled by the central flow tracker"
                .into(),
        ))
    }
}

// 0.22 R1: UDP is flow-tracked, not a message protocol.
impl FlowProtocol for Udp {}

#[cfg(test)]
mod tests {
    use super::*;

    #[test]
    fn dispatch_is_all_udp() {
        assert!(matches!(<Udp as Protocol>::dispatch(), Dispatch::AllUdp));
    }

    #[test]
    fn register_returns_err_for_lifecycle_only_marker() {
        let mut b = flowscope::driver::Driver::builder(FiveTuple::bidirectional());
        assert!(<Udp as Protocol>::register(&mut b).is_err());
    }
}