diff options
| author | zhenyok <[email protected]> | 2022-02-10 16:50:32 +0300 |
|---|---|---|
| committer | Daniil Cherednik <[email protected]> | 2022-02-10 16:50:32 +0300 |
| commit | ae11a371d50c25e7fff450f692a12cba03ceaf4f (patch) | |
| tree | 5d5cb817648f650d76cf1076100726fd9b8448e8 /library/cpp/messagebus/remote_connection_status.cpp | |
| parent | b4b9936f4dce18fb9da09a1e46342c289d19663b (diff) | |
Restoring authorship annotation for <[email protected]>. Commit 2 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 4e4e01dcf51..2c48b2a287c 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; |
