aboutsummaryrefslogtreecommitdiffstats
path: root/library/cpp/messagebus/remote_connection_status.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/remote_connection_status.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/remote_connection_status.cpp')
-rw-r--r--library/cpp/messagebus/remote_connection_status.cpp52
1 files changed, 26 insertions, 26 deletions
diff --git a/library/cpp/messagebus/remote_connection_status.cpp b/library/cpp/messagebus/remote_connection_status.cpp
index 4e4e01dcf5..2c48b2a287 100644
--- a/library/cpp/messagebus/remote_connection_status.cpp
+++ b/library/cpp/messagebus/remote_connection_status.cpp
@@ -128,32 +128,32 @@ size_t TRemoteConnectionWriterStatus::GetInFlight() const {
return SendQueueSize + AckMessagesSize;
}
-TConnectionStatusMonRecord TRemoteConnectionStatus::GetStatusProtobuf() const {
- TConnectionStatusMonRecord status;
-
- // TODO: fill unfilled fields
- status.SetSendQueueSize(WriterStatus.SendQueueSize);
- status.SetAckMessagesSize(WriterStatus.AckMessagesSize);
- // status.SetErrorCount();
- // status.SetWriteBytes();
- // status.SetWriteBytesCompressed();
- // status.SetWriteMessages();
- status.SetWriteSyscalls(WriterStatus.Incremental.NetworkOps);
- status.SetWriteActs(WriterStatus.Acts);
- // status.SetReadBytes();
- // status.SetReadBytesCompressed();
- // status.SetReadMessages();
- status.SetReadSyscalls(ReaderStatus.Incremental.NetworkOps);
- status.SetReadActs(ReaderStatus.Acts);
-
- TMessageStatusCounter sumStatusCounter;
- sumStatusCounter += WriterStatus.Incremental.StatusCounter;
- sumStatusCounter += ReaderStatus.Incremental.StatusCounter;
- sumStatusCounter.FillErrorsProtobuf(&status);
-
- return status;
-}
-
+TConnectionStatusMonRecord TRemoteConnectionStatus::GetStatusProtobuf() const {
+ TConnectionStatusMonRecord status;
+
+ // TODO: fill unfilled fields
+ status.SetSendQueueSize(WriterStatus.SendQueueSize);
+ status.SetAckMessagesSize(WriterStatus.AckMessagesSize);
+ // status.SetErrorCount();
+ // status.SetWriteBytes();
+ // status.SetWriteBytesCompressed();
+ // status.SetWriteMessages();
+ status.SetWriteSyscalls(WriterStatus.Incremental.NetworkOps);
+ status.SetWriteActs(WriterStatus.Acts);
+ // status.SetReadBytes();
+ // status.SetReadBytesCompressed();
+ // status.SetReadMessages();
+ status.SetReadSyscalls(ReaderStatus.Incremental.NetworkOps);
+ status.SetReadActs(ReaderStatus.Acts);
+
+ TMessageStatusCounter sumStatusCounter;
+ sumStatusCounter += WriterStatus.Incremental.StatusCounter;
+ sumStatusCounter += ReaderStatus.Incremental.StatusCounter;
+ sumStatusCounter.FillErrorsProtobuf(&status);
+
+ return status;
+}
+
TString TRemoteConnectionStatus::PrintToString() const {
TStringStream ss;