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;