From 9e2daec8b3a0389b6717a01b48adf1334b2923be Mon Sep 17 00:00:00 2001 From: vnugent Date: Sat, 27 Jul 2024 20:48:37 -0400 Subject: get it working before overhaul --- plugins/ObjectCacheServer/src/Cache/CacheListenerPubQueue.cs | 2 +- plugins/ObjectCacheServer/src/Cache/PeerEventQueueManager.cs | 4 ++-- 2 files changed, 3 insertions(+), 3 deletions(-) (limited to 'plugins/ObjectCacheServer/src/Cache') diff --git a/plugins/ObjectCacheServer/src/Cache/CacheListenerPubQueue.cs b/plugins/ObjectCacheServer/src/Cache/CacheListenerPubQueue.cs index aef0255..c662baa 100644 --- a/plugins/ObjectCacheServer/src/Cache/CacheListenerPubQueue.cs +++ b/plugins/ObjectCacheServer/src/Cache/CacheListenerPubQueue.cs @@ -109,7 +109,7 @@ namespace VNLib.Data.Caching.ObjectCache.Server.Cache /// public void PublishEvent(ChangeEvent changeEvent) { - if (!_listenerQueue.TryEnque(changeEvent)) + if (!_listenerQueue.TryEnqueue(changeEvent)) { _logProvider.Warn("Cache listener event queue is overflowing"); } diff --git a/plugins/ObjectCacheServer/src/Cache/PeerEventQueueManager.cs b/plugins/ObjectCacheServer/src/Cache/PeerEventQueueManager.cs index 4b76a9b..363f5ed 100644 --- a/plugins/ObjectCacheServer/src/Cache/PeerEventQueueManager.cs +++ b/plugins/ObjectCacheServer/src/Cache/PeerEventQueueManager.cs @@ -228,13 +228,13 @@ namespace VNLib.Data.Caching.ObjectCache.Server.Cache FullMode = BoundedChannelFullMode.DropOldest, }); - public void PublishChange(ChangeEvent change) => Queue.TryEnque(change); + public void PublishChange(ChangeEvent change) => Queue.TryEnqueue(change); public void PublishChanges(Span changes) { for (int i = 0; i < changes.Length; i++) { - Queue.TryEnque(changes[i]); + Queue.TryEnqueue(changes[i]); } } -- cgit