diff --git a/aquatic/src/lib/config.rs b/aquatic/src/lib/config.rs index a3152f5..3f29205 100644 --- a/aquatic/src/lib/config.rs +++ b/aquatic/src/lib/config.rs @@ -26,7 +26,7 @@ pub struct NetworkConfig { /// Ask peers to announce this often (seconds) pub peer_announce_interval: i32, /// Setting on socket. When value is zero, don't set (use OS default) - pub recv_buffer_size: usize, + pub socket_recv_buffer_size: usize, pub poll_event_capacity: usize, } @@ -78,7 +78,7 @@ impl Default for NetworkConfig { max_response_peers: 255, peer_announce_interval: 60 * 15, poll_event_capacity: 4096, - recv_buffer_size: 4096 * 128, + socket_recv_buffer_size: 4096 * 128, } } } diff --git a/aquatic/src/lib/network.rs b/aquatic/src/lib/network.rs index 24c428a..f771f3e 100644 --- a/aquatic/src/lib/network.rs +++ b/aquatic/src/lib/network.rs @@ -93,11 +93,13 @@ fn create_socket(config: &Config) -> ::std::net::UdpSocket { socket.set_nonblocking(true) .expect("socket: set nonblocking"); - if config.network.recv_buffer_size != 0 { - if let Err(err) = socket.set_recv_buffer_size(config.network.recv_buffer_size){ + let recv_buffer_size = config.network.socket_recv_buffer_size; + + if recv_buffer_size != 0 { + if let Err(err) = socket.set_recv_buffer_size(recv_buffer_size){ eprintln!( "socket: failed setting recv buffer to {}: {:?}", - config.network.recv_buffer_size, + recv_buffer_size, err ); }