lx/netapp
1
1
Fork 5
Code Issues 2 Pull requests 1 Releases 1 Wiki Activity

netapp.rs: Set SO_REUSEPORT on listen_addr with TcpSocket. #9

Closed
jpds wants to merge 11 commits from jpds/netapp:so-reuseport into main
pull from: jpds/netapp:so-reuseport
merge into: lx:main
Conversation 3 Commits 11 Files changed 7 +4 -2
2 changed files with 4 additions and 2 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files
Showing only changes of commit 14ba9a811f - Show all commits

3
examples/basalt.rs
View file

@ -1,4 +1,5 @@
use std::io::Write; use std::io::Write;
use std::num::NonZeroUsize;
use std::sync::Arc; use std::sync::Arc;
use std::time::Duration; use std::time::Duration;
@ -41,7 +42,7 @@ pub struct Opt {
view_size: usize, view_size: usize,
#[structopt(long = "cache-size", short = "c", default_value = "1000")] #[structopt(long = "cache-size", short = "c", default_value = "1000")]
cache_size: usize, cache_size: NonZeroUsize,
#[structopt(long = "exchange-interval-secs", short = "x", default_value = "1")] #[structopt(long = "exchange-interval-secs", short = "x", default_value = "1")]
exchange_interval: u64, exchange_interval: u64,

3
src/peering/basalt.rs
View file

@ -1,5 +1,6 @@
use std::collections::HashSet; use std::collections::HashSet;
use std::net::SocketAddr; use std::net::SocketAddr;
use std::num::NonZeroUsize;
use std::sync::{Arc, RwLock}; use std::sync::{Arc, RwLock};
use std::time::Duration; use std::time::Duration;
@ -229,7 +230,7 @@ impl BasaltView {
pub struct BasaltParams { pub struct BasaltParams {
pub view_size: usize, pub view_size: usize,
pub cache_size: usize, pub cache_size: NonZeroUsize,
pub exchange_interval: Duration, pub exchange_interval: Duration,
pub reset_interval: Duration, pub reset_interval: Duration,
pub reset_count: usize, pub reset_count: usize,