diff --git a/Cargo.lock b/Cargo.lock index c96bfdf..7e415e3 100644 --- a/Cargo.lock +++ b/Cargo.lock @@ -247,7 +247,6 @@ dependencies = [ "futures-rustls", "glommio", "hashbrown 0.11.2", - "histogram", "indexmap", "log", "mimalloc", diff --git a/aquatic_ws/Cargo.toml b/aquatic_ws/Cargo.toml index 953bbd6..af69a0a 100644 --- a/aquatic_ws/Cargo.toml +++ b/aquatic_ws/Cargo.toml @@ -28,7 +28,6 @@ futures = "0.3" futures-rustls = "0.22" glommio = { git = "https://github.com/DataDog/glommio.git", rev = "4e6b14772da2f4325271fbcf12d24cf91ed466e5" } hashbrown = { version = "0.11.2", features = ["serde"] } -histogram = "0.6" indexmap = "1" log = "0.4" mimalloc = { version = "0.1", default-features = false } diff --git a/aquatic_ws/src/lib/tasks.rs b/aquatic_ws/src/lib/tasks.rs index f96426c..59ad0f4 100644 --- a/aquatic_ws/src/lib/tasks.rs +++ b/aquatic_ws/src/lib/tasks.rs @@ -14,39 +14,3 @@ pub fn update_access_list(config: &Config, state: &State) { AccessListMode::Off => {} } } - -pub fn print_statistics(state: &State) { - let mut peers_per_torrent = Histogram::new(); - - { - let torrents = &mut state.torrent_maps.lock(); - - for torrent in torrents.ipv4.values() { - let num_peers = (torrent.num_seeders + torrent.num_leechers) as u64; - - if let Err(err) = peers_per_torrent.increment(num_peers) { - eprintln!("error incrementing peers_per_torrent histogram: {}", err) - } - } - for torrent in torrents.ipv6.values() { - let num_peers = (torrent.num_seeders + torrent.num_leechers) as u64; - - if let Err(err) = peers_per_torrent.increment(num_peers) { - eprintln!("error incrementing peers_per_torrent histogram: {}", err) - } - } - } - - if peers_per_torrent.entries() != 0 { - println!( - "peers per torrent: min: {}, p50: {}, p75: {}, p90: {}, p99: {}, p999: {}, max: {}", - peers_per_torrent.minimum().unwrap(), - peers_per_torrent.percentile(50.0).unwrap(), - peers_per_torrent.percentile(75.0).unwrap(), - peers_per_torrent.percentile(90.0).unwrap(), - peers_per_torrent.percentile(99.0).unwrap(), - peers_per_torrent.percentile(99.9).unwrap(), - peers_per_torrent.maximum().unwrap(), - ); - } -}