From 430038ee6c2fd1cc3925d6bf16e4cf36997095b7 Mon Sep 17 00:00:00 2001 From: Simon Paitrault Date: Tue, 27 Jun 2023 12:48:07 +0200 Subject: [PATCH] chore: adding env var for gossip tick Signed-off-by: Simon Paitrault --- crates/topos-p2p/src/behaviour/gossip.rs | 11 ++++++++++- 1 file changed, 10 insertions(+), 1 deletion(-) diff --git a/crates/topos-p2p/src/behaviour/gossip.rs b/crates/topos-p2p/src/behaviour/gossip.rs index bc5d78caa..a08e205d8 100644 --- a/crates/topos-p2p/src/behaviour/gossip.rs +++ b/crates/topos-p2p/src/behaviour/gossip.rs @@ -73,7 +73,12 @@ impl Behaviour { gossipsub, echo_queue: VecDeque::new(), ready_queue: VecDeque::new(), - tick: tokio::time::interval(Duration::from_millis(100)), + tick: tokio::time::interval(Duration::from_millis( + env::var("TOPOS_GOSSIP_INTERVAL") + .map(|v| v.parse::()) + .unwrap_or(Ok(100)) + .unwrap(), + )), } } } @@ -139,6 +144,8 @@ impl NetworkBehaviour for Behaviour { for _ in 0..self.batch_size { if let Some(data) = self.echo_queue.pop_front() { echos.data.push(data); + } else { + break; } } @@ -152,6 +159,8 @@ impl NetworkBehaviour for Behaviour { for _ in 0..self.batch_size { if let Some(data) = self.ready_queue.pop_front() { readies.data.push(data); + } else { + break; } }