netring 0.5.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

//! Integration test for block timeout behavior.

#![cfg(feature = "integration-tests")]

mod helpers;

use netring::CaptureBuilder;
use std::time::Duration;

#[test]
fn block_timeout_triggers() {
    let port = helpers::unique_port();

    let mut rx = CaptureBuilder::default()
        .interface(helpers::LOOPBACK)
        .block_timeout_ms(10) // very short timeout
        .build()
        .expect("build rx");

    // Send exactly 1 small packet — not enough to fill a block
    helpers::send_udp_to_loopback(port, b"timeout_test", 1);

    // The block should be retired by timeout, not by being full
    let batch = rx
        .next_batch_blocking(Duration::from_secs(2))
        .expect("poll")
        .expect("should get a batch via timeout");

    assert!(!batch.is_empty());
    // With a 10ms timeout and only 1 packet, the block was likely
    // retired via timeout. Note: on a busy loopback, the block might
    // fill with other traffic before the timeout fires.
    // We mainly verify the batch arrives within a reasonable time.
}