pezkuwichain/pezkuwi-telemetry
1
0
Fork 0
mirror of https://github.com/pezkuwichain/pezkuwi-telemetry.git synced 2026-06-12 15:51:00 +00:00
Code Issues Packages Projects Releases Wiki Activity

monitoring queue len

Browse Source
This commit is contained in:
James Wilson
2021-08-09 16:38:23 +01:00
parent 87c0ee7d0d
commit b97aec99a8
1 changed files with 4 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files
backend/telemetry_core/src/aggregator/inner_loop.rs
+4 -2
View File
@@ -197,9 +197,11 @@ impl InnerLoop {
// TEMP: let's monitor message queue len out of interest
let tx_len = metered_tx.clone();
tokio::spawn(async move {
let mut n = 0;
loop {
println!("Queue len: {}", tx_len.len());
tokio::time::sleep(tokio::time::Duration::from_secs(1)).await
println!("#{} Queue len: {}", n, tx_len.len());
n += 1;
tokio::time::sleep(tokio::time::Duration::from_millis(500)).await;
}
});