aboutsummaryrefslogtreecommitdiffstats
path: root/library/cpp/messagebus/message_status_counter.cpp
diff options
context:
space:
mode:
authorzhenyok <zhenyok@yandex-team.ru>2022-02-10 16:50:32 +0300
committerDaniil Cherednik <dcherednik@yandex-team.ru>2022-02-10 16:50:32 +0300
commitae11a371d50c25e7fff450f692a12cba03ceaf4f (patch)
tree5d5cb817648f650d76cf1076100726fd9b8448e8 /library/cpp/messagebus/message_status_counter.cpp
parentb4b9936f4dce18fb9da09a1e46342c289d19663b (diff)
downloadydb-ae11a371d50c25e7fff450f692a12cba03ceaf4f.tar.gz
Restoring authorship annotation for <zhenyok@yandex-team.ru>. Commit 2 of 2.
Diffstat (limited to 'library/cpp/messagebus/message_status_counter.cpp')
-rw-r--r--library/cpp/messagebus/message_status_counter.cpp28
1 files changed, 14 insertions, 14 deletions
diff --git a/library/cpp/messagebus/message_status_counter.cpp b/library/cpp/messagebus/message_status_counter.cpp
index dd417081e0..891c8f5bb2 100644
--- a/library/cpp/messagebus/message_status_counter.cpp
+++ b/library/cpp/messagebus/message_status_counter.cpp
@@ -5,7 +5,7 @@
#include <library/cpp/messagebus/monitoring/mon_proto.pb.h>
-#include <util/stream/str.h>
+#include <util/stream/str.h>
using namespace NBus;
using namespace NBus::NPrivate;
@@ -55,17 +55,17 @@ TString TMessageStatusCounter::PrintToString() const {
return ss.Str();
}
-void TMessageStatusCounter::FillErrorsProtobuf(TConnectionStatusMonRecord* status) const {
- status->clear_errorcountbystatus();
- for (size_t i = 0; i < MESSAGE_STATUS_COUNT; ++i) {
- if (i == MESSAGE_OK) {
+void TMessageStatusCounter::FillErrorsProtobuf(TConnectionStatusMonRecord* status) const {
+ status->clear_errorcountbystatus();
+ for (size_t i = 0; i < MESSAGE_STATUS_COUNT; ++i) {
+ if (i == MESSAGE_OK) {
Y_VERIFY(Counts[i] == 0);
- continue;
- }
- if (Counts[i] != 0) {
- TMessageStatusRecord* description = status->add_errorcountbystatus();
- description->SetStatus(TMessageStatusCounter::MessageStatusToProtobuf((EMessageStatus)i));
- description->SetCount(Counts[i]);
- }
- }
-}
+ continue;
+ }
+ if (Counts[i] != 0) {
+ TMessageStatusRecord* description = status->add_errorcountbystatus();
+ description->SetStatus(TMessageStatusCounter::MessageStatusToProtobuf((EMessageStatus)i));
+ description->SetCount(Counts[i]);
+ }
+ }
+}