From: Mathias Froehlich <Mathias.Froehlich@web.de>
Date: Thu, 8 Nov 2012 20:31:16 +0000 (+0100)
Subject: hla: catch exceptions in processMessages()
X-Git-Url: https://git.mxchange.org/?a=commitdiff_plain;h=8c57a77d7efd8562b7622f261d97b8621ed0c4ae;p=simgear.git

hla: catch exceptions in processMessages()
---

diff --git a/simgear/hla/RTI13Federate.cxx b/simgear/hla/RTI13Federate.cxx
index 154a3b33..1a46cfdb 100644
--- a/simgear/hla/RTI13Federate.cxx
+++ b/simgear/hla/RTI13Federate.cxx
@@ -1566,7 +1566,7 @@ RTI13Federate::queryLITS(SGTimeStamp& timeStamp)
 bool
 RTI13Federate::processMessage()
 {
-    bool result = _ambassador->tick();
+    bool result = _tick();
     _federateAmbassador->processQueues();
     return result;
 }
@@ -1574,18 +1574,65 @@ RTI13Federate::processMessage()
 bool
 RTI13Federate::processMessages(const double& minimum, const double& maximum)
 {
-    bool result = _ambassador->tick(minimum, 0);
+    bool result = _tick(minimum, 0);
     _federateAmbassador->processQueues();
     if (!result)
         return false;
     SGTimeStamp timeStamp = SGTimeStamp::now() + SGTimeStamp::fromSec(maximum);
     do {
-        result = _ambassador->tick(0, 0);
+        result = _tick(0, 0);
         _federateAmbassador->processQueues();
     } while (result && SGTimeStamp::now() <= timeStamp);
     return result;
 }
 
+bool
+RTI13Federate::_tick()
+{
+    if (!_ambassador.valid()) {
+        SG_LOG(SG_NETWORK, SG_WARN, "RTI: Ambassador is zero while calling _tick().");
+        return false;
+    }
+
+    try {
+        return _ambassador->tick();
+    } catch (RTI::SpecifiedSaveLabelDoesNotExist& e) {
+        SG_LOG(SG_NETWORK, SG_WARN, "RTI: Specified save label does not exist: " << e._name << " " << e._reason);
+        return false;
+    } catch (RTI::ConcurrentAccessAttempted& e) {
+        SG_LOG(SG_NETWORK, SG_WARN, "RTI: Concurrent access attempted: " << e._name << " " << e._reason);
+        return false;
+    } catch (RTI::RTIinternalError& e) {
+        SG_LOG(SG_NETWORK, SG_WARN, "RTI: Internal error: " << e._name << " " << e._reason);
+        return false;
+    }
+    return false;
+}
+
+bool
+RTI13Federate::_tick(const double& minimum, const double& maximum)
+{
+    if (!_ambassador.valid()) {
+        SG_LOG(SG_NETWORK, SG_WARN, "RTI: Ambassador is zero while calling _tick().");
+        return false;
+    }
+
+    try {
+        return _ambassador->tick(minimum, maximum);
+    } catch (RTI::SpecifiedSaveLabelDoesNotExist& e) {
+        SG_LOG(SG_NETWORK, SG_WARN, "RTI: Specified save label does not exist: " << e._name << " " << e._reason);
+        return false;
+    } catch (RTI::ConcurrentAccessAttempted& e) {
+        SG_LOG(SG_NETWORK, SG_WARN, "RTI: Concurrent access attempted: " << e._name << " " << e._reason);
+        return false;
+    } catch (RTI::RTIinternalError& e) {
+        SG_LOG(SG_NETWORK, SG_WARN, "RTI: Internal error: " << e._name << " " << e._reason);
+        return false;
+    }
+    return false;
+}
+
+
 RTI13ObjectClass*
 RTI13Federate::createObjectClass(const std::string& objectClassName, HLAObjectClass* hlaObjectClass)
 {
diff --git a/simgear/hla/RTI13Federate.hxx b/simgear/hla/RTI13Federate.hxx
index 83878ad0..ac6c5855 100644
--- a/simgear/hla/RTI13Federate.hxx
+++ b/simgear/hla/RTI13Federate.hxx
@@ -78,6 +78,10 @@ public:
     virtual bool processMessage();
     virtual bool processMessages(const double& minimum, const double& maximum);
 
+    // helper functions for the above
+    bool _tick();
+    bool _tick(const double& minimum, const double& maximum);
+
     virtual RTI13ObjectClass* createObjectClass(const std::string& name, HLAObjectClass* hlaObjectClass);
     virtual RTI13InteractionClass* createInteractionClass(const std::string& name, HLAInteractionClass* interactionClass);