aboutsummaryrefslogtreecommitdiffstats
path: root/src/swarm/sync.rs
diff options
context:
space:
mode:
authortv <tv@krebsco.de>2026-11-05 16:11:43 +0100
committertv <tv@krebsco.de>2026-11-05 16:11:43 +0100
commit1a20d28c7131a1b768079018f03dfb7bd1ffbc6e (patch)
tree7ac5fdcdd7e6cf9908cd6bdac9377acac45c9a25 /src/swarm/sync.rs
parent4e31f6aefec4d792985fb79c0e369564ae87c531 (diff)
no epoch tag measure
Diffstat (limited to 'src/swarm/sync.rs')
-rw-r--r--src/swarm/sync.rs4
1 files changed, 1 insertions, 3 deletions
diff --git a/src/swarm/sync.rs b/src/swarm/sync.rs
index 5511ea2..5ee36a2 100644
--- a/src/swarm/sync.rs
+++ b/src/swarm/sync.rs
@@ -296,8 +296,6 @@ async fn deliver_sync_to_peer(state: &AppState, peer: &str) -> Result<()> {
}
transport::SyncBody::Delta(_) => None,
};
- let ids = rmp_serde::encode::to_vec(&transport::EpochTag::of(epoch))
- .map_or(0, |tag| tag.len());
let envelope = transport::SyncEnvelope {
epoch: transport::EpochTag::of(epoch),
epoch_seq,
@@ -311,7 +309,7 @@ async fn deliver_sync_to_peer(state: &AppState, peer: &str) -> Result<()> {
.encode(&peer_owned, &ParsedMessage::Sync(envelope))
.map(Some);
if let (Ok(Some(encoded)), Some(inner)) = (&encoded, inner) {
- stats.sync_framing(encoded.payload_len.saturating_sub(inner), ids);
+ stats.sync_framing(encoded.payload_len.saturating_sub(inner));
}
(session, encoded)
},