Skip to content

Commit

Permalink
review feedback
Browse files Browse the repository at this point in the history
  • Loading branch information
XAMPPRocky committed Oct 8, 2024
1 parent e7f265d commit 5e1e5e7
Showing 1 changed file with 1 addition and 10 deletions.
11 changes: 1 addition & 10 deletions src/components/proxy/io_uring_shared.rs
Original file line number Diff line number Diff line change
Expand Up @@ -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
Expand Down Expand Up @@ -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()?;

Expand Down Expand Up @@ -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 => {
Expand Down

0 comments on commit 5e1e5e7

Please sign in to comment.