From 36ed0dc893e54dc30a6133535a2916036668b34a Mon Sep 17 00:00:00 2001 From: LittleSheep Date: Fri, 8 Aug 2025 14:47:54 +0800 Subject: [PATCH] :bug: Fix last active info didn't flushed --- DysonNetwork.Pass/Handlers/LastActiveFlushHandler.cs | 2 +- DysonNetwork.Shared/Cache/FlushBufferService.cs | 8 +++----- 2 files changed, 4 insertions(+), 6 deletions(-) diff --git a/DysonNetwork.Pass/Handlers/LastActiveFlushHandler.cs b/DysonNetwork.Pass/Handlers/LastActiveFlushHandler.cs index d45dd1f..b9b95aa 100644 --- a/DysonNetwork.Pass/Handlers/LastActiveFlushHandler.cs +++ b/DysonNetwork.Pass/Handlers/LastActiveFlushHandler.cs @@ -53,7 +53,7 @@ public class LastActiveFlushHandler(IServiceProvider srp, ILogger logger) : IJob +public class LastActiveFlushJob(FlushBufferService fbs, LastActiveFlushHandler hdl, ILogger logger) : IJob { public async Task Execute(IJobExecutionContext context) { diff --git a/DysonNetwork.Shared/Cache/FlushBufferService.cs b/DysonNetwork.Shared/Cache/FlushBufferService.cs index 4a6adbb..bc883ec 100644 --- a/DysonNetwork.Shared/Cache/FlushBufferService.cs +++ b/DysonNetwork.Shared/Cache/FlushBufferService.cs @@ -18,11 +18,9 @@ public class FlushBufferService(ILogger logger) var type = typeof(T); lock (_lockObject) { - if (!_buffers.TryGetValue(type, out var buffer)) - { - buffer = new ConcurrentQueue(); - _buffers[type] = buffer; - } + if (_buffers.TryGetValue(type, out var buffer)) return (ConcurrentQueue)buffer; + buffer = new ConcurrentQueue(); + _buffers[type] = buffer; return (ConcurrentQueue)buffer; } }