diff options
| author |  vnugent <public@vaughnnugent.com> | 2023-10-14 15:50:46 -0400 |
|---|---|---|
| committer | vnugent <public@vaughnnugent.com> | 2023-10-14 15:50:46 -0400 |
| commit | 3c353afe4dffa3da9c96ef25b02f0004676afe5f (patch) | |
| tree | 1e3c5889734c029701205c55fa842552ded81c2b /plugins/ObjectCacheServer/src/Clustering | |
| parent | 531baabc8289eeaa2aad63cb0e86cc3dd978d97e (diff) | |
experimential expansion and performance changes
Diffstat (limited to 'plugins/ObjectCacheServer/src/Clustering')
| -rw-r--r-- | plugins/ObjectCacheServer/src/Clustering/CacheNodeReplicationMaanger.cs | 4 | ||||
| -rw-r--r-- | plugins/ObjectCacheServer/src/Clustering/PeerDiscoveryManager.cs | 2 |
2 files changed, 3 insertions, 3 deletions
diff --git a/plugins/ObjectCacheServer/src/Clustering/CacheNodeReplicationMaanger.cs b/plugins/ObjectCacheServer/src/Clustering/CacheNodeReplicationMaanger.cs index 5a04737..19f09dc 100644 --- a/plugins/ObjectCacheServer/src/Clustering/CacheNodeReplicationMaanger.cs +++ b/plugins/ObjectCacheServer/src/Clustering/CacheNodeReplicationMaanger.cs @@ -76,11 +76,11 @@ namespace VNLib.Data.Caching.ObjectCache.Server.Clustering //Load the node config _nodeConfig = plugin.GetOrCreateSingleton<NodeConfig>(); _cacheStore = plugin.GetOrCreateSingleton<CacheStore>(); - _peerAdapter = plugin.GetOrCreateSingleton<PeerDiscoveryManager>(); + _peerAdapter = plugin.GetOrCreateSingleton<PeerDiscoveryManager>(); //Init fbm config with fixed message size _replicationClientConfig = FBMDataCacheExtensions.GetDefaultConfig( - (plugin as ObjectCacheServerEntry)!.CacheHeap, + (plugin as ObjectCacheServerEntry)!.ListenerHeap, MAX_MESSAGE_SIZE, debugLog: plugin.IsDebug() ? plugin.Log : null ); diff --git a/plugins/ObjectCacheServer/src/Clustering/PeerDiscoveryManager.cs b/plugins/ObjectCacheServer/src/Clustering/PeerDiscoveryManager.cs index 65cc009..6475f9c 100644 --- a/plugins/ObjectCacheServer/src/Clustering/PeerDiscoveryManager.cs +++ b/plugins/ObjectCacheServer/src/Clustering/PeerDiscoveryManager.cs @@ -135,7 +135,7 @@ namespace VNLib.Data.Caching.ObjectCache.Server.Clustering if (allAds.Length > 0) { - //Discover all kown nodes + //Discover all known nodes await Config.Config.DiscoverNodesAsync(allAds, exitToken); } |