diff options
| author | tv <tv@krebsco.de> | 2026-10-27 00:36:40 +0100 |
|---|---|---|
| committer | tv <tv@krebsco.de> | 2026-10-27 00:36:40 +0100 |
| commit | fde8a76ec5d8e697d9b13470cd15ed324bae3d00 (patch) | |
| tree | 6045b4c9fcd5ca2da221668f23e115c88c8e3d97 /src/swarm/sync.rs | |
| parent | 7af8f58d46737bb5835aa1625485f22ecf374ebe (diff) | |
talk about "transport" unless mycelium is meant
Diffstat (limited to 'src/swarm/sync.rs')
| -rw-r--r-- | src/swarm/sync.rs | 10 |
1 files changed, 7 insertions, 3 deletions
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 |
