diff --git a/test/integration-ebpf/src/redirect.rs b/test/integration-ebpf/src/redirect.rs index 2b695945..215b43fa 100644 --- a/test/integration-ebpf/src/redirect.rs +++ b/test/integration-ebpf/src/redirect.rs @@ -31,7 +31,9 @@ pub fn redirect_sock(ctx: XdpContext) -> u32 { // Check whether incoming packet's queue ID matches the queue ID of the socket in XSKMAP at index `queue_id`. if SOCKS.get(queue_id) == Some(queue_id) { // Queue ID matches, redirect to AF_XDP socket. - SOCKS.redirect(0, 0).unwrap_or(xdp_action::XDP_ABORTED) + SOCKS + .redirect(queue_id, 0) + .unwrap_or(xdp_action::XDP_ABORTED) } else { // Queue ID did not match, pass packet to kernel network stack. xdp_action::XDP_PASS