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

aquatic: config: rename recv_buffer_size to socket_recv_buffer_size

Browse source
This commit is contained in:
Joakim Frostegård 2020-04-12 13:29:21 +02:00
parent 5430e561f5
commit ad7a8c46a9
2 changed files with 7 additions and 5 deletions
Download patch file Download diff file Expand all files Collapse all files

4
aquatic/src/lib/config.rs
View file

@ -26,7 +26,7 @@ pub struct NetworkConfig {
/// Ask peers to announce this often (seconds) /// Ask peers to announce this often (seconds)
pub peer_announce_interval: i32, pub peer_announce_interval: i32,
/// Setting on socket. When value is zero, don't set (use OS default) /// 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, pub poll_event_capacity: usize,
} }
@ -78,7 +78,7 @@ impl Default for NetworkConfig {
max_response_peers: 255, max_response_peers: 255,
peer_announce_interval: 60 * 15, peer_announce_interval: 60 * 15,
poll_event_capacity: 4096, poll_event_capacity: 4096,
recv_buffer_size: 4096 * 128, socket_recv_buffer_size: 4096 * 128,
} }
} }
} }

8
aquatic/src/lib/network.rs
View file

@ -93,11 +93,13 @@ fn create_socket(config: &Config) -> ::std::net::UdpSocket {
socket.set_nonblocking(true) socket.set_nonblocking(true)
.expect("socket: set nonblocking"); .expect("socket: set nonblocking");
if config.network.recv_buffer_size != 0 { let recv_buffer_size = config.network.socket_recv_buffer_size;
if let Err(err) = socket.set_recv_buffer_size(config.network.recv_buffer_size){
if recv_buffer_size != 0 {
if let Err(err) = socket.set_recv_buffer_size(recv_buffer_size){
eprintln!( eprintln!(
"socket: failed setting recv buffer to {}: {:?}", "socket: failed setting recv buffer to {}: {:?}",
config.network.recv_buffer_size, recv_buffer_size,
err err
); );
} }