perf: Queue up CPU * 32 recvs

googleforgames · Oct 22, 2024 · a0c350a · a0c350a
1 parent a4f9db1
commit a0c350a
Showing 1 changed file with 6 additions and 1 deletion.
diff --git a/src/components/proxy/io_uring_shared.rs b/src/components/proxy/io_uring_shared.rs
@@ -592,7 +592,12 @@ impl IoUringLoop {
                     tokens,
                 };
 
-                loop_ctx.enqueue_recv(buffer_pool.clone().alloc());
+                // Queue a number of recv's to hopefully reduce the number of
+                // syscalls between data.
+                for _ in 0..(num_cpus::get() * 32) {
+                    loop_ctx.enqueue_recv(buffer_pool.clone().alloc());
+                }
+
                 loop_ctx
                     .push_with_token(pending_sends_event.io_uring_entry(), Token::PendingsSends);
                 loop_ctx.push_with_token(shutdown_event.io_uring_entry(), Token::Shutdown);