Compilation on Windows

[modules/yacs.git] / src / engine / OutGate.cxx

diff --git a/src/engine/OutGate.cxx b/src/engine/OutGate.cxx
index 3781918fd9d98f5acd582652ac8851b2429a16dc..758b2b104f4855d7ecd3c5aed3a31bf30601a72a 100644 (file)
--- a/src/engine/OutGate.cxx
+++ b/src/engine/OutGate.cxx
@@ -1,6 +1,28 @@
+// Copyright (C) 2006-2013  CEA/DEN, EDF R&D
+//
+// This library is free software; you can redistribute it and/or
+// modify it under the terms of the GNU Lesser General Public
+// License as published by the Free Software Foundation; either
+// version 2.1 of the License.
+//
+// This library is distributed in the hope that it will be useful,
+// but WITHOUT ANY WARRANTY; without even the implied warranty of
+// MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the GNU
+// Lesser General Public License for more details.
+//
+// You should have received a copy of the GNU Lesser General Public
+// License along with this library; if not, write to the Free Software
+// Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA  02111-1307 USA
+//
+// See http://www.salome-platform.org/ or email : webmaster.salome@opencascade.com
+//
+
 #include "OutGate.hxx"
 #include "InGate.hxx"
 
+//#define _DEVDEBUG_
+#include "YacsTrace.hxx"
+
 using namespace YACS::ENGINE;
 using namespace std;
 
@@ -15,63 +37,108 @@ string OutGate::getNameOfTypeOfCurrentInstance() const
   return NAME;
 }
 
+void OutGate::exReset()
+{
+  for(map<InGate *, bool>::iterator iter=_setOfInGate.begin();iter!=_setOfInGate.end();iter++)
+    (*iter).second=false;
+}
+
+//! Notify this port that its node is finished
+/*!
+ *  Calls (notify) all the connected ingates : InGate::exNotifyFromPrecursor
+ *
+ *  Called by Bloc::updateStateOnFinishedEventFrom
+ */
+
 void OutGate::exNotifyDone()
 {
-  for(set<InGate *>::iterator iter=_setOfInGate.begin();iter!=_setOfInGate.end();iter++)
-    (*iter)->exNotifyFromPrecursor();
+  DEBTRACE("OutGate::exNotifyDone");
+  for(map<InGate *, bool>::iterator iter=_setOfInGate.begin();iter!=_setOfInGate.end();iter++)
+    (*iter).first->exNotifyFromPrecursor(this);
+}
+
+//! Notify this port that its node has failed
+/*!
+ *
+ */
+void OutGate::exNotifyFailed()
+{
+  for(map<InGate *, bool>::iterator iter=_setOfInGate.begin();iter!=_setOfInGate.end();iter++)
+    (*iter).first->exNotifyFailed();
+}
+
+//! Notify this port that its node has been disabled
+/*!
+ *
+ */
+void OutGate::exNotifyDisabled()
+{
+  for(map<InGate *, bool>::iterator iter=_setOfInGate.begin();iter!=_setOfInGate.end();iter++)
+    (*iter).first->exNotifyDisabled();
+}
+
+void OutGate::edDisconnectAllLinksFromMe()
+{
+  for(map<InGate *, bool>::iterator iter=_setOfInGate.begin();iter!=_setOfInGate.end();iter++)
+    (*iter).first->edRemovePrecursor(this);
+  _setOfInGate.clear();
 }
 
 bool OutGate::edAddInGate(InGate *inGate)
 {
   if(!isAlreadyInSet(inGate))
     {
-      inGate->edAppendPrecursor();
-      _setOfInGate.insert(inGate);
+      inGate->edAppendPrecursor(this);
+      _setOfInGate[inGate]=false;
+      modified();
+      inGate->modified();
       return true;
     }
   else
     return false;
 }
 
-set<InGate *> OutGate::edSetInGate() const
+std::set<InGate *> OutGate::edSetInGate() const
 {
-  return _setOfInGate;
+  set<InGate *> ret;
+  for(map<InGate *, bool>::const_iterator iter=_setOfInGate.begin();iter!=_setOfInGate.end();iter++)
+    ret.insert((*iter).first);
+  return ret;
 }
 
-void OutGate::edRemoveInGate(InGate *inGate) throw(Exception)
+void OutGate::edRemoveInGate(InGate *inGate, bool coherenceWithInGate) throw(YACS::Exception)
 {
-  bool found=false;
-  for(set<InGate *>::iterator iter=_setOfInGate.begin();iter!=_setOfInGate.end() && !found;iter++)
-    if((*iter)==inGate)
-      {
-       _setOfInGate.erase(iter);
-       inGate->edRemovePrecursor();
-       found=true;
-      }
-  if(!found)
+  std::map< InGate* , bool >::iterator iter=_setOfInGate.find(inGate);
+  if(iter==_setOfInGate.end())
     throw Exception("InGate not already connected to OutGate");
+  else
+    {
+      if(coherenceWithInGate)
+        inGate->edRemovePrecursor(this);
+      _setOfInGate.erase(iter);
+      inGate->modified();
+      modified();
+    }
 }
 
-//Idem OutGate::edRemoveInGateOneWay except that no exception thrown if CF not exists
+//Idem OutGate::edRemoveInGate except that no exception thrown if CF not exists
 void OutGate::edRemoveInGateOneWay(InGate *inGate)
 {
   bool found=false;
-  for(set<InGate *>::iterator iter=_setOfInGate.begin();iter!=_setOfInGate.end() && !found;iter++)
-    if((*iter)==inGate)
+  for(map<InGate *, bool>::iterator iter=_setOfInGate.begin();iter!=_setOfInGate.end() && !found;iter++)
+    if((*iter).first==inGate)
       {
-       _setOfInGate.erase(iter);
-       inGate->edRemovePrecursor();
-       found=true;
+        _setOfInGate.erase(iter);
+        inGate->edRemovePrecursor(this);
+        found=true;
+        modified();
+        inGate->modified();
       }
 }
 
 bool OutGate::isAlreadyInSet(InGate *inGate) const
 {
-  bool ret=false;
-  for(set<InGate *>::const_iterator iter=_setOfInGate.begin();iter!=_setOfInGate.end() && !ret;iter++)
-    if((*iter)==inGate)
-      ret=true;
-  return ret;
+  return _setOfInGate.find(inGate)!=_setOfInGate.end();
 }
 
 int OutGate::getNbOfInGatesConnected() const