aboutsummaryrefslogtreecommitdiffstats
path: root/library/cpp/messagebus/message_counter.cpp
diff options
context:
space:
mode:
authornga <nga@yandex-team.ru>2022-02-10 16:48:09 +0300
committerDaniil Cherednik <dcherednik@yandex-team.ru>2022-02-10 16:48:09 +0300
commit1f553f46fb4f3c5eec631352cdd900a0709016af (patch)
treea231fba2c03b440becaea6c86a2702d0bfb0336e /library/cpp/messagebus/message_counter.cpp
parentc4de7efdedc25b49cbea74bd589eecb61b55b60a (diff)
downloadydb-1f553f46fb4f3c5eec631352cdd900a0709016af.tar.gz
Restoring authorship annotation for <nga@yandex-team.ru>. Commit 1 of 2.
Diffstat (limited to 'library/cpp/messagebus/message_counter.cpp')
-rw-r--r--library/cpp/messagebus/message_counter.cpp80
1 files changed, 40 insertions, 40 deletions
diff --git a/library/cpp/messagebus/message_counter.cpp b/library/cpp/messagebus/message_counter.cpp
index 04d9343f6a..93092a65a6 100644
--- a/library/cpp/messagebus/message_counter.cpp
+++ b/library/cpp/messagebus/message_counter.cpp
@@ -1,46 +1,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)
+#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;
-}
-
+
+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) {
+ 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();
-}
+ }
+
+ 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();
+}