os/impl/LogForwarder: Do not use a static Bottle

When the `forward` method is called twice, the `Bottle::clear()` method could be called before the message is sent, hence deleting the bottle being sent. This fixes the `LogForwarder` skipping messages when messages are sent too quickly (Fixes #2643).
robotology · Aug 2, 2021 · 63a1e8e · 63a1e8e
1 parent fb23c99
commit 63a1e8e
Show file tree

Hide file tree

Showing 3 changed files with 15 additions and 8 deletions.
diff --git a/doc/release/yarp_3_5/LogForwarder_static_Bottle.md b/doc/release/yarp_3_5/LogForwarder_static_Bottle.md
@@ -0,0 +1,9 @@
+LogForwarder_static_Bottle {#yarp-3.5}
+--------------------------
+
+### Libraries
+
+#### `os`
+
+* The `LogForwarder` no longer skips messages when messages are sent too
+  quickly (#2643).
diff --git a/src/libYARP_os/src/yarp/os/impl/LogForwarder.cpp b/src/libYARP_os/src/yarp/os/impl/LogForwarder.cpp
@@ -37,7 +37,6 @@ yarp::os::impl::LogForwarder::LogForwarder()
     if (!outputPort.open(logPortName)) {
         printf("LogForwarder error while opening port %s\n", logPortName.c_str());
     }
-    outputPort.enableBackgroundWrite(true);
     outputPort.addOutput("/yarplogger", "fast_tcp");
 
     started = true;
@@ -46,12 +45,12 @@ yarp::os::impl::LogForwarder::LogForwarder()
 void yarp::os::impl::LogForwarder::forward(const std::string& message)
 {
     mutex.lock();
-    static Bottle b;
+    Bottle& b = outputPort.prepare();
     b.clear();
     std::string port = "[" + outputPort.getName() + "]";
     b.addString(port);
     b.addString(message);
-    outputPort.write(b);
+    outputPort.writeStrict();
     mutex.unlock();
 }
 
@@ -68,9 +67,7 @@ void yarp::os::impl::LogForwarder::shutdown()
 
         yarp::os::impl::LogForwarder& fw = getInstance();
         fw.forward(ost.str());
-        while (fw.outputPort.isWriting()) {
-            yarp::os::SystemClock::delaySystem(0.2);
-        }
+        fw.outputPort.waitForWrite();
         fw.outputPort.interrupt();
         fw.outputPort.close();
     }

diff --git a/src/libYARP_os/src/yarp/os/impl/LogForwarder.h b/src/libYARP_os/src/yarp/os/impl/LogForwarder.h
@@ -8,7 +8,8 @@
 
 #include <yarp/os/api.h>
 
-#include <yarp/os/Port.h>
+#include <yarp/os/Bottle.h>
+#include <yarp/os/BufferedPort.h>
 
 #include <mutex>
 #include <string>
@@ -32,7 +33,7 @@ class YARP_os_impl_API LogForwarder
     LogForwarder& operator=(LogForwarder const&) = delete;
 
     std::mutex mutex;
-    yarp::os::Port outputPort;
+    yarp::os::BufferedPort<yarp::os::Bottle> outputPort;
     static bool started;
 };