From 511a3e0b50ab30c80cc474f1ae2b6e2ae7d9e83c Mon Sep 17 00:00:00 2001 From: Ulimo Date: Fri, 12 Jan 2024 16:36:56 +0100 Subject: [PATCH] fix so the latest percentage is sent if no changes (#298) --- .../StateManager/Internal/Sync/LruTableSync.cs | 7 ++++--- 1 file changed, 4 insertions(+), 3 deletions(-) diff --git a/src/FlowtideDotNet.Storage/StateManager/Internal/Sync/LruTableSync.cs b/src/FlowtideDotNet.Storage/StateManager/Internal/Sync/LruTableSync.cs index e0ae94f6b..edc9a6fbd 100644 --- a/src/FlowtideDotNet.Storage/StateManager/Internal/Sync/LruTableSync.cs +++ b/src/FlowtideDotNet.Storage/StateManager/Internal/Sync/LruTableSync.cs @@ -47,6 +47,7 @@ internal struct LinkedListValue private long m_metrics_lastSeenTotal; private long m_metrics_lastSeenHits; + private float m_metrics_lastSentPercentage; private bool m_disposedValue; private readonly Process _currentProcess; @@ -90,12 +91,12 @@ public LruTableSync(int maxSize, ILogger logger, Meter meter, string streamName, var newHits = hit - m_metrics_lastSeenHits; m_metrics_lastSeenTotal = total; m_metrics_lastSeenHits = hit; - return new Measurement((float)newHits / newTotal, new KeyValuePair("stream", m_streamName)); + m_metrics_lastSentPercentage = (float)newHits / newTotal; + return new Measurement(m_metrics_lastSentPercentage, new KeyValuePair("stream", m_streamName)); } else { - var percentage = (float)m_metrics_lastSeenHits / m_metrics_lastSeenTotal; - return new Measurement(percentage, new KeyValuePair("stream", m_streamName)); + return new Measurement(m_metrics_lastSentPercentage, new KeyValuePair("stream", m_streamName)); } }); }