fix: Fix inactivity tracking queue undercut notification propagation …

…mechanism
angelobreuer · Mar 17, 2024 · b15e45b · b15e45b
1 parent 5abb18c
commit b15e45b
Showing 1 changed file with 6 additions and 1 deletion.
diff --git a/src/Lavalink4NET.InactivityTracking/Queue/InactivityExpirationQueue.cs b/src/Lavalink4NET.InactivityTracking/Queue/InactivityExpirationQueue.cs
@@ -36,6 +36,7 @@ public InactivityExpirationQueue(ISystemClock systemClock, ILogger<InactivityExp
         _playerQueueSyncRoot = new object();
         _expirationUndercutTaskCompletionSource = new TaskCompletionSource(creationOptions: TaskCreationOptions.RunContinuationsAsynchronously);
         _queueWaitSemaphoreSlim = new SemaphoreSlim(0, int.MaxValue);
+        _lowestExpirationAt = DateTimeOffset.MaxValue;
     }
 
     private void PromoteInternal()
@@ -92,7 +93,11 @@ private void NotifyInternal(ILavalinkPlayer player, DateTimeOffset expireAfter)
         Diagnostics.InactivityExpirationQueueSize.Add(delta: 1, tag: KeyValuePair.Create<string, object?>("label", player.Label));
         Diagnostics.TotalExpirationQueueSize.Add(delta: 1, tag: KeyValuePair.Create<string, object?>("label", player.Label));
 
-        if (expireAfter < _lowestExpirationAt)
+        if (_lowestExpirationAt == DateTimeOffset.MaxValue)
+        {
+            _lowestExpirationAt = expireAfter;
+        }
+        else if (expireAfter < _lowestExpirationAt)
         {
             _lowestExpirationAt = expireAfter;
             _expirationUndercutTaskCompletionSource?.TrySetResult();