summaryrefslogtreecommitdiffstats
path: root/src/swarm/sync.rs
diff options
context:
space:
mode:
authortv <tv@krebsco.de>2026-10-27 00:36:40 +0100
committertv <tv@krebsco.de>2026-10-27 00:36:40 +0100
commitfde8a76ec5d8e697d9b13470cd15ed324bae3d00 (patch)
tree6045b4c9fcd5ca2da221668f23e115c88c8e3d97 /src/swarm/sync.rs
parent7af8f58d46737bb5835aa1625485f22ecf374ebe (diff)
talk about "transport" unless mycelium is meant
Diffstat (limited to 'src/swarm/sync.rs')
-rw-r--r--src/swarm/sync.rs10
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