diff options
author | Alexander Rutkovsky <alexvru@mail.ru> | 2022-03-24 14:45:04 +0300 |
---|---|---|
committer | Alexander Rutkovsky <alexvru@mail.ru> | 2022-03-24 14:45:04 +0300 |
commit | 8f435f2d7ebc63bc91e00867bb196fd369329f54 (patch) | |
tree | 362527c17f165a095893bc582d88ca73daa44dc2 | |
parent | b9fd46f9ff1a358339996e962e96b658677983c7 (diff) | |
download | ydb-8f435f2d7ebc63bc91e00867bb196fd369329f54.tar.gz |
Small BS_QUEUE message relevance improvement KIKIMR-8102
ref:e818a33dd368f6f75da59bbba604bf74b53bd481
-rw-r--r-- | ydb/core/blobstorage/backpressure/queue.cpp | 13 |
1 files changed, 7 insertions, 6 deletions
diff --git a/ydb/core/blobstorage/backpressure/queue.cpp b/ydb/core/blobstorage/backpressure/queue.cpp index 7e9622334d5..e1574116a0c 100644 --- a/ydb/core/blobstorage/backpressure/queue.cpp +++ b/ydb/core/blobstorage/backpressure/queue.cpp @@ -131,12 +131,6 @@ void TBlobStorageQueue::SendToVDisk(const TActorContext& ctx, const TActorId& re continue; } - if (!item.Event.Relevant()) { - ++*QueueItemsPruned; - it = EraseItem(Queues.Waiting, it); - continue; - } - // update item parameters item.MsgId = NextMsgId; item.SequenceId = CurrentSequenceId; @@ -187,6 +181,13 @@ void TBlobStorageQueue::SendToVDisk(const TActorContext& ctx, const TActorId& re ++*QueueOverflow; break; } + + if (!item.Event.Relevant()) { + ++*QueueItemsPruned; + it = EraseItem(Queues.Waiting, it); + continue; + } + InFlightCost += item.Cost; // move item to in-flight queue |