プロジェクト

全般

プロフィール

操作
リンクをコピー

バグ #2178

完了

onInitializeやonActivated、onExecuteなどが例外を投げたときのリスナーについて

kurihara さんが13年以上前に追加. 13年以上前に更新.

ステータス:
終了
優先度:
通常
担当者:
-
対象バージョン:
-
開始日:
2011/06/29
期日:
進捗率:

100%

予定工数:

説明

株式会社　小田桐様からの報告

onInitializeやonActivated、onExecuteなどが例外を投げたとき、
登録しているPostComponentActionListenerが呼び出されません。
onExecuteなどが戻り値でエラーを返した場合は、
PostComponentActionListenerが呼び出されるため、
例外を投げた場合でもPostComponentActionListenerは
呼び出された方が良いと思います。
操作
リンクをコピー
 #1

kurihara さんが13年以上前に更新

  • プロジェクト を OpenRTM-aist から OpenRTM-aist (C++) に変更
操作
リンクをコピー
 #2

n-ando さんが13年以上前に更新

  • ステータス を 新規 から 終了 に変更
  • 進捗率 を 0 から 100 に変更

onXXX()で例外が発生した場合も、戻り値RTC::ERRORとしてコールバックが呼ばれるように修正した。

--- RTObject.cpp    (revision 2191)
+++ RTObject.cpp    (working copy)
@@ -780,23 +780,23 @@
       {
         preOnInitialize(0);
         ret = onInitialize();
-        postOnInitialize(0, ret);
-        std::string active_set;
-        active_set = m_properties.getProperty("configuration.active_config",
-                                              "default");
-        if (m_configsets.haveConfig(active_set.c_str()))
-          {
-            m_configsets.update(active_set.c_str());
-          }
-        else
-          {
-            m_configsets.update("default");
-          }
       }
     catch (...)
       {
-    return RTC::RTC_ERROR;
+    ret = RTC::RTC_ERROR;
       }
+    std::string active_set;
+    active_set = m_properties.getProperty("configuration.active_config",
+                                          "default");
+    if (m_configsets.haveConfig(active_set.c_str()))
+      {
+        m_configsets.update(active_set.c_str());
+      }
+    else
+      {
+        m_configsets.update("default");
+      }
+    postOnInitialize(0, ret);
     return ret;
   }

@@ -816,12 +816,12 @@
       {
         preOnFinalize(0);
     ret = onFinalize();
-        postOnFinalize(0, ret);
       }
     catch (...)
       {
-    return RTC::RTC_ERROR;
+    ret = RTC::RTC_ERROR;
       }
+    postOnFinalize(0, ret);
     return ret;
   }

@@ -841,12 +841,12 @@
       {
         preOnStartup(ec_id);
     ret = onStartup(ec_id);
-        postOnStartup(ec_id, ret);
       }
     catch (...)
       {
-    return RTC::RTC_ERROR;
+    ret = RTC::RTC_ERROR;
       }
+    postOnStartup(ec_id, ret);
     return ret;
   }

@@ -866,12 +866,12 @@
       {
         preOnShutdown(ec_id);
     ret = onShutdown(ec_id);
-        postOnShutdown(ec_id, ret);
       }
     catch (...)
       {
-    return RTC::RTC_ERROR;
+    ret = RTC::RTC_ERROR;
       }
+    postOnShutdown(ec_id, ret);
     return ret;
   }

@@ -893,12 +893,12 @@
     m_configsets.update();
     ret = onActivated(ec_id);
         m_portAdmin.activatePorts();
-        postOnActivated(ec_id, ret);
       }
     catch (...)
       {
-    return RTC::RTC_ERROR;
+    ret = RTC::RTC_ERROR;
       }
+    postOnActivated(ec_id, ret);
     return ret;
   }

@@ -919,12 +919,12 @@
         preOnDeactivated(ec_id);
         m_portAdmin.deactivatePorts();
     ret = onDeactivated(ec_id);
-        postOnDeactivated(ec_id, ret);
       }
     catch (...)
       {
-    return RTC::RTC_ERROR;
+    ret = RTC::RTC_ERROR;
       }
+    postOnDeactivated(ec_id, ret);
     return ret;
   }

@@ -944,12 +944,12 @@
       {
         preOnAborting(ec_id);
     ret = onAborting(ec_id);
-        postOnAborting(ec_id, ret);
       }
     catch (...)
       {
-    return RTC::RTC_ERROR;
+    ret = RTC::RTC_ERROR;
       }
+    postOnAborting(ec_id, ret);
     return ret;
   }

@@ -969,13 +969,13 @@
       {
         preOnError(ec_id);
     ret = onError(ec_id);
-    m_configsets.update();
-        postOnError(ec_id, ret);
       }
     catch (...)
       {
-    return RTC::RTC_ERROR;
+    ret = RTC::RTC_ERROR;
       }
+    m_configsets.update();
+    postOnError(ec_id, ret);
     return ret;
   }

@@ -995,12 +995,12 @@
       {
         preOnReset(ec_id);
     ret = onReset(ec_id);
-        postOnReset(ec_id, ret);
       }
     catch (...)
       {
-    return RTC::RTC_ERROR;
+    ret = RTC::RTC_ERROR;
       }
+    postOnReset(ec_id, ret);
     return ret;
   }

@@ -1023,12 +1023,12 @@
     if (m_readAll) {readAll(); }
     ret = onExecute(ec_id);
     if (m_writeAll) { writeAll();}
-        postOnExecute(ec_id, ret);
       }
     catch (...)
       {
-    return RTC::RTC_ERROR;
+    ret = RTC::RTC_ERROR;
       }
+    postOnExecute(ec_id, ret);
     return ret;
   }

@@ -1050,12 +1050,12 @@
         preOnStateUpdate(ec_id);
     ret = onStateUpdate(ec_id);
     m_configsets.update();
-        postOnStateUpdate(ec_id, ret);
       }
     catch (...)
       {
-    return RTC::RTC_ERROR;
+    ret = RTC::RTC_ERROR;
       }
+    postOnStateUpdate(ec_id, ret);
     return ret;
   }

@@ -1075,12 +1075,12 @@
       {
         preOnRateChanged(ec_id);
     ret = onRateChanged(ec_id);
-        postOnRateChanged(ec_id, ret);
       }
     catch (...)
       {
-    return RTC::RTC_ERROR;
+    ret = RTC::RTC_ERROR;
       }
+    postOnRateChanged(ec_id, ret);
     return ret;
   }

操作
リンクをコピー

他の形式にエクスポート: Atom PDF