diff options
Diffstat (limited to 'plugins/ObjectCacheServer')
-rw-r--r-- | plugins/ObjectCacheServer/src/Cache/CacheEventQueueManager.cs | 3 |
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 |