diff options
author | ivanmorozov333 <ivanmorozov@ydb.tech> | 2025-07-17 11:33:40 +0300 |
---|---|---|
committer | GitHub <noreply@github.com> | 2025-07-17 11:33:40 +0300 |
commit | c0ec55e71aa5551e5962aead214f2b6494042c9b (patch) | |
tree | 6de483e69efc1723ce1c09a2fd096619a6ded228 | |
parent | 4ebb0f9dba156b0908fb297d561c9c0414f1db50 (diff) | |
download | ydb-c0ec55e71aa5551e5962aead214f2b6494042c9b.tar.gz |
fix signal and verification (#21255)
Co-authored-by: ivanmorozov333 <imorozov333@ya.ru>
-rw-r--r-- | ydb/core/tx/general_cache/service/manager.h | 4 |
1 files changed, 3 insertions, 1 deletions
diff --git a/ydb/core/tx/general_cache/service/manager.h b/ydb/core/tx/general_cache/service/manager.h index 49c8e6b2c2f..33242e64051 100644 --- a/ydb/core/tx/general_cache/service/manager.h +++ b/ydb/core/tx/general_cache/service/manager.h @@ -203,7 +203,9 @@ public: void Abort() { const TMonotonic now = TMonotonic::Now(); for (auto&& i : RequestsQueue) { - for (auto&& objAddr : i->GetWaitBySource(SourceId)) { + auto addresses = i->GetWaitBySource(SourceId); + Counters->GetQueueObjectsCount()->Sub(addresses.size()); + for (auto&& objAddr : addresses) { Y_UNUSED(i->AddError(objAddr, "source broken: " + ::ToString(SourceId))); } } |