From efd81d30ac3473a142968df7e4ba46bb4d44ecc9 Mon Sep 17 00:00:00 2001
From: Erin Power <erin.power@embark-studios.com>
Date: Mon, 7 Oct 2024 16:28:03 +0200
Subject: [PATCH] review feedback

---
 src/components/proxy/io_uring_shared.rs | 11 +----------
 1 file changed, 1 insertion(+), 10 deletions(-)

diff --git a/src/components/proxy/io_uring_shared.rs b/src/components/proxy/io_uring_shared.rs
index 934d53eca..b9b28eb44 100644
--- a/src/components/proxy/io_uring_shared.rs
+++ b/src/components/proxy/io_uring_shared.rs
@@ -370,8 +370,6 @@ enum Token {
     Recv { key: usize },
     /// Packet sent
     Send { key: usize },
-    /// Recv packet processed
-    RecvPacketProcessed,
     /// One or more packets are ready to be sent
     PendingsSends,
     /// Loop shutdown requested
@@ -549,7 +547,7 @@ impl IoUringLoop {
         // Used to notify the uring when a received packet has finished
         // processing and we can perform another recv, as we (currently) only
         // ever process a single packet at a time
-        let mut process_event = EventFd::new()?;
+        let process_event = EventFd::new()?;
         // Used to notify the uring loop to shutdown
         let mut shutdown_event = EventFd::new()?;
 
@@ -655,13 +653,6 @@ impl IoUringLoop {
                                     &mut last_received_at,
                                 );
 
-                                // Queue the wait for the processing of the packet to finish
-                                loop_ctx.push_with_token(
-                                    process_event.io_uring_entry(),
-                                    Token::RecvPacketProcessed,
-                                );
-                            }
-                            Token::RecvPacketProcessed => {
                                 loop_ctx.enqueue_recv(buffer_pool.clone().alloc());
                             }
                             Token::PendingsSends => {