Skip to content

Commit df88dac

Browse files
authored
Fix counters not decremented on bs_queue destruction (#11530)
1 parent 2ec8c2c commit df88dac

File tree

1 file changed

+2
-0
lines changed

1 file changed

+2
-0
lines changed

ydb/core/blobstorage/backpressure/queue.cpp

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -46,8 +46,10 @@ TBlobStorageQueue::~TBlobStorageQueue() {
4646
for (TItemList *queue : {&Queues.Waiting, &Queues.InFlight, &Queues.Unused}) {
4747
for (TItem& item : *queue) {
4848
SetItemQueue(item, EItemQueue::NotSet);
49+
--*QueueSize;
4950
}
5051
}
52+
*QueueWindowSize -= WindowSize;
5153
}
5254

5355
void TBlobStorageQueue::UpdateCostModel(TInstant now, const NKikimrBlobStorage::TVDiskCostSettings& settings,

0 commit comments

Comments
 (0)