library/cpp/messagebus/message_counter.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

#include "message_counter.h"

#include <util/stream/str.h> 
 
using namespace NBus; 
using namespace NBus::NPrivate; 
 
TMessageCounter::TMessageCounter() 
    : BytesData(0) 
    , BytesNetwork(0) 
    , Count(0) 
    , CountCompressed(0) 
    , CountCompressionRequests(0) 
{
}
 
TMessageCounter& TMessageCounter::operator+=(const TMessageCounter& that) { 
    BytesData += that.BytesData; 
    BytesNetwork += that.BytesNetwork; 
    Count += that.Count; 
    CountCompressed += that.CountCompressed; 
    CountCompressionRequests += that.CountCompressionRequests; 
    return *this; 
} 
 
TString TMessageCounter::ToString(bool reader) const {
    if (reader) { 
        Y_ASSERT(CountCompressionRequests == 0);
    } 
 
    TStringStream readValue; 
    readValue << Count; 
    if (CountCompressionRequests != 0 || CountCompressed != 0) { 
        readValue << " (" << CountCompressed << " compr"; 
        if (!reader) { 
            readValue << ", " << CountCompressionRequests << " compr reqs"; 
        } 
        readValue << ")"; 
    } 
    readValue << ", "; 
    readValue << BytesData << "b"; 
    if (BytesNetwork != BytesData) { 
        readValue << " (" << BytesNetwork << "b network)"; 
    } 
    return readValue.Str(); 
}