friendlynamazu/server
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

optimize cacheservice

Browse Source
This commit is contained in:
rootdarkarchon
2023-11-04 03:35:19 +01:00
parent 2eeeb748a0
commit 192ddfb188
1 changed files with 25 additions and 22 deletions
Download Patch File Download Diff File Expand all files Collapse all files

27
MareSynchronosServer/MareSynchronosServer/Services/OnlineSyncedPairCacheService.cs
View File

@@ -1,15 +1,14 @@
using MareSynchronosShared.Metrics; using MareSynchronosShared.Metrics;
using System.Collections.Concurrent;
namespace MareSynchronosServer.Services; namespace MareSynchronosServer.Services;
public class OnlineSyncedPairCacheService : IHostedService public class OnlineSyncedPairCacheService : IHostedService
{ {
private const int CleanupCount = 1; private const int CleanupCount = 1;
private const int CacheCount = 500; private const int CacheCount = 1000;
private Task? _cleanUpTask; private Task? _cleanUpTask;
private readonly CancellationTokenSource _runnerCts = new(); private readonly CancellationTokenSource _runnerCts = new();
private readonly ConcurrentDictionary<string, Dictionary<string, DateTime>> _lastSeenCache = new(StringComparer.Ordinal); private readonly Dictionary<string, Dictionary<string, DateTime>> _lastSeenCache = new(StringComparer.Ordinal);
private readonly SemaphoreSlim _cleanupSemaphore = new(CleanupCount); private readonly SemaphoreSlim _cleanupSemaphore = new(CleanupCount);
private readonly SemaphoreSlim _cacheSemaphore = new(CacheCount); private readonly SemaphoreSlim _cacheSemaphore = new(CacheCount);
private readonly SemaphoreSlim _cacheAdditionSemaphore = new(1); private readonly SemaphoreSlim _cacheAdditionSemaphore = new(1);
@@ -120,9 +119,9 @@ public class OnlineSyncedPairCacheService : IHostedService
{ {
while (!ct.IsCancellationRequested) while (!ct.IsCancellationRequested)
{ {
await Task.Delay(TimeSpan.FromSeconds(10), ct).ConfigureAwait(false); await Task.Delay(TimeSpan.FromSeconds(60), ct).ConfigureAwait(false);
_logger.LogInformation("Cleaning up stale entries"); _logger.LogInformation("Cleaning up stale entries: spin up");
try try
{ {
@@ -144,13 +143,17 @@ public class OnlineSyncedPairCacheService : IHostedService
{ {
int entriesRemoved = 0; int entriesRemoved = 0;
int playersRemoved = 0; int playersRemoved = 0;
foreach (var playerCache in _lastSeenCache.ToDictionary(k => k.Key, k => k.Value, StringComparer.Ordinal)) _logger.LogInformation("Cleaning up stale entries: start");
Parallel.ForEach(_lastSeenCache.ToDictionary(k => k.Key, k => k.Value, StringComparer.Ordinal),
playerCache =>
{ {
ct.ThrowIfCancellationRequested();
foreach (var cacheEntry in playerCache.Value.ToDictionary(k => k.Key, k => k.Value, StringComparer.Ordinal)) foreach (var cacheEntry in playerCache.Value.ToDictionary(k => k.Key, k => k.Value, StringComparer.Ordinal))
{ {
if (cacheEntry.Value < DateTime.UtcNow) if (cacheEntry.Value < DateTime.UtcNow)
{ {
entriesRemoved++; Interlocked.Increment(ref entriesRemoved);
playerCache.Value.Remove(cacheEntry.Key); playerCache.Value.Remove(cacheEntry.Key);
} }
} }
@@ -159,18 +162,18 @@ public class OnlineSyncedPairCacheService : IHostedService
if (!playerCache.Value.Any()) if (!playerCache.Value.Any())
{ {
playersRemoved++; Interlocked.Increment(ref playersRemoved);
_lastSeenCache.Remove(playerCache.Key, out _); _lastSeenCache.Remove(playerCache.Key, out _);
} }
} });
_logger.LogInformation("Cleaning up complete, removed {entries} individual entries and {players} players", entriesRemoved, playersRemoved); _logger.LogInformation("Cleaning up stale entries: complete; removed {entries} individual entries and {players} players", entriesRemoved, playersRemoved);
_mareMetrics.SetGaugeTo(MetricsAPI.GaugeUserPairCacheEntries, _lastSeenCache.Values.SelectMany(k => k.Keys).Count()); _mareMetrics.SetGaugeTo(MetricsAPI.GaugeUserPairCacheEntries, _lastSeenCache.Values.SelectMany(k => k.Keys).Count());
_mareMetrics.SetGaugeTo(MetricsAPI.GaugeUserPairCacheUsers, _lastSeenCache.Keys.Count()); _mareMetrics.SetGaugeTo(MetricsAPI.GaugeUserPairCacheUsers, _lastSeenCache.Keys.Count);
} }
catch (Exception ex) catch (Exception ex)
{ {
_logger.LogWarning(ex, "Cleanup failed"); _logger.LogWarning(ex, "Cleaning up stale entries: failed");
} }
} }
} }