change stale data processing I guess

2023-10-17 23:32:58 +02:00
parent 527b95a271
commit 5316daf7d8
1 changed files with 9 additions and 9 deletions
--- a/MareSynchronosServer/MareSynchronosServer/Services/UserPairCacheService.cs
+++ b/MareSynchronosServer/MareSynchronosServer/Services/UserPairCacheService.cs
@@ -134,10 +134,11 @@ public class UserPairCacheService : IHostedService
            if (_staleUserData.Any())
            {
                _logger.LogDebug("Processing Stale Entries");
-                try
-                {
+
                using var dbContext = await _dbContextFactory.CreateDbContextAsync().ConfigureAwait(false);
-                    while (_staleUserData.TryPeek(out var staleUserPair))
+                while (_staleUserData.TryDequeue(out var staleUserPair))
+                {
+                    try
                    {
                        if (staleUserPair.UID == null)
                        {
@@ -175,15 +176,14 @@ public class UserPairCacheService : IHostedService
                                }
                            }
                        }
-
-                        _staleUserData.TryDequeue(out _);
-                    }
                    }
                    catch (Exception ex)
                    {
                        _logger.LogError(ex, "Error during Stale entry processing");
                    }
                }
+
+            }
        }
    }