YGGverse/aquatic
1
0
Fork 0
mirror of https://github.com/YGGverse/aquatic.git synced 2026-03-31 17:55:36 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions

aquatic: print num requests per readable poll event

Browse source
This commit is contained in:
Joakim Frostegård 2020-04-07 15:31:17 +02:00
parent 3ca22c9f3f
commit 3b52acbd20
3 changed files with 21 additions and 6 deletions
Download patch file Download diff file Expand all files Collapse all files

1
aquatic/src/lib/common.rs
View file

@ -120,6 +120,7 @@ pub type TorrentMap = DashMap<InfoHash, TorrentData>;
pub struct Statistics {
pub requests_received: AtomicUsize,
pub responses_sent: AtomicUsize,
pub readable_events: AtomicUsize,
}

24
aquatic/src/lib/lib.rs
View file

@ -33,15 +33,27 @@ pub fn run(){
loop {
::std::thread::sleep(Duration::from_secs(interval));
let requests_per_second: f64 = state.statistics.requests_received
.fetch_and(0, Ordering::SeqCst) as f64 / interval as f64;
let responses_per_second: f64 = state.statistics.responses_sent
.fetch_and(0, Ordering::SeqCst) as f64 / interval as f64;
let requests_received: f64 = state.statistics.requests_received
.fetch_and(0, Ordering::SeqCst) as f64;
let responses_sent: f64 = state.statistics.responses_sent
.fetch_and(0, Ordering::SeqCst) as f64;
let requests_per_second = requests_received / interval as f64;
let responses_per_second: f64 = responses_sent / interval as f64;
let readable_events: f64 = state.statistics.readable_events
.fetch_and(0, Ordering::SeqCst) as f64;
let requests_per_readable_event = if readable_events == 0.0 {
0.0
} else {
requests_received / readable_events
};
println!(
"stats: {} requests/second, {} responses/second",
"stats: {:.2} requests/second, {:.2} responses/second, {:.2} requests/readable event",
requests_per_second,
responses_per_second
responses_per_second,
requests_per_readable_event
);
}
});

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

@ -58,6 +58,8 @@ pub fn run_event_loop(
&mut scrape_requests
);
state.statistics.readable_events.fetch_add(1, Ordering::SeqCst);
poll.registry()
.reregister(&mut socket, token, interests)
.unwrap();