diff options
author | hcpp <hcpp@ydb.tech> | 2022-10-21 01:35:49 +0300 |
---|---|---|
committer | hcpp <hcpp@ydb.tech> | 2022-10-21 01:35:49 +0300 |
commit | b7cbacab05926fc7ad4856a02481082dfbbb9e68 (patch) | |
tree | 09cdb113ed153bf59a397f23511b2c991ab0e87f | |
parent | 07eb3b00e935ed116e058c249c5a3cc208568b7a (diff) | |
download | ydb-b7cbacab05926fc7ad4856a02481082dfbbb9e68.tar.gz |
metrics has been fixed
-rw-r--r-- | ydb/core/yq/libs/control_plane_proxy/control_plane_proxy.cpp | 16 | ||||
-rw-r--r-- | ydb/core/yq/libs/control_plane_storage/ydb_control_plane_storage_impl.h | 16 |
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(); } } }; |