library/cpp/messagebus/acceptor_status.cpp


1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68

#include "acceptor_status.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) { 
    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; 
} 
 
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", 
                 TString() + LastSystemErrorText(LastAcceptErrorErrno) + " at " + LastAcceptErrorInstant.ToString());
    } 
 
    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(); 
}