replace hard-coded queue ID with queried queue ID

aya-rs · Nov 13, 2024 · 0ca10c8 · 0ca10c8
1 parent dca68ae
commit 0ca10c8
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/test/integration-ebpf/src/redirect.rs b/test/integration-ebpf/src/redirect.rs
@@ -31,7 +31,7 @@ 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