Skip to content

Commit 7060fa6

Browse files
authored
fixed sphinx version metrics registration (#5546)
1 parent 9be9c04 commit 7060fa6

File tree

3 files changed

+10
-3
lines changed

3 files changed

+10
-3
lines changed

contracts/Cargo.lock

+1-1
Some generated files are not rendered by default. Learn more about customizing how changed files appear on GitHub.

nym-node/nym-node-metrics/src/mixnet.rs

+2-1
Original file line numberDiff line numberDiff line change
@@ -63,6 +63,7 @@ impl MixingStats {
6363
.or_default()
6464
.forward_packets
6565
.received += 1;
66+
6667
*self.ingress.received_versions.entry(version).or_default() += 1;
6768
}
6869

@@ -213,7 +214,7 @@ impl Display for PacketKind {
213214
PacketKind::Unknown => "unknown".fmt(f),
214215
PacketKind::Outfox => "outfox".fmt(f),
215216
PacketKind::Sphinx(sphinx_version) => {
216-
write!(f, "sphinx-{sphinx_version}")
217+
write!(f, "sphinx_{sphinx_version}")
217218
}
218219
}
219220
}

nym-node/nym-node-metrics/src/prometheus_wrapper.rs

+7-1
Original file line numberDiff line numberDiff line change
@@ -291,7 +291,13 @@ impl PrometheusMetric {
291291
}
292292

293293
fn set(&self, value: i64) {
294-
metrics_registry().set(&self.name(), value);
294+
let reg = metrics_registry();
295+
if !reg.set(&self.name(), value) {
296+
if let Some(registrable) = self.to_registrable_metric() {
297+
reg.register_metric(registrable);
298+
reg.set(&self.name(), value);
299+
}
300+
}
295301
}
296302

297303
fn set_float(&self, value: f64) {

0 commit comments

Comments
 (0)