intermediate changes

ref:cde9a383711a11544ce7e107a78147fb96cc4029

1 files changed, 46 insertions, 0 deletions

diff --git a/library/cpp/messagebus/message_counter.cpp b/library/cpp/messagebus/message_counter.cpp
new file mode 100644
index 00000000000..04d9343f6a2
--- /dev/null
+++ b/library/cpp/messagebus/message_counter.cpp
@@ -0,0 +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)
+{
+}
+
+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();
+}