diff options
author | vnugent <public@vaughnnugent.com> | 2023-09-22 12:29:37 -0400 |
---|---|---|
committer | vnugent <public@vaughnnugent.com> | 2023-09-22 12:29:37 -0400 |
commit | b1645cbdc4985d4ec72336e98c04bf207a717aee (patch) | |
tree | 6c84fabd2c16263a158cab79bba8d912e15de500 /plugins/ObjectCacheServer/src/Cache/CacheEventQueueManager.cs | |
parent | 895556aaff7a15d018dfdcafbda3be68961ee727 (diff) |
Structure refactor & unused feature pruning, more http2 prep
Diffstat (limited to 'plugins/ObjectCacheServer/src/Cache/CacheEventQueueManager.cs')
-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 |