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
commitb4b9936f4dce18fb9da09a1e46342c289d19663b (patch)
tree1368a616e0854115cdfae09d29013fa1133e333d /library/cpp/messagebus/remote_connection_status.cpp
parentebfae0ebbb895e280d4efda81e07d3cf667c1625 (diff)
downloadydb-b4b9936f4dce18fb9da09a1e46342c289d19663b.tar.gz
Restoring authorship annotation for <zhenyok@yandex-team.ru>. Commit 1 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 2c48b2a287..4e4e01dcf5 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;