* Major changes on IOStatus update / propagation

[bbtk.git] / kernel / src / bbtkConnection.cxx

diff --git a/kernel/src/bbtkConnection.cxx b/kernel/src/bbtkConnection.cxx
index 0b8fb9c11dc890b0ee3ffe9b5a24d491a9828e07..51538159f28d03e9d3981c014f53104e1ecbde7b 100644 (file)
--- a/kernel/src/bbtkConnection.cxx
+++ b/kernel/src/bbtkConnection.cxx
@@ -2,8 +2,8 @@
   Program:   bbtk
   Module:    $RCSfile: bbtkConnection.cxx,v $
   Language:  C++
-  Date:      $Date: 2008/10/17 08:18:13 $
-  Version:   $Revision: 1.15 $
+  Date:      $Date: 2008/12/08 12:54:19 $
+  Version:   $Revision: 1.16 $
 =========================================================================*/
 
 /* ---------------------------------------------------------------------
@@ -37,9 +37,16 @@
 #include "bbtkFactory.h"
 #include "bbtkBlackBox.h"
 #include "bbtkMessageManager.h"
+#include "bbtkBlackBoxOutputConnector.h"
 
 namespace bbtk
 {
+  const std::string IOSTATUS_STRING[3] = 
+    {"Up-to-date","Modified","Out-of-date"}; 
+  
+  const std::string& GetIOStatusString(IOStatus s)
+  { return IOSTATUS_STRING[s]; }
+
   //==================================================================
   Connection::Pointer Connection::New(BlackBox::Pointer from, 
                                      const std::string& output,
@@ -160,6 +167,8 @@ Connection::Connection(BlackBox::Pointer from, const std::string& output,
     //Pointer p = MakePointer(this,true);
     from->bbConnectOutput(output,this);
     to->bbConnectInput(input,this);
+ 
+    from->bbGetOutputConnector(output).AddChangeObserver(boost::bind(&bbtk::Connection::OnOutputChange,this, _1, _2, _3));
 
     
     bbtkDebugMessage("connection",1,"<== Connection::Connection(\""
@@ -278,6 +287,7 @@ Connection::Connection(BlackBox::Pointer from, const std::string& output,
     from->bbConnectOutput(output,this);
     to->bbConnectInput(input,this);
 
+    from->bbGetOutputConnector(output).AddChangeObserver(boost::bind(&bbtk::Connection::OnOutputChange,this, _1, _2, _3));
     
     bbtkDebugMessage("connection",1,"<== Connection::Connection(\""
                     <<from->bbGetFullName()<<"\",\""<<output<<"\",\""
@@ -329,23 +339,26 @@ Connection::Connection(BlackBox::Pointer from, const std::string& output,
   
   //==================================================================
   /// Backward Update
-  IOStatus Connection::BackwardUpdate()
+  void Connection::BackwardUpdate()
   {
     bbtkDebugMessage("process",5,
                     "===> Connection::BackwardUpdate() ["
                     <<GetFullName()<<"]"<<std::endl);
 
-    IOStatus s = UPTODATE;
-    s = mFrom->bbBackwardUpdate(GetThisPointer<Connection>());
+    mFrom->bbBackwardUpdate(GetThisPointer<Connection>());
 
     TransferData();
 
-    if (mAdaptor && (s==MODIFIED)) mAdaptor->bbSetModifiedStatus();
+    // Transfer status
+    IOStatus s = MODIFIED;
+    if ( mFrom->bbGetOutputConnector(mOutput).GetStatus() == OUTOFDATE) 
+      s = OUTOFDATE,
+    mTo->bbGetInputConnector(mInput).SetStatus(s);
 
     bbtkDebugMessage("process",5,
                     "<=== Connection::BackwardUpdate() ["
                     <<GetFullName()<<"]"<<std::endl);
-    return s;
+    return; // s;
   }
   //==================================================================
 
@@ -481,6 +494,7 @@ Connection::Connection(BlackBox::Pointer from, const std::string& output,
   }
   //==================================================================
   
+  /*
   //==================================================================
   /// Modified
   void Connection::SetModifiedStatus()
@@ -493,11 +507,28 @@ Connection::Connection(BlackBox::Pointer from, const std::string& output,
     
     mTo->bbSetModifiedStatus(  mTo->bbGetInputConnectorMap().find(mInput)->second );
     
-    /*
-    bbtkDebugMessage("modified",2,
-                    "==> Connection::SetModifiedStatus() ["
+ 
+  }
+  //==================================================================
+  */
+  //==================================================================
+  /// From.Output change propagation
+  void Connection::OnOutputChange(bbtk::BlackBox::Pointer, const std::string&, 
+                                 IOStatus status)
+  {
+    bbtkDebugMessage("change",2,
+                    "==> Connection::OnOutputChange("<<status<<") ["
                     <<GetFullName()<<"]"<<std::endl);
-    */
+    
+    if (mAdaptor) 
+      {
+       BlackBoxInputConnector* ac = mAdaptor->bbGetInputConnectorMap().find("In")->second;
+       mAdaptor->bbSetStatusAndPropagate(ac,status);
+      }
+    
+    mTo->bbSetStatusAndPropagate( mTo->bbGetInputConnectorMap().find(mInput)->second, status);
+    
+ 
   }
   //==================================================================