aboutsummaryrefslogtreecommitdiffstats
path: root/src
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
parent4e31f6aefec4d792985fb79c0e369564ae87c531 (diff)
no epoch tag measure
Diffstat (limited to 'src')
-rw-r--r--src/simtest/bench.rs4
-rw-r--r--src/swarm/stats.rs11
-rw-r--r--src/swarm/sync.rs4
3 files changed, 6 insertions, 13 deletions
diff --git a/src/simtest/bench.rs b/src/simtest/bench.rs
index aec54dc..dd7d892 100644
--- a/src/simtest/bench.rs
+++ b/src/simtest/bench.rs
@@ -334,7 +334,6 @@ impl Totals {
relay.delivered_bytes += stats.relay.delivered_bytes;
relay.framed += stats.relay.framed;
relay.framing_bytes += stats.relay.framing_bytes;
- relay.framing_id_bytes += stats.relay.framing_id_bytes;
relay.deflated += stats.relay.deflated;
relay.deflated_from += stats.relay.deflated_from;
relay.deflated_to += stats.relay.deflated_to;
@@ -772,9 +771,8 @@ fn report(
let framed = r1.framed - r0.framed;
let _ = writeln!(
out,
- " sync envelopes: {:.0} bytes each beside the Automerge message, {:.0} of them the epoch",
+ " sync envelopes: {:.0} bytes each beside the Automerge message",
each(r1.framing_bytes - r0.framing_bytes, framed),
- each(r1.framing_id_bytes - r0.framing_id_bytes, framed),
);
let deflated = r1.deflated - r0.deflated;
let _ = writeln!(
diff --git a/src/swarm/stats.rs b/src/swarm/stats.rs
index ba75d68..8ab27e8 100644
--- a/src/swarm/stats.rs
+++ b/src/swarm/stats.rs
@@ -128,11 +128,10 @@ pub(crate) struct Relay {
/// payload's bytes.
pub(crate) delivered: u64,
pub(crate) delivered_bytes: u64,
- /// Sync messages sent (not offers), the bytes the envelope added to their
- /// Automerge messages, and of those the epoch's.
+ /// Sync messages sent (not offers), and the bytes the envelope added to their
+ /// Automerge messages.
pub(crate) framed: u64,
pub(crate) framing_bytes: u64,
- pub(crate) framing_id_bytes: u64,
/// Sync messages deflated (`compress`), their bytes before and after.
pub(crate) deflated: u64,
pub(crate) deflated_from: u64,
@@ -284,13 +283,11 @@ impl NodeStats {
inner.relay.deflated_to += to as u64;
}
- /// A sync message went out whose envelope added `bytes` to its Automerge message,
- /// `ids` of them the epoch.
- pub(crate) fn sync_framing(&self, bytes: usize, ids: usize) {
+ /// A sync message went out whose envelope added `bytes` to its Automerge message.
+ pub(crate) fn sync_framing(&self, bytes: usize) {
let mut inner = self.lock();
inner.relay.framed += 1;
inner.relay.framing_bytes += bytes as u64;
- inner.relay.framing_id_bytes += ids as u64;
}
/// A sync message taken as delivered went out, of `bytes` payload.
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)
},