From db3c4e997f03a660ac37a6bdf86c6215726a71bd Mon Sep 17 00:00:00 2001 From: tv Date: Wed, 28 Oct 2026 01:47:47 +0100 Subject: rename PING/PONG to STATUS/STATUS_REPLY --- src/swarm/peer/worker.rs | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) (limited to 'src/swarm/peer/worker.rs') diff --git a/src/swarm/peer/worker.rs b/src/swarm/peer/worker.rs index 057e4bd..c68e2ea 100644 --- a/src/swarm/peer/worker.rs +++ b/src/swarm/peer/worker.rs @@ -10,7 +10,7 @@ use tracing::{debug, info, warn}; use super::forget::{AppliedForgets, apply_forget_records, forget_strangers}; use super::handshake::retry_hello_if_due; -use super::keepalive::send_ping; +use super::keepalive::send_status; use crate::locks::MutexExt; use crate::state::AppState; use crate::swarm::sync::SyncEvent; @@ -83,9 +83,9 @@ pub(crate) async fn run_peer_worker(state: AppState) { let probe_due = !ping_due && crate::swarm::source::probe_due(&state, peer, Instant::now()); if (ping_due || probe_due) - && let Err(error) = send_ping(&state, peer).await + && let Err(error) = send_status(&state, peer).await { - debug!(peer = %peer, error = %format!("{error:#}"), "Keepalive PING failed"); + debug!(peer = %peer, error = %format!("{error:#}"), "Keepalive STATUS failed"); } if let Err(error) = retry_hello_if_due(&state, peer).await { -- cgit v1.3.1