network-protocol 1.2.1

Secure, high-performance protocol core with backpressure control, structured logging, timeout handling, TLS support, and comprehensive benchmarking for robust Rust networked applications and services.
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

use bytes::BytesMut;
use network_protocol::{config::PROTOCOL_VERSION, core::codec::PacketCodec, core::packet::Packet};
use tokio_util::codec::Encoder;

#[test]
#[allow(clippy::unwrap_used)]
fn stress_packet_encode_decode_large_series() {
    // Simulate heavy burst of packets, ensure no panics and minimal overhead
    let mut codec = PacketCodec;
    let mut buf = BytesMut::new();

    for size in [0usize, 1, 64, 512, 4096, 65536, 1_048_576] {
        for _ in 0..10_000 {
            let p = Packet {
                version: PROTOCOL_VERSION,
                payload: vec![0u8; size],
            };
            codec.encode(p, &mut buf).unwrap();
            let decoded = Packet::from_bytes(&buf);
            assert!(decoded.is_ok());
            buf.clear();
        }
    }
}