aboutsummaryrefslogtreecommitdiffstats
diff options
context:
space:
mode:
authorivanmorozov333 <ivanmorozov@ydb.tech>2025-07-17 11:33:40 +0300
committerGitHub <noreply@github.com>2025-07-17 11:33:40 +0300
commitc0ec55e71aa5551e5962aead214f2b6494042c9b (patch)
tree6de483e69efc1723ce1c09a2fd096619a6ded228
parent4ebb0f9dba156b0908fb297d561c9c0414f1db50 (diff)
downloadydb-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.h4
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)));
}
}