protobuf/echo/Echo: Add some tracing

philips-software · Nov 18, 2023 · 8d8c03e · 8d8c03e
1 parent 45fd7da
commit 8d8c03e
Show file tree

Hide file tree

Showing 2 changed files with 7 additions and 0 deletions.
diff --git a/infra/stream/BufferingStreamReader.cpp b/infra/stream/BufferingStreamReader.cpp
@@ -1,4 +1,5 @@
 #include "infra/stream/BufferingStreamReader.hpp"
+#include "services/tracer/GlobalTracer.hpp"
 
 namespace infra
 {
@@ -103,6 +104,8 @@ namespace infra
         while (!input.Empty())
         {
             auto range = input.ExtractContiguousRange(std::numeric_limits<std::size_t>::max());
+            if (buffer.max_size() - buffer.size() < range.size())
+                services::GlobalTracer().Trace() << "StoreRemainder buffer size = " << buffer.size() << " max is " << buffer.max_size() << " adding " << range.size();
             buffer.insert(buffer.end(), range.begin(), range.end());
         }
     }

diff --git a/protobuf/echo/Echo.cpp b/protobuf/echo/Echo.cpp
@@ -1,4 +1,5 @@
 #include "protobuf/echo/Echo.hpp"
+#include "services/tracer/GlobalTracer.hpp"
 
 namespace services
 {
@@ -95,6 +96,7 @@ namespace services
 
     void EchoOnStreams::ReleaseReader()
     {
+        services::GlobalTracer().Trace() << "ReleaseReader, available = " << readerPtr->Available();
         readerAccess.SetAction(nullptr);
         bufferedReader = infra::none;
         readerPtr = nullptr;
@@ -161,6 +163,8 @@ namespace services
 
         if (stream.Failed())
         {
+            services::GlobalTracer().Trace() << "StartReceiveMessage stream failed, available = " << readerPtr->Available();
+
             bufferedReader->Rewind(start);
             bufferedReader = infra::none;
             readerPtr = nullptr;