diff options
author | vnugent <public@vaughnnugent.com> | 2024-07-27 20:48:37 -0400 |
---|---|---|
committer | vnugent <public@vaughnnugent.com> | 2024-07-27 20:48:37 -0400 |
commit | 9e2daec8b3a0389b6717a01b48adf1334b2923be (patch) | |
tree | 27c6f83adab1391d832a838e7b826bb5b23b478b /plugins/ObjectCacheServer/src/Cache | |
parent | 24929f4e7acce9847f4cbe813e850ee57d474723 (diff) |
get it working before overhaul
Diffstat (limited to 'plugins/ObjectCacheServer/src/Cache')
-rw-r--r-- | plugins/ObjectCacheServer/src/Cache/CacheListenerPubQueue.cs | 2 | ||||
-rw-r--r-- | plugins/ObjectCacheServer/src/Cache/PeerEventQueueManager.cs | 4 |
2 files changed, 3 insertions, 3 deletions
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 ///<inheritdoc/> 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<ChangeEvent> changes) { for (int i = 0; i < changes.Length; i++) { - Queue.TryEnque(changes[i]); + Queue.TryEnqueue(changes[i]); } } |