summaryrefslogtreecommitdiffstats
path: root/library/cpp/messagebus/acceptor_status.cpp
diff options
context:
space:
mode:
authornga <[email protected]>2022-02-10 16:48:09 +0300
committerDaniil Cherednik <[email protected]>2022-02-10 16:48:09 +0300
commit1f553f46fb4f3c5eec631352cdd900a0709016af (patch)
treea231fba2c03b440becaea6c86a2702d0bfb0336e /library/cpp/messagebus/acceptor_status.cpp
parentc4de7efdedc25b49cbea74bd589eecb61b55b60a (diff)
Restoring authorship annotation for <[email protected]>. Commit 1 of 2.
Diffstat (limited to 'library/cpp/messagebus/acceptor_status.cpp')
-rw-r--r--library/cpp/messagebus/acceptor_status.cpp120
1 files changed, 60 insertions, 60 deletions
diff --git a/library/cpp/messagebus/acceptor_status.cpp b/library/cpp/messagebus/acceptor_status.cpp
index 5006ff68aee..3b0725a46b5 100644
--- a/library/cpp/messagebus/acceptor_status.cpp
+++ b/library/cpp/messagebus/acceptor_status.cpp
@@ -1,68 +1,68 @@
#include "acceptor_status.h"
-
-#include "key_value_printer.h"
-
+
+#include "key_value_printer.h"
+
#include <util/stream/format.h>
#include <util/stream/output.h>
-
-using namespace NBus;
-using namespace NBus::NPrivate;
-
-TAcceptorStatus::TAcceptorStatus()
- : Summary(false)
- , AcceptorId(0)
- , Fd(INVALID_SOCKET)
-{
- ResetIncremental();
-}
-
-void TAcceptorStatus::ResetIncremental() {
- AcceptSuccessCount = 0;
- AcceptErrorCount = 0;
- LastAcceptErrorErrno = 0;
- LastAcceptErrorInstant = TInstant();
- LastAcceptSuccessInstant = TInstant();
-}
-
-TAcceptorStatus& TAcceptorStatus::operator+=(const TAcceptorStatus& that) {
+
+using namespace NBus;
+using namespace NBus::NPrivate;
+
+TAcceptorStatus::TAcceptorStatus()
+ : Summary(false)
+ , AcceptorId(0)
+ , Fd(INVALID_SOCKET)
+{
+ ResetIncremental();
+}
+
+void TAcceptorStatus::ResetIncremental() {
+ AcceptSuccessCount = 0;
+ AcceptErrorCount = 0;
+ LastAcceptErrorErrno = 0;
+ LastAcceptErrorInstant = TInstant();
+ LastAcceptSuccessInstant = TInstant();
+}
+
+TAcceptorStatus& TAcceptorStatus::operator+=(const TAcceptorStatus& that) {
Y_ASSERT(Summary);
Y_ASSERT(AcceptorId == 0);
-
- AcceptSuccessCount += that.AcceptSuccessCount;
- LastAcceptSuccessInstant = Max(LastAcceptSuccessInstant, that.LastAcceptSuccessInstant);
-
- AcceptErrorCount += that.AcceptErrorCount;
- if (that.LastAcceptErrorInstant > LastAcceptErrorInstant) {
- LastAcceptErrorInstant = that.LastAcceptErrorInstant;
- LastAcceptErrorErrno = that.LastAcceptErrorErrno;
- }
-
- return *this;
-}
-
+
+ AcceptSuccessCount += that.AcceptSuccessCount;
+ LastAcceptSuccessInstant = Max(LastAcceptSuccessInstant, that.LastAcceptSuccessInstant);
+
+ AcceptErrorCount += that.AcceptErrorCount;
+ if (that.LastAcceptErrorInstant > LastAcceptErrorInstant) {
+ LastAcceptErrorInstant = that.LastAcceptErrorInstant;
+ LastAcceptErrorErrno = that.LastAcceptErrorErrno;
+ }
+
+ return *this;
+}
+
TString TAcceptorStatus::PrintToString() const {
- TStringStream ss;
-
- if (!Summary) {
- ss << "acceptor (" << AcceptorId << "), fd=" << Fd << ", addr=" << ListenAddr << Endl;
- }
-
- TKeyValuePrinter p;
-
- p.AddRow("accept error count", LeftPad(AcceptErrorCount, 4));
-
- if (AcceptErrorCount > 0) {
- p.AddRow("last accept error",
+ TStringStream ss;
+
+ if (!Summary) {
+ ss << "acceptor (" << AcceptorId << "), fd=" << Fd << ", addr=" << ListenAddr << Endl;
+ }
+
+ TKeyValuePrinter p;
+
+ p.AddRow("accept error count", LeftPad(AcceptErrorCount, 4));
+
+ if (AcceptErrorCount > 0) {
+ p.AddRow("last accept error",
TString() + LastSystemErrorText(LastAcceptErrorErrno) + " at " + LastAcceptErrorInstant.ToString());
- }
-
- p.AddRow("accept success count", LeftPad(AcceptSuccessCount, 4));
- if (AcceptSuccessCount > 0) {
- p.AddRow("last accept success",
+ }
+
+ p.AddRow("accept success count", LeftPad(AcceptSuccessCount, 4));
+ if (AcceptSuccessCount > 0) {
+ p.AddRow("last accept success",
TString() + "at " + LastAcceptSuccessInstant.ToString());
- }
-
- ss << p.PrintToString();
-
- return ss.Str();
-}
+ }
+
+ ss << p.PrintToString();
+
+ return ss.Str();
+}