aboutsummaryrefslogtreecommitdiffstats
diff options
context:
space:
mode:
authorhcpp <hcpp@ydb.tech>2022-10-21 01:35:49 +0300
committerhcpp <hcpp@ydb.tech>2022-10-21 01:35:49 +0300
commitb7cbacab05926fc7ad4856a02481082dfbbb9e68 (patch)
tree09cdb113ed153bf59a397f23511b2c991ab0e87f
parent07eb3b00e935ed116e058c249c5a3cc208568b7a (diff)
downloadydb-b7cbacab05926fc7ad4856a02481082dfbbb9e68.tar.gz
metrics has been fixed
-rw-r--r--ydb/core/yq/libs/control_plane_proxy/control_plane_proxy.cpp16
-rw-r--r--ydb/core/yq/libs/control_plane_storage/ydb_control_plane_storage_impl.h16
2 files changed, 16 insertions, 16 deletions
diff --git a/ydb/core/yq/libs/control_plane_proxy/control_plane_proxy.cpp b/ydb/core/yq/libs/control_plane_proxy/control_plane_proxy.cpp
index 6b2a3b239da..7ea74c1ac62 100644
--- a/ydb/core/yq/libs/control_plane_proxy/control_plane_proxy.cpp
+++ b/ydb/core/yq/libs/control_plane_proxy/control_plane_proxy.cpp
@@ -118,8 +118,8 @@ struct TRequestCounters {
}
void DecInFly() {
- Scope->InFly->Inc();
- Common->InFly->Inc();
+ Scope->InFly->Dec();
+ Common->InFly->Dec();
}
void IncOk() {
@@ -128,8 +128,8 @@ struct TRequestCounters {
}
void DecOk() {
- Scope->Ok->Inc();
- Common->Ok->Inc();
+ Scope->Ok->Dec();
+ Common->Ok->Dec();
}
void IncError() {
@@ -138,8 +138,8 @@ struct TRequestCounters {
}
void DecError() {
- Scope->Error->Inc();
- Common->Error->Inc();
+ Scope->Error->Dec();
+ Common->Error->Dec();
}
void IncTimeout() {
@@ -148,8 +148,8 @@ struct TRequestCounters {
}
void DecTimeout() {
- Scope->Timeout->Inc();
- Common->Timeout->Inc();
+ Scope->Timeout->Dec();
+ Common->Timeout->Dec();
}
};
diff --git a/ydb/core/yq/libs/control_plane_storage/ydb_control_plane_storage_impl.h b/ydb/core/yq/libs/control_plane_storage/ydb_control_plane_storage_impl.h
index 9a713734474..f91618ecf3b 100644
--- a/ydb/core/yq/libs/control_plane_storage/ydb_control_plane_storage_impl.h
+++ b/ydb/core/yq/libs/control_plane_storage/ydb_control_plane_storage_impl.h
@@ -112,10 +112,10 @@ struct TRequestCounters {
void DecInFly() {
if (Scope) {
- Scope->InFly->Inc();
+ Scope->InFly->Dec();
}
if (Common) {
- Common->InFly->Inc();
+ Common->InFly->Dec();
}
}
@@ -130,10 +130,10 @@ struct TRequestCounters {
void DecOk() {
if (Scope) {
- Scope->Ok->Inc();
+ Scope->Ok->Dec();
}
if (Common) {
- Common->Ok->Inc();
+ Common->Ok->Dec();
}
}
@@ -148,10 +148,10 @@ struct TRequestCounters {
void DecError() {
if (Scope) {
- Scope->Error->Inc();
+ Scope->Error->Dec();
}
if (Common) {
- Common->Error->Inc();
+ Common->Error->Dec();
}
}
@@ -166,10 +166,10 @@ struct TRequestCounters {
void DecRetry() {
if (Scope) {
- Scope->Retry->Inc();
+ Scope->Retry->Dec();
}
if (Common) {
- Common->Retry->Inc();
+ Common->Retry->Dec();
}
}
};