From 4f1dd8760ad4442d24cc7e67092a9ac50a36ccd0 Mon Sep 17 00:00:00 2001
From: Karen Arutyunov <karen@codesynthesis.com>
Date: Thu, 23 Mar 2017 22:42:48 +0300
Subject: Fix diagnostics interleaving characters

---
 butl/diagnostics.cxx | 24 +++++++++++++++++++++++-
 1 file changed, 23 insertions(+), 1 deletion(-)

(limited to 'butl/diagnostics.cxx')

diff --git a/butl/diagnostics.cxx b/butl/diagnostics.cxx
index 7dc8bd0..b692777 100644
--- a/butl/diagnostics.cxx
+++ b/butl/diagnostics.cxx
@@ -4,6 +4,7 @@
 
 #include <butl/diagnostics>
 
+#include <mutex>
 #include <iostream> // cerr
 
 using namespace std;
@@ -12,6 +13,18 @@ namespace butl
 {
   ostream* diag_stream = &cerr;
 
+  static mutex diag_mutex;
+
+  diag_lock::diag_lock ()
+  {
+    diag_mutex.lock ();
+  }
+
+  diag_lock::~diag_lock ()
+  {
+    diag_mutex.unlock ();
+  }
+
   void diag_record::
   flush () const
   {
@@ -20,7 +33,16 @@ namespace butl
       if (epilogue_ == nullptr)
       {
         os.put ('\n');
-        *diag_stream << os.str ();
+
+        {
+          diag_lock l;
+          *diag_stream << os.str ();
+        }
+
+        // We can endup flushing the result of several writes. The last one may
+        // possibly be incomplete, but that's not a problem as it will also be
+        // followed by the flush() call.
+        //
         diag_stream->flush ();
 
         empty_ = true;
-- 
cgit v1.1