yip-io 0.1.0

High-performance I/O engines (AF_XDP zero-copy, io_uring, and vectorized recvmmsg/sendmmsg) for yip
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

use std::net::UdpSocket;
use yip_io::batch::{send_gso_superpacket, set_udp_gso_segment};

#[test]
fn test_set_udp_gso_segment_probe() {
    let sock = UdpSocket::bind("127.0.0.1:0").expect("bind test socket");
    // Probe GSO segment setting - should succeed or cleanly report unsupported without error
    let res = set_udp_gso_segment(&sock, 1280);
    assert!(res.is_ok(), "GSO probe should succeed or return Ok(false)");
}

#[test]
fn test_send_gso_superpacket_or_unsupported() {
    let s1 = UdpSocket::bind("127.0.0.1:0").expect("bind s1");
    let s2 = UdpSocket::bind("127.0.0.1:0").expect("bind s2");
    s1.set_nonblocking(true).unwrap();
    s2.set_nonblocking(true).unwrap();

    let addr2 = s2.local_addr().unwrap();
    let payload = vec![0x42u8; 1280 * 2]; // 2 segments

    match send_gso_superpacket(&s1, &payload, 1280, addr2) {
        Ok(sent) => {
            // Kernel accepted GSO send or transient full buffer
            assert!(sent == 0 || sent == payload.len());
        }
        Err(e) => {
            // Kernel lacks UDP_SEGMENT or unsupported on this device loopback
            let raw = e.raw_os_error().unwrap_or(0);
            assert!(
                raw == libc::EINVAL || raw == libc::EOPNOTSUPP || raw == libc::EIO,
                "unexpected GSO error: {e}"
            );
        }
    }
}

#[test]
fn test_gso_super_packet_slicing() {
    let payload = vec![0x42u8; 64000];
    let mss = 1420;
    let segments = yip_io::tun_offload::slice_gso_payload(&payload, mss);
    assert_eq!(segments.len(), 46);
    assert_eq!(segments[0].len(), 1420);
    assert_eq!(segments.last().unwrap().len(), 64000 - 45 * 1420);
}