YGGverse/aquatic
1
0
Fork 0
mirror of https://github.com/YGGverse/aquatic.git synced 2026-04-02 18:55:32 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions

udp: uring: set send_buffer_entries to ring_entries, improve comments

Browse source
This commit is contained in:
Joakim Frostegård 2023-03-09 22:15:19 +01:00
parent 587dd07131
commit 0f333d4755
1 changed files with 3 additions and 3 deletions
Download patch file Download diff file Expand all files Collapse all files

6
aquatic_udp/src/workers/socket/uring/mod.rs
View file

@ -94,8 +94,8 @@ impl SocketWorker {
priv_dropper: PrivilegeDropper, priv_dropper: PrivilegeDropper,
) { ) {
let ring_entries = config.network.ring_entries.next_power_of_two(); let ring_entries = config.network.ring_entries.next_power_of_two();
// Bias ring towards sending to prevent build-up of unsent responses // Try to fill up the ring with send requests
let send_buffer_entries = ring_entries - (ring_entries / 4); let send_buffer_entries = ring_entries;
let socket = create_socket(&config, priv_dropper).expect("create socket"); let socket = create_socket(&config, priv_dropper).expect("create socket");
let access_list_cache = create_access_list_cache(&shared_state.access_list); let access_list_cache = create_access_list_cache(&shared_state.access_list);
@ -346,7 +346,7 @@ impl SocketWorker {
if result < 0 { if result < 0 {
if -result == libc::ENOBUFS { if -result == libc::ENOBUFS {
::log::warn!("recv failed due to lack of buffers, try increasing ring size"); ::log::info!("recv failed due to lack of buffers. If increasing ring size doesn't help, get faster hardware");
} else { } else {
::log::warn!( ::log::warn!(
"recv failed: {:#}", "recv failed: {:#}",