Changeset 10919 for trunk/FACT++

Timestamp:

06/07/11 22:14:11 (13 years ago)

Author:

tbretz

Message:

Added local mutices to protect Write calls from different threads - the current implementation is even overprotective

Location:

trunk/FACT++/src

Files:

• MessageDim.cc (modified) (3 diffs)
• MessageImp.cc (modified) (3 diffs)

trunk/FACT++/src/MessageDim.cc

@@ -1 +1 @@
 #include "MessageDim.h"
+
+#include <mutex>
 
 #include "tools.h"
@@ -66 +68 @@
 int MessageDimTX::Write(const Time &t, const string &txt, int qos)
 {
+    static mutex mtx;
+
+    mtx.lock();
+
     MessageImp::Write(t, txt, qos);
 
@@ -77 +83 @@
         Out() << " !! " << t.GetAsStr() << " - Sending failed!" << endl;
 
+    mtx.unlock();
+
     return rc;
 }
-
-
 
 // **************************************************************************

trunk/FACT++/src/MessageImp.cc

@@ -13 +13 @@
 
 #include <stdarg.h>
+
+#include <mutex>
 
 #include "tools.h"
@@ -105 +107 @@
 int MessageImp::Write(const Time &time, const string &txt, int severity)
 {
+    static mutex mtx;
+
+    mtx.lock();
+
     switch (severity)
     {
@@ -116 +122 @@
     }
     fOut << time.GetAsStr() << " - " << txt << endl;
+
+    mtx.unlock();
 
     return 0;