From 63c705fd17d40baaaa41854cd947cfce4cadc01b Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?Joakim=20Frosteg=C3=A5rd?= Date: Thu, 9 Mar 2023 22:15:57 +0100 Subject: [PATCH] udp: config: rename ring_entries to ring_size --- aquatic_udp/src/config.rs | 4 ++-- aquatic_udp/src/workers/socket/uring/mod.rs | 2 +- 2 files changed, 3 insertions(+), 3 deletions(-) diff --git a/aquatic_udp/src/config.rs b/aquatic_udp/src/config.rs index c5da489..03763e1 100644 --- a/aquatic_udp/src/config.rs +++ b/aquatic_udp/src/config.rs @@ -93,7 +93,7 @@ pub struct NetworkConfig { /// /// Will be rounded to next power of two if not already one #[cfg(feature = "io-uring")] - pub ring_entries: u16, + pub ring_size: u16, /// Store this many responses at most for retrying (once) on send failure /// /// Useful on operating systems that do not provide an udp send buffer, @@ -120,7 +120,7 @@ impl Default for NetworkConfig { poll_event_capacity: 4096, poll_timeout_ms: 50, #[cfg(feature = "io-uring")] - ring_entries: 1024, + ring_size: 1024, resend_buffer_max_len: 0, } } diff --git a/aquatic_udp/src/workers/socket/uring/mod.rs b/aquatic_udp/src/workers/socket/uring/mod.rs index 56bc36d..0c213de 100644 --- a/aquatic_udp/src/workers/socket/uring/mod.rs +++ b/aquatic_udp/src/workers/socket/uring/mod.rs @@ -93,7 +93,7 @@ impl SocketWorker { response_receiver: Receiver<(ConnectedResponse, CanonicalSocketAddr)>, priv_dropper: PrivilegeDropper, ) { - let ring_entries = config.network.ring_entries.next_power_of_two(); + let ring_entries = config.network.ring_size.next_power_of_two(); // Try to fill up the ring with send requests let send_buffer_entries = ring_entries;