Call `PeerManager::timer_tick_occurred` regularly to ping peers

[rapid-gossip-sync-server] / src / tracking.rs

diff --git a/src/tracking.rs b/src/tracking.rs
index 0f34924ed9458f5618014bf785c7fb382789dae0..ebe04134a91d43e42d284459404a83a5898008d6 100644 (file)
--- a/src/tracking.rs
+++ b/src/tracking.rs
@@ -50,6 +50,15 @@ pub(crate) async fn download_gossip(persistence_sender: mpsc::Sender<GossipMessa
        ));
        router.set_pm(Arc::clone(&peer_handler));
 
+       let ph_timer = Arc::clone(&peer_handler);
+       tokio::spawn(async move {
+               let mut intvl = tokio::time::interval(Duration::from_secs(10));
+               loop {
+                       intvl.tick().await;
+                       ph_timer.timer_tick_occurred();
+               }
+       });
+
        println!("Connecting to Lightning peers...");
        let peers = config::ln_peers();
        let mut connected_peer_count = 0;