From fde8a76ec5d8e697d9b13470cd15ed324bae3d00 Mon Sep 17 00:00:00 2001 From: tv Date: Tue, 27 Oct 2026 00:36:40 +0100 Subject: talk about "transport" unless mycelium is meant --- src/swarm/sync.rs | 10 +++++++--- 1 file changed, 7 insertions(+), 3 deletions(-) (limited to 'src/swarm/sync.rs') diff --git a/src/swarm/sync.rs b/src/swarm/sync.rs index 4e382ec..011f049 100644 --- a/src/swarm/sync.rs +++ b/src/swarm/sync.rs @@ -162,7 +162,8 @@ async fn deliver_sync_to_peer(state: &AppState, peer: &str) -> Result<()> { return transport::SyncBody::Message(payload); } // Too large for one message: all or nothing, and on a slow link - // within Mycelium's deadline. The peer fetches it in chunks. + // within the transport's delivery limit. The peer fetches it in + // chunks. let from = peer_state.sync.withdraw_for_delta(); let spec = transport::DeltaSpec::new(from, replica.heads().to_vec()); info!( @@ -213,7 +214,7 @@ async fn deliver_sync_to_peer(state: &AppState, peer: &str) -> Result<()> { (session, encoded) }; - // Off the sync worker: a slow send (a large message, a busy Mycelium) mustn't hold + // Off the sync worker: a slow send (a large message, a busy transport) mustn't hold // up every other peer's. One message per peer is in flight (`sending`), so a peer's // messages still go out in order. let state = state.clone(); @@ -240,7 +241,10 @@ async fn send_generated( Ok(()) => { let regenerate = peer_state_mutex.lock().await.sync.send_succeeded(session); - trace!(regenerate, "Outbound sync message accepted by Mycelium"); + trace!( + regenerate, + "Outbound sync message accepted by the transport" + ); if regenerate { state -- cgit v1.3.1