From 3ff75db0f2526b0da33b7b9521d7afe71767eb41 Mon Sep 17 00:00:00 2001 From: rootdarkarchon Date: Mon, 28 Apr 2025 11:07:51 +0200 Subject: [PATCH] fix bug, again --- .../MareSynchronosServer/Hubs/ConcurrencyFilter.cs | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) diff --git a/MareSynchronosServer/MareSynchronosServer/Hubs/ConcurrencyFilter.cs b/MareSynchronosServer/MareSynchronosServer/Hubs/ConcurrencyFilter.cs index 20f688b..5572c32 100644 --- a/MareSynchronosServer/MareSynchronosServer/Hubs/ConcurrencyFilter.cs +++ b/MareSynchronosServer/MareSynchronosServer/Hubs/ConcurrencyFilter.cs @@ -10,7 +10,7 @@ public sealed class ConcurrencyFilter : IHubFilter, IDisposable private SemaphoreSlim _limiter; private int _setLimit = 0; private readonly IConfigurationService _config; - private readonly CancellationTokenSource _cancellationToken; + private readonly CancellationTokenSource _cts = new(); private bool _disposed; @@ -23,7 +23,7 @@ public sealed class ConcurrencyFilter : IHubFilter, IDisposable _ = Task.Run(async () => { - var token = _cancellationToken.Token; + var token = _cts.Token; while (!token.IsCancellationRequested) { mareMetrics.SetGaugeTo(MetricsAPI.GaugeHubConcurrency, _limiter?.CurrentCount ?? 0); @@ -71,7 +71,7 @@ public sealed class ConcurrencyFilter : IHubFilter, IDisposable } _disposed = true; - _cancellationToken.Cancel(); + _cts.Cancel(); _config.ConfigChangedEvent -= OnConfigChange; } }