Changeset 281 in pacpusframework for trunk/src/PacpusLib/ComponentBase.cpp

Timestamp:

Mar 20, 2014, 2:35:01 PM (11 years ago)

Author:

Marek Kurdej

Message:

Transporting and catching exceptions in threads.

File:

• trunk/src/PacpusLib/ComponentBase.cpp (modified) (3 diffs)

trunk/src/PacpusLib/ComponentBase.cpp

@@ -11 +11 @@
 #include <Pacpus/kernel/PacpusException.h>
 
+#include <boost/bind/bind.hpp>
+#include <boost/exception/detail/exception_ptr.hpp>
+#include <boost/exception/diagnostic_information.hpp>
+#include <boost/exception/exception.hpp>
 #include <boost/program_options/parsers.hpp>
 #include <boost/program_options/variables_map.hpp>
@@ -127 +131 @@
 }
 
+void ComponentBase::startComponentWithException(boost::exception_ptr& error)
+{
+    try {
+        startActivity();
+        error = boost::exception_ptr();
+    } catch (...) {
+        error = boost::current_exception();
+    }
+}
+
+void ComponentBase::startComponentInThread()
+{
+    boost::exception_ptr error;
+    boost::thread t(
+        boost::bind(
+            &ComponentBase::startComponentWithException,
+            this,
+            boost::ref(error)
+        )
+    );
+    t.join();
+    if (error) {
+        try {
+            boost::rethrow_exception(error);
+        } catch (boost::exception& e) {
+            LOG_FATAL("[" << getName() << "]" << "\tboost::exception thrown: " << boost::diagnostic_information(e));
+            //throw;
+        }
+    }
+}
+
 int ComponentBase::startComponent()
 {
@@ -135 +170 @@
 
     setActive(true);
-    boost::thread worker(&ComponentBase::startActivity, this);
+    boost::thread worker(&ComponentBase::startComponentInThread, this);
+    //boost::thread worker(&ComponentBase::startActivity, this);
     //startActivity();
     return true;