From 7e0db52948c4f7470cf5dcab1dd6a183743d247f Mon Sep 17 00:00:00 2001 From: Simon Paitrault Date: Sat, 2 Mar 2024 17:53:30 +0100 Subject: [PATCH] chore: adding republish_count Signed-off-by: Simon Paitrault --- crates/topos-tce-broadcast/src/task_manager/task.rs | 3 +++ 1 file changed, 3 insertions(+) diff --git a/crates/topos-tce-broadcast/src/task_manager/task.rs b/crates/topos-tce-broadcast/src/task_manager/task.rs index b8a505d74..9113986e7 100644 --- a/crates/topos-tce-broadcast/src/task_manager/task.rs +++ b/crates/topos-tce-broadcast/src/task_manager/task.rs @@ -97,6 +97,9 @@ impl IntoFuture for Task { let mut gossip_timer = tokio::time::interval(Duration::from_secs(5)); gossip_timer.set_missed_tick_behavior(tokio::time::MissedTickBehavior::Skip); + // First tick is instant + gossip_timer.tick().await; + loop { tokio::select! { _tick = gossip_timer.tick(), if !self.broadcast_state.received_echo() => {