aboutsummaryrefslogtreecommitdiffstats
diff options
context:
space:
mode:
authorAlexander Rutkovsky <alexvru@mail.ru>2022-03-24 14:45:04 +0300
committerAlexander Rutkovsky <alexvru@mail.ru>2022-03-24 14:45:04 +0300
commit8f435f2d7ebc63bc91e00867bb196fd369329f54 (patch)
tree362527c17f165a095893bc582d88ca73daa44dc2
parentb9fd46f9ff1a358339996e962e96b658677983c7 (diff)
downloadydb-8f435f2d7ebc63bc91e00867bb196fd369329f54.tar.gz
Small BS_QUEUE message relevance improvement KIKIMR-8102
ref:e818a33dd368f6f75da59bbba604bf74b53bd481
-rw-r--r--ydb/core/blobstorage/backpressure/queue.cpp13
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