projects
/
rapid-gossip-sync-server
/ commitdiff
commit
grep
author
committer
pickaxe
?
search:
re
summary
|
shortlog
|
log
|
commit
| commitdiff |
tree
raw
|
patch
|
inline
| side by side (parent:
b1d0152
)
Call `PeerManager::timer_tick_occurred` regularly to ping peers
author
Matt Corallo
<git@bluematt.me>
Wed, 8 Feb 2023 16:59:09 +0000
(16:59 +0000)
committer
Matt Corallo
<git@bluematt.me>
Wed, 15 Mar 2023 17:52:43 +0000
(17:52 +0000)
src/tracking.rs
patch
|
blob
|
history
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));
));
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;
println!("Connecting to Lightning peers...");
let peers = config::ln_peers();
let mut connected_peer_count = 0;