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

//! 0.21 H.2: compile-time assertion that `Monitor`, `MonitorBuilder`,
//! `ShardedRunner`, and `EventStream<M>` are `Send`.
//!
//! flowscope 0.13's `Driver<E>: Send + Sync` cleared the last
//! `!Send` field on `Monitor` (`Rc<RefCell<…>>` in the typed-slot
//! tree). Asserting it here freezes the contract — future
//! regressions (someone reintroducing a `Rc` somewhere) will fail
//! the test instead of silently breaking multi-thread users.

#![cfg(all(feature = "tokio", feature = "flow", feature = "http"))]

use netring::monitor::{EventStream, Monitor, MonitorBuilder, ShardedRunner};

fn assert_send<T: Send>() {}

#[test]
fn monitor_is_send() {
    assert_send::<Monitor>();
}

#[test]
fn monitor_builder_is_send() {
    assert_send::<MonitorBuilder>();
}

#[test]
fn sharded_runner_is_send() {
    assert_send::<ShardedRunner>();
}

#[test]
fn event_stream_is_send() {
    assert_send::<EventStream<flowscope::http::HttpMessage>>();
}