From b1645cbdc4985d4ec72336e98c04bf207a717aee Mon Sep 17 00:00:00 2001 From: vnugent Date: Fri, 22 Sep 2023 12:29:37 -0400 Subject: Structure refactor & unused feature pruning, more http2 prep --- plugins/ObjectCacheServer/src/Cache/CacheEventQueueManager.cs | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) 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 -- cgit