mirror/ternfs-XTXMarkets
1
0
Fork 0
mirror of https://github.com/XTXMarkets/ternfs.git synced 2025-12-21 02:30:18 -06:00
Code Issues Packages Projects Releases Wiki Activity

minor fixes

Browse Source
This commit is contained in:
Miroslav Crnic
2025-10-16 17:12:37 +00:00
parent 6bfd89dec7
commit d96abd3083
5 changed files with 33 additions and 23 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
cpp/shard/Shard.cpp
View File

@@ -609,6 +609,10 @@ public:
_shared.proxyLogsDBResponseQueueSize = _shared.proxyLogsDBResponseQueueSize*0.95 + _shared.proxyLogsDBResponseQueue.size()*0.05;
_shared.droppedProxyLogsDBResponses = _shared.droppedProxyLogsDBResponses*0.95 + (_proxyLogsDBResponses.size()-pushed)*0.05;
pushed = _shared.writerProxyShardRespQueue.push(_proxyResponses);
_shared.writerProxyRespQueueSize = _shared.writerProxyRespQueueSize*0.95 + _shared.writerProxyShardRespQueue.size()*0.05;
_shared.droppedProxyWriteResponses = _shared.droppedProxyWriteResponses*0.95 + (_proxyResponses.size()-pushed)*0.05;
pushed = _shared.writerShardReqQueue.push(_writeReqs);
_shared.writerRequestQueueSize = _shared.writerRequestQueueSize*0.95 + _shared.writerShardReqQueue.size()*0.05;
_shared.droppedWriteRequests = _shared.droppedWriteRequests*0.95 + (_writeReqs.size()-pushed)*0.05;