aboutsummaryrefslogtreecommitdiffstats
path: root/src/transport/traffic.rs
diff options
context:
space:
mode:
Diffstat (limited to 'src/transport/traffic.rs')
-rw-r--r--src/transport/traffic.rs6
1 files changed, 6 insertions, 0 deletions
diff --git a/src/transport/traffic.rs b/src/transport/traffic.rs
index 180d3b5..e810595 100644
--- a/src/transport/traffic.rs
+++ b/src/transport/traffic.rs
@@ -59,6 +59,8 @@ pub(crate) struct ByKind {
pub(crate) hyparview: Counter,
/// SIGNATURES (`swarm::signatures`).
pub(crate) signatures: Counter,
+ /// REFUSALS (`swarm::refusals`).
+ pub(crate) refusals: Counter,
}
impl ByKind {
@@ -76,6 +78,7 @@ impl ByKind {
MessageKind::Prune,
MessageKind::Neighbour,
MessageKind::Signatures,
+ MessageKind::Refusals,
] {
let theirs = *other.get(kind);
self.get_mut(kind).absorb(theirs);
@@ -98,6 +101,7 @@ impl ByKind {
&self.hyparview
}
MessageKind::Signatures => &self.signatures,
+ MessageKind::Refusals => &self.refusals,
}
}
@@ -117,6 +121,7 @@ impl ByKind {
&mut self.hyparview
}
MessageKind::Signatures => &mut self.signatures,
+ MessageKind::Refusals => &mut self.refusals,
}
}
}
@@ -327,6 +332,7 @@ fn names(kind: MessageKind) -> (&'static str, &'static str) {
MessageKind::NeighbourReply => ("NEIGHBOUR_REPLY", "hyparview"),
MessageKind::Disconnect => ("DISCONNECT", "hyparview"),
MessageKind::Signatures => ("SIGNATURES", "signatures"),
+ MessageKind::Refusals => ("REFUSALS", "refusals"),
}
}