aboutsummaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorLibravatar vnugent <public@vaughnnugent.com>2023-09-22 12:29:37 -0400
committerLibravatar vnugent <public@vaughnnugent.com>2023-09-22 12:29:37 -0400
commitb1645cbdc4985d4ec72336e98c04bf207a717aee (patch)
tree6c84fabd2c16263a158cab79bba8d912e15de500
parent895556aaff7a15d018dfdcafbda3be68961ee727 (diff)
Structure refactor & unused feature pruning, more http2 prep
-rw-r--r--plugins/ObjectCacheServer/src/Cache/CacheEventQueueManager.cs3
1 files changed, 2 insertions, 1 deletions
diff --git a/plugins/ObjectCacheServer/src/Cache/CacheEventQueueManager.cs b/plugins/ObjectCacheServer/src/Cache/CacheEventQueueManager.cs
index ad0eb5a..e3c613d 100644
--- a/plugins/ObjectCacheServer/src/Cache/CacheEventQueueManager.cs
+++ b/plugins/ObjectCacheServer/src/Cache/CacheEventQueueManager.cs
@@ -32,7 +32,6 @@ using System.Collections.Generic;
using VNLib.Plugins;
using VNLib.Utils.Async;
using VNLib.Utils.Logging;
-using VNLib.Utils.Extensions;
using VNLib.Plugins.Extensions.Loading;
using VNLib.Plugins.Extensions.Loading.Events;
@@ -164,6 +163,7 @@ namespace VNLib.Data.Caching.ObjectCache.Server.Cache
{
//Enter locks
lock (SubLock)
+ {
lock (StoreLock)
{
//Get all stale queues (queues without listeners)
@@ -178,6 +178,7 @@ namespace VNLib.Data.Caching.ObjectCache.Server.Cache
Subscribers.Remove(nq);
}
}
+ }
}
//Interval to purge stale subscribers