in nfm-common/src/sock_ops_handler.rs [1027:1069]
fn test_ebpf_sock_op_too_many_connections() {
let mut mock_ktime_us: u64 = 99;
let mut cookie: u64 = 197;
let mut mock_ebpf_maps = MockEbpfMaps::new();
for _ in 0..MAX_ENTRIES_SK_PROPS_HI {
run_sock_ops_test(
cookie,
BPF_SOCK_OPS_TCP_CONNECT_CB,
&mut mock_ebpf_maps,
mock_ktime_us,
Ok(()),
);
cookie += 3;
mock_ktime_us += 10;
}
for _ in 0..10 {
run_sock_ops_test(
cookie,
BPF_SOCK_OPS_TCP_CONNECT_CB,
&mut mock_ebpf_maps,
mock_ktime_us,
Err(SockOpsResultCode::MapInsertionError),
);
cookie += 3;
mock_ktime_us += 10;
}
// Validate results.
assert!(MAX_ENTRIES_SK_PROPS_HI > 0);
assert_eq!(
mock_ebpf_maps.NFM_SK_PROPS.data.len(),
MAX_ENTRIES_SK_PROPS_HI.try_into().unwrap()
);
assert_eq!(
mock_ebpf_maps.counters().active_connect_events,
(MAX_ENTRIES_SK_PROPS_HI + 10).try_into().unwrap()
);
assert_eq!(mock_ebpf_maps.counters().map_insertion_errors, 10);
}