diff options
| author | tv <tv@krebsco.de> | 2026-11-05 16:11:43 +0100 |
|---|---|---|
| committer | tv <tv@krebsco.de> | 2026-11-05 16:11:43 +0100 |
| commit | 1a20d28c7131a1b768079018f03dfb7bd1ffbc6e (patch) | |
| tree | 7ac5fdcdd7e6cf9908cd6bdac9377acac45c9a25 /src/swarm/sync.rs | |
| parent | 4e31f6aefec4d792985fb79c0e369564ae87c531 (diff) | |
no epoch tag measure
Diffstat (limited to 'src/swarm/sync.rs')
| -rw-r--r-- | src/swarm/sync.rs | 4 |
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) }, |
