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;  | 
