From 22c2cad83e0724e073ffd53d8578ccc056686697 Mon Sep 17 00:00:00 2001 From: rootdarkarchon Date: Fri, 19 Jan 2024 11:39:39 +0100 Subject: [PATCH] try locking metrics --- .../Metrics/MareMetrics.cs | 18 ++++++++++++------ 1 file changed, 12 insertions(+), 6 deletions(-) diff --git a/MareSynchronosServer/MareSynchronosShared/Metrics/MareMetrics.cs b/MareSynchronosServer/MareSynchronosShared/Metrics/MareMetrics.cs index 630c79d..d2d3e22 100644 --- a/MareSynchronosServer/MareSynchronosShared/Metrics/MareMetrics.cs +++ b/MareSynchronosServer/MareSynchronosShared/Metrics/MareMetrics.cs @@ -32,7 +32,8 @@ public class MareMetrics { if (_gauges.TryGetValue(gaugeName, out Gauge gauge)) { - gauge.WithLabels(labels).Inc(value); + lock (gauge) + gauge.WithLabels(labels).Inc(value); } } @@ -40,7 +41,8 @@ public class MareMetrics { if (_gauges.TryGetValue(gaugeName, out Gauge gauge)) { - gauge.WithLabels(labels).Dec(value); + lock (gauge) + gauge.WithLabels(labels).Dec(value); } } @@ -48,7 +50,8 @@ public class MareMetrics { if (_gauges.TryGetValue(gaugeName, out Gauge gauge)) { - gauge.Set(value); + lock (gauge) + gauge.Set(value); } } @@ -56,7 +59,8 @@ public class MareMetrics { if (_gauges.TryGetValue(gaugeName, out Gauge gauge)) { - gauge.Inc(value); + lock (gauge) + gauge.Inc(value); } } @@ -64,7 +68,8 @@ public class MareMetrics { if (_gauges.TryGetValue(gaugeName, out Gauge gauge)) { - gauge.Dec(value); + lock (gauge) + gauge.Dec(value); } } @@ -72,7 +77,8 @@ public class MareMetrics { if (_counters.TryGetValue(counterName, out Counter counter)) { - counter.Inc(value); + lock (counter) + counter.Inc(value); } } } \ No newline at end of file