aboutsummaryrefslogtreecommitdiffstats
path: root/library/cpp/messagebus/remote_connection_status.cpp
diff options
context:
space:
mode:
authorAnton Samokhvalov <pg83@yandex.ru>2022-02-10 16:45:15 +0300
committerDaniil Cherednik <dcherednik@yandex-team.ru>2022-02-10 16:45:15 +0300
commit72cb13b4aff9bc9cf22e49251bc8fd143f82538f (patch)
treeda2c34829458c7d4e74bdfbdf85dff449e9e7fb8 /library/cpp/messagebus/remote_connection_status.cpp
parent778e51ba091dc39e7b7fcab2b9cf4dbedfb6f2b5 (diff)
downloadydb-72cb13b4aff9bc9cf22e49251bc8fd143f82538f.tar.gz
Restoring authorship annotation for Anton Samokhvalov <pg83@yandex.ru>. Commit 1 of 2.
Diffstat (limited to 'library/cpp/messagebus/remote_connection_status.cpp')
-rw-r--r--library/cpp/messagebus/remote_connection_status.cpp28
1 files changed, 14 insertions, 14 deletions
diff --git a/library/cpp/messagebus/remote_connection_status.cpp b/library/cpp/messagebus/remote_connection_status.cpp
index 2c48b2a287..05b47e281e 100644
--- a/library/cpp/messagebus/remote_connection_status.cpp
+++ b/library/cpp/messagebus/remote_connection_status.cpp
@@ -62,7 +62,7 @@ TRemoteConnectionStatusBase::TRemoteConnectionStatusBase()
{
}
-TRemoteConnectionStatusBase& TRemoteConnectionStatusBase ::operator+=(const TRemoteConnectionStatusBase& that) {
+TRemoteConnectionStatusBase& TRemoteConnectionStatusBase ::operator+=(const TRemoteConnectionStatusBase& that) {
REMOTE_CONNECTION_STATUS_BASE_MAP(STRUCT_FIELD_ADD, )
return *this;
}
@@ -72,8 +72,8 @@ TRemoteConnectionIncrementalStatusBase::TRemoteConnectionIncrementalStatusBase()
{
}
-TRemoteConnectionIncrementalStatusBase& TRemoteConnectionIncrementalStatusBase::operator+=(
- const TRemoteConnectionIncrementalStatusBase& that) {
+TRemoteConnectionIncrementalStatusBase& TRemoteConnectionIncrementalStatusBase::operator+=(
+ const TRemoteConnectionIncrementalStatusBase& that) {
REMOTE_CONNECTION_INCREMENTAL_STATUS_BASE_MAP(STRUCT_FIELD_ADD, )
return *this;
}
@@ -84,8 +84,8 @@ TRemoteConnectionReaderIncrementalStatus::TRemoteConnectionReaderIncrementalStat
}
TRemoteConnectionReaderIncrementalStatus& TRemoteConnectionReaderIncrementalStatus::operator+=(
- const TRemoteConnectionReaderIncrementalStatus& that) {
- TRemoteConnectionIncrementalStatusBase::operator+=(that);
+ const TRemoteConnectionReaderIncrementalStatus& that) {
+ TRemoteConnectionIncrementalStatusBase::operator+=(that);
REMOTE_CONNECTION_READER_INCREMENTAL_STATUS_MAP(STRUCT_FIELD_ADD, )
return *this;
}
@@ -96,7 +96,7 @@ TRemoteConnectionReaderStatus::TRemoteConnectionReaderStatus()
}
TRemoteConnectionReaderStatus& TRemoteConnectionReaderStatus::operator+=(const TRemoteConnectionReaderStatus& that) {
- TRemoteConnectionStatusBase::operator+=(that);
+ TRemoteConnectionStatusBase::operator+=(that);
REMOTE_CONNECTION_READER_STATUS_MAP(STRUCT_FIELD_ADD, )
return *this;
}
@@ -107,8 +107,8 @@ TRemoteConnectionWriterIncrementalStatus::TRemoteConnectionWriterIncrementalStat
}
TRemoteConnectionWriterIncrementalStatus& TRemoteConnectionWriterIncrementalStatus::operator+=(
- const TRemoteConnectionWriterIncrementalStatus& that) {
- TRemoteConnectionIncrementalStatusBase::operator+=(that);
+ const TRemoteConnectionWriterIncrementalStatus& that) {
+ TRemoteConnectionIncrementalStatusBase::operator+=(that);
REMOTE_CONNECTION_WRITER_INCREMENTAL_STATUS(STRUCT_FIELD_ADD, )
return *this;
}
@@ -119,7 +119,7 @@ TRemoteConnectionWriterStatus::TRemoteConnectionWriterStatus()
}
TRemoteConnectionWriterStatus& TRemoteConnectionWriterStatus::operator+=(const TRemoteConnectionWriterStatus& that) {
- TRemoteConnectionStatusBase::operator+=(that);
+ TRemoteConnectionStatusBase::operator+=(that);
REMOTE_CONNECTION_WRITER_STATUS(STRUCT_FIELD_ADD, )
return *this;
}
@@ -162,9 +162,9 @@ TString TRemoteConnectionStatus::PrintToString() const {
if (!Summary) {
// TODO: print MyAddr too, but only if it is set
ss << WriterStatus.PeerAddr << " (" << WriterStatus.ConnectionId << ")"
- << ", writefd=" << WriterStatus.Fd
- << ", readfd=" << ReaderStatus.Fd
- << Endl;
+ << ", writefd=" << WriterStatus.Fd
+ << ", readfd=" << ReaderStatus.Fd
+ << Endl;
if (WriterStatus.Connected) {
p.AddRow("connect time", WriterStatus.ConnectTime.ToString());
p.AddRow("writer state", ToCString(WriterStatus.State));
@@ -182,7 +182,7 @@ TString TRemoteConnectionStatus::PrintToString() const {
p.AddRow("send queue", LeftPad(WriterStatus.SendQueueSize, 6));
- if (Server) {
+ if (Server) {
p.AddRow("quota msg", LeftPad(ReaderStatus.QuotaMsg, 6));
p.AddRow("quota bytes", LeftPad(ReaderStatus.QuotaBytes, 6));
p.AddRow("quota exhausted", LeftPad(ReaderStatus.QuotaExhausted, 6));
@@ -254,7 +254,7 @@ TString TSessionDumpStatus::PrintToString() const {
return ss.Str();
}
-TString TBusMessageQueueStatus::PrintToString() const {
+TString TBusMessageQueueStatus::PrintToString() const {
TStringStream ss;
ss << "work queue:\n";
ss << ExecutorStatus.Status;