Changeset 281 in pacpusframework for trunk

Timestamp:

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

Author:

Marek Kurdej

Message:

Transporting and catching exceptions in threads.

Location:

trunk

Files:

• include/Pacpus/kernel/ComponentBase.h (modified) (2 diffs)
• src/PacpusLib/ComponentBase.cpp (modified) (3 diffs)

trunk/include/Pacpus/kernel/ComponentBase.h

@@ -38 +38 @@
 class QWidget;
 
-namespace boost {
-namespace program_options {
+namespace boost
+{
+class exception_ptr;
+
+namespace program_options
+{
     class options_description_easy_init;
-}
-}
+} // namespace program_options
+
+} // namespace boost
 
 namespace pacpus {
@@ -200 +205 @@
     /// called by the ComponentManager to start the component
     int startComponent();
+    void startComponentInThread();
+    void startComponentWithException(boost::exception_ptr& error);
 
     /// called by the ComponentManager to stop the component

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;