diff options
author | zhenyok <zhenyok@yandex-team.ru> | 2022-02-10 16:50:32 +0300 |
---|---|---|
committer | Daniil Cherednik <dcherednik@yandex-team.ru> | 2022-02-10 16:50:32 +0300 |
commit | b4b9936f4dce18fb9da09a1e46342c289d19663b (patch) | |
tree | 1368a616e0854115cdfae09d29013fa1133e333d /library/cpp/messagebus/remote_connection_status.cpp | |
parent | ebfae0ebbb895e280d4efda81e07d3cf667c1625 (diff) | |
download | ydb-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.cpp | 52 |
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; |