X-Git-Url: https://git.creatis.insa-lyon.fr/pubgit/?a=blobdiff_plain;f=kernel%2Fsrc%2FbbtkBlackBox.cxx;h=2e5716e3f9ba87e897ae7f3a69d7b10568af3743;hb=e746553dde41260204aae07b809f484544de10b9;hp=c21285cd6b136b7e4a7a96aaf92675ed61b561fd;hpb=6575a389b71b1b85c79e4444885becb76ecf16e4;p=bbtk.git

diff --git a/kernel/src/bbtkBlackBox.cxx b/kernel/src/bbtkBlackBox.cxx
index c21285c..2e5716e 100644
--- a/kernel/src/bbtkBlackBox.cxx
+++ b/kernel/src/bbtkBlackBox.cxx
@@ -2,8 +2,8 @@
   Program:   bbtk
   Module:    $RCSfile: bbtkBlackBox.cxx,v $
   Language:  C++
-  Date:      $Date: 2008/10/17 08:18:12 $
-  Version:   $Revision: 1.25 $
+  Date:      $Date: 2008/12/10 09:33:18 $
+  Version:   $Revision: 1.36 $
 =========================================================================*/
 
 /* ---------------------------------------------------------------------
@@ -36,6 +36,7 @@
 #include "bbtkPackage.h"
 #include "bbtkMessageManager.h"
 #include "bbtkFactory.h"
+#include "bbtkBlackBoxOutputConnector.h"
 
 #include "bbtkConfigurationFile.h"
 #include "bbtkWxBlackBox.h"
@@ -50,7 +51,7 @@ namespace bbtk
 
   static bool bbmgSomeBoxExecuting = false;
   static bool bbmgFreezeExecution = false;
-  static std::set<BlackBox::Pointer> bbmgExecutionList;
+  static std::set<BlackBox::WeakPointer> bbmgExecutionList;
 
   //=========================================================================
   BlackBox::Deleter::Deleter()
@@ -102,7 +103,8 @@ namespace bbtk
   //=========================================================================
   BlackBox::BlackBox(const std::string &name) 
     : 
-    bbmStatus(MODIFIED), 
+    //    bbmStatus(MODIFIED), 
+    bbmExecuting(false),
     bbmName(name),
     bbmBoxProcessMode("Pipeline"),
     bbmParent()
@@ -122,7 +124,8 @@ namespace bbtk
   //=========================================================================
   BlackBox::BlackBox(BlackBox& from, const std::string &name) 
     :
-      bbmStatus(from.bbmStatus), 
+    //    bbmStatus(from.bbmStatus), 
+      bbmExecuting(false),
       bbmName(name), 
       bbmBoxProcessMode(from.bbmBoxProcessMode),
       bbmParent()
@@ -155,9 +158,16 @@ namespace bbtk
   void BlackBox::bbExecute(bool force)
   {
     bbtkDebugMessageInc("process",2,
-			"=> BlackBox::bbExecute() ["
+			"=> BlackBox::bbExecute("<<(int)force<<") ["
 			<<bbGetFullName()<<"]"<<std::endl);
  
+    // If already executing : return
+    if (bbGetExecuting()) 
+      {
+	bbtkDebugMessage("process",2,
+			 " -> already executing : bailing out"<<std::endl);
+	return;
+      }
 
     // If execution frozen : return
     if (bbGlobalGetFreezeExecution()) 
@@ -169,7 +179,7 @@ namespace bbtk
     BBTK_BUSY_CURSOR;
 
     // If force is true then update is triggered even if the box is UPTODATE
-    if (force) bbSetModifiedStatus();
+    //    if (force) bbSetModifiedStatus();
 
     // Calls the main recursive update method 
     bbBackwardUpdate(Connection::Pointer());
@@ -334,7 +344,7 @@ namespace bbtk
   /// Copies the input / output values from another box
   void BlackBox::bbCopyIOValues(BlackBox& from)
   {
-    bbtkDebugMessageInc("Kernel",9,
+    bbtkDebugMessageInc("Kernel",1,
     			"BlackBox::bbCopyIOValues("
 			<<from.bbGetFullName()<<") ["
 			<<bbGetFullName()<<"]"<<std::endl);
@@ -346,6 +356,7 @@ namespace bbtk
       {		
 	if (! i->second->GetCopyConstruct() ) continue;
 	std::string input = i->second->GetName();
+	bbtkDebugMessage("Kernel",2,"* Copying input "<<input<<std::endl);
 	this->bbSetInput(input, from.bbGetInput(input) );
       }									
     // copies the output values
@@ -356,6 +367,7 @@ namespace bbtk
       {							
 	if (! o->second->GetCopyConstruct() ) continue;
 	std::string output = o->second->GetName();
+	bbtkDebugMessage("Kernel",2,"* Copying output "<<output<<std::endl);
 	this->bbSetOutput(output, from.bbGetOutput(output) );
       }
 
@@ -428,92 +440,199 @@ namespace bbtk
   }
   //=========================================================================
 
+
+
+
+  //=========================================================================
+  void BlackBox::bbAddOutputObserver(const std::string& output, 
+				   OutputChangeCallbackType f)
+  {
+    bbGetOutputConnector(output).AddChangeObserver(f);
+  }  
+  //=========================================================================
+
+  //=========================================================================
+  void BlackBox::bbRemoveOutputObserver(const std::string& output_name, 
+				      OutputChangeCallbackType f)
+  {
+    bbtkError("BlackBox::RemoveChangeObserver NOT IMPLEMENTED");
+  }
+  //=========================================================================
+
+
+  /*
   //=========================================================================
-  ///  Signals that the BlackBox has been modified
-  void BlackBox::bbSetModifiedStatus(BlackBoxInputConnector* c)
+  ///  Sets the ChangeTime of input 
+  void BlackBox::bbSetInputChangeTime(BlackBoxInputConnector* c, 
+				      const ChangeTime& t)
   {
-    bbtkDebugMessage("modified",1,
-		     "==> BlackBox::bbSetModifiedStatus("<<c<<") ["
+    bbtkDebugMessage("change",1,
+		     "==> BlackBox::bbSetInputChangeTime("<<c<<","<<t<<") ["
 		     <<bbGetFullName()<<"]"<<std::endl);
     
-    if ( (c==bbGetInputConnectorMap().find("WinHide")->second) )
-      //	 && (bbCanReact()))
+    // If new time is greater than old one
+    if ( c->SetChangeTime(t) ) 
       {
-	bbtkDebugMessage("modified",2,
-			 "-> Hide triggered by WinHide input change"
-			 <<std::endl);
-	this->bbHideWindow();
-	this->bbSetStatus(MODIFIED); 
-	return;
+	bool was_up_to_date = bbIsUpToDate();
+	// If new time is greater than the old max time of inputs
+	if ( mMaxInputChangeTime.Set(t) ) 
+	  {
+	    // If the box turned out-of-date
+	    if ( was_up_to_date && bbIsOutOfDate() )
+	      {
+		// 
+		if ( ( bbBoxProcessModeIsReactive()  ||
+		       (c==bbGetInputConnectorMap().find("BoxExecute")->second))
+		     && (bbCanReact() ) )
+		  {
+		    bbtkDebugMessage("change",2,
+				     "an input of "
+				     <<bbGetFullName()
+				     <<" changed and box is in Reactive mode or BoxExecute input changed : adding it to the global execution list"
+				     <<std::endl);
+		    bbGlobalAddToExecutionList( GetThisPointer<BlackBox>() );
+		  }
+    		// Have to propagate the modification to aval boxes
+		OutputConnectorMapType::iterator i;
+		for (i = bbGetOutputConnectorMap().begin();
+		     i != bbGetOutputConnectorMap().end();
+		     ++i)
+		  {
+		    i->second->SetChangeTime(t);
+		  }
+		// update the MinOutputChangeTime
+		mMinOutputChangeTime.Set(t);
+	      }
+	  }
       }
-    if ( (c==bbGetInputConnectorMap().find("WinClose")->second) )
-      //	 && (bbCanReact()))
+  }
+  //=========================================================================
+
+ //=========================================================================
+  ///  Sets the ChangeTime of output 
+  void BlackBox::bbSetOutputChangeTime(BlackBoxOutputConnector* c, 
+				       const ChangeTime& t)
+  {
+    bbtkDebugMessage("change",1,
+		     "==> BlackBox::bbSetOutputChangeTime("<<c<<","<<t<<") ["
+		     <<bbGetFullName()<<"]"<<std::endl);
+    
+    //ChangeTime old = 
+    c->SetChangeTime(t);
+    // c->GetChangeTime() = t;
+    //    bbUpdateMinOutputChangeTime(t);
+    // propagate
+    
+  }
+  //=========================================================================
+  */
+
+  /*
+  //=========================================================================
+  void BlackBox::bbUpdateMaxInputChangeTime(const ChangeTime& t)
+  {    
+
+    
+    if ( t > mMaxInputChangeTime ) 
       {
-	bbtkDebugMessage("modified",2,
-			 "-> Close triggered by WinClose input change"
-			 <<std::endl);
-	this->bbHideWindow();
-	this->bbSetStatus(MODIFIED); 
-	return;
+	mMaxInputChangeTime = t;
+	if ( mMinOutputChangeTime > mMaxInputChangeTime )
+	  {
+	    
+	  }
       }
     
+  }
+  //=========================================================================
+
+  //=========================================================================
+  void bbUpdateMinOutputChangeTime(const ChangeTime& t)
+  {
+    ChangeTime old = mMinOutputChangeTime;
+    mMinOutputChangeTime = MAXLONG;
+    OutputConnectorMapType::iterator i;
+    for (i = bbGetOutputConnectorMap.begin();
+	 i != bbGetOutputConnectorMap.end();
+	 ++i)
+      {
+	if (i->second->GetChangeTime() < mMinOutputChangeTime)
+	  mMinOutputChangeTime = i->second->GetChangeTime();
+      }
+    if ( mMinOutputChangeTime < old )
+      {
+      }
+   
+  }
+  //=========================================================================
+  */
+
+  //=========================================================================
+  /// Signals that the BlackBox has been modified through 
+  /// the input connector c
+  /// and propagates it downward
+  /// ** NOT USER INTENDED **
+  void BlackBox::bbSetStatusAndPropagate(BlackBoxInputConnector* c,
+					 IOStatus s)
+  {
+    bbtkDebugMessageInc("change",5,
+			"=> BlackBox::bbSetStatusAndPropagate(input,"
+			<<GetIOStatusString(s)<<") ["
+			<<bbGetFullName()<<"]"<<std::endl);
+
+    if (s==UPTODATE) bbtkError("bbSetStatusAndPropagate with status UPTODATE!");
+    c->SetStatus(s);
+    OutputConnectorMapType::const_iterator o;	
+    for ( o = bbGetOutputConnectorMap().begin(); 
+	  o != bbGetOutputConnectorMap().end(); ++o )			
+      {									
+	if (o->second->GetStatus()==UPTODATE) 
+	  {
+	    o->second->SetStatus(OUTOFDATE);
+	    o->second->SignalChange(GetThisPointer<BlackBox>(),o->first); 
+	  }
+      }									
+    
     if ( ( bbBoxProcessModeIsReactive()  ||
 	   (c==bbGetInputConnectorMap().find("BoxExecute")->second))
 	 && (bbCanReact() ) )
       {
-	bbtkDebugMessage("modified",2,
+	bbtkDebugMessage("change",2,
 			 "-> Execution triggered by Reactive mode or BoxExecute input change"<<std::endl);
-	this->bbSetStatus(MODIFIED); 
         bbGlobalAddToExecutionList( GetThisPointer<BlackBox>() );
-      }
-    /*
-    else if ( bbGetStatus() == MODIFIED ) //! this->bbIsUptodate()) 
-      { 
-	bbtkDebugMessage("modified",2,"-> Already modified"<<std::endl);
-	return;
-      }
-    */
-    else 
-      {
-	bbtkDebugMessage("modified",2,"-> Status set to modified"<<std::endl);
-	this->bbSetStatus(MODIFIED); 
-      }
- 
-    this->bbSignalOutputModification(false);
-
-    /* 
-  bbtkDebugMessageDec("process",5,
-			"<= BlackBox::bbSetModifiedStatus("<<c<<") ["
+      }    
+    bbtkDebugMessageInc("change",5,
+			"<= BlackBox::bbSetStatusAndPropagate(input) ["
 			<<bbGetFullName()<<"]"<<std::endl);
-    */
-  }  
+  }
   //=========================================================================
 
+
   //=========================================================================  
   void BlackBox::bbSignalOutputModification(bool reaction)
   {
-    bbtkDebugMessageInc("process",5,
-			"=> BlackBox::bbSignalOutputModification() ["
+    bbtkDebugMessageInc("change",5,
+			"=> BlackBox::bbSignalOutputModification("
+			<<reaction<<") ["
 			<<bbGetFullName()<<"]"<<std::endl);
     
-    OutputConnectorMapType::iterator change = bbGetOutputConnectorMap().end();
     OutputConnectorMapType::iterator i;
     for ( i  = bbGetOutputConnectorMap().begin(); 
-	  i != bbGetOutputConnectorMap().end(); ++i) {
-      /*     if ( i->first == "BoxChange" ) 
-	{
-	  change = i;
-	  continue;
-	}
-      */
-      i->second->SetModifiedStatus();
-    } 
-    //    if (change != bbGetOutputConnectorMap().end()) 
-    // change->second->SetModifiedStatus();
+	  i != bbGetOutputConnectorMap().end(); ++i) 
+      {
+	//	std::cout << "Stat = "
+	//<<GetIOStatusString(i->second->GetStatus())
+	//		  <<std::endl;
+	// LG : CANNOT SIGNAL ONLY WHEN UPTODATE 
+	// See bbtkSampleOutputObserver
+	//	if (i->second->GetStatus()==UPTODATE) 
+	//	  {
+	    i->second->SignalChange(GetThisPointer<BlackBox>(),i->first); 
+	    //	  }
+      } 
 
     if (reaction) bbGlobalProcessExecutionList();
 
-    bbtkDebugMessageDec("process",5,
+    bbtkDebugMessageDec("change",5,
 			"<= BlackBox::bbSignalOutputModification() ["
 			<<bbGetFullName()<<"]"<<std::endl);
     
@@ -521,46 +640,54 @@ namespace bbtk
   //=========================================================================   
   //=========================================================================  
   void BlackBox::bbSignalOutputModification(const std::string& output,
-	bool reaction)
+					    bool reaction)
   {
-    bbtkDebugMessageInc("process",5,
+    bbtkDebugMessageInc("change",5,
 			"=> BlackBox::bbSignalOutputModification("
-			<<output<<") ["
+			<<output<<","<<reaction<<") ["
 			<<bbGetFullName()<<"]"<<std::endl);
     
-    OutputConnectorMapType::iterator i = bbGetOutputConnectorMap().find(output);
+    OutputConnectorMapType::iterator i = 
+      bbGetOutputConnectorMap().find(output);
+
+
     if ( i == bbGetOutputConnectorMap().end() ) 
 	{
 	  bbtkError("BlackBox["<<bbGetFullName()<<"]::bbSignalOutputModification("<<output<<") : unknown output");
 	}
-    i->second->SetModifiedStatus();
-    // Has to notify the output "BoxChange" also
-    if (output != "BoxChange") 
-      {
-	i = bbGetOutputConnectorMap().find("BoxChange");
-	if ( i != bbGetOutputConnectorMap().end() ) 
+
+    //    if (i->second->GetStatus()==UPTODATE) 
+    //      {
+	i->second->SignalChange(GetThisPointer<BlackBox>(),i->first); 
+	// Has to notify the output "BoxChange" also
+	if (output != "BoxChange") 
 	  {
-	    i->second->SetModifiedStatus();
+	    i = bbGetOutputConnectorMap().find("BoxChange");
+	    if ( i != bbGetOutputConnectorMap().end() ) 
+	      {
+		i->second->SignalChange(GetThisPointer<BlackBox>(),i->first); 
+	      }
 	  }
-      }
-  if (reaction) bbGlobalProcessExecutionList();
-
-  bbtkDebugMessageDec("process",5,
-                      "<= BlackBox::bbSignalOutputModification("
-                      <<output<<") ["
-                      <<bbGetFullName()<<"]"<<std::endl);
+	if (reaction) bbGlobalProcessExecutionList();
+	//      }
 
+    bbtkDebugMessageDec("change",5,
+			"<= BlackBox::bbSignalOutputModification("
+			<<output<<") ["
+			<<bbGetFullName()<<"]"<<std::endl);
+    
   }  
   //=========================================================================   
   //=========================================================================  
   void BlackBox::bbSignalOutputModification(const std::vector<std::string>& output,
 	bool reaction)
   {
-    bbtkDebugMessageInc("process",5,
+    bbtkDebugMessageInc("change",5,
 			"=> BlackBox::bbSignalOutputModification(vector of outputs) ["
 			<<bbGetFullName()<<"]"<<std::endl);
     OutputConnectorMapType::iterator i;
     std::vector<std::string>::const_iterator o;
+    bool changed = false;
     for (o=output.begin();o!=output.end();++o) 
       {
 	// the output "BoxChange" must be signaled **AFTER** all others
@@ -571,18 +698,26 @@ namespace bbtk
 	  {
 	    bbtkError("BlackBox["<<bbGetFullName()<<"]::bbSignalOutputModification("<<*o<<") : unknown output");
 	  }
-	i->second->SetModifiedStatus();
+
+	//	if (i->second->GetStatus()==UPTODATE)
+	//	  {
+	    i->second->SignalChange(GetThisPointer<BlackBox>(),i->first); 
+	    changed = true;
+	    //  }
       }
     // Has to notify the output "BoxChange" also
     i = bbGetOutputConnectorMap().find("BoxChange");
-    if ( i != bbGetOutputConnectorMap().end() ) 
+    if ( changed && (i != bbGetOutputConnectorMap().end())) 
       {
-	i->second->SetModifiedStatus();
+	// if (i->second->GetStatus()==UPTODATE) 
+	//	  {
+	    i->second->SignalChange(GetThisPointer<BlackBox>(),i->first); 
+	    if (reaction) bbGlobalProcessExecutionList();
+	    //  }
       }
-  if (reaction) bbGlobalProcessExecutionList();
 
-   bbtkDebugMessageDec("process",5,
-		       "<= BlackBox::bbSignalOutputModification(vector of outputs) ["
+    bbtkDebugMessageDec("change",5,
+			"<= BlackBox::bbSignalOutputModification(vector of outputs) ["
 			<<bbGetFullName()<<"]"<<std::endl);
 
   }  
@@ -590,9 +725,9 @@ namespace bbtk
 
   //=========================================================================
   /// Updates the BlackBox inputs
-  /// \returns UPTODATE if all inputs are in UPTODATE status after update
-  ///          else MODIFIED 
-  IOStatus BlackBox::bbUpdateInputs(bool excludeParent)
+  /// Calls BackwardUpdate on all BlackBoxInputConnector
+  /// \returns The maximum of final IOStatus after each input update
+  IOStatus BlackBox::bbUpdateInputs()
   {
     bbtkDebugMessageInc("process",4,
 			"=> BlackBox::bbUpdateInputs() ["
@@ -605,28 +740,85 @@ namespace bbtk
     for ( i = bbGetInputConnectorMap().begin(); 
 	  i!= bbGetInputConnectorMap().end(); ++i) 
       {
-	if (excludeParent && (i->first=="WinParent")) continue;
-	if (i->first=="WinHide") continue;
+	//	if (i->first=="WinHide") continue;
 	// If input type is Void : no recurse
 	//if (  bbGetDescriptor()->GetInputDescriptor(i->first)->GetTypeInfo() 
 	//      == typeid(Void) ) 
 	//  continue;
-
-	IOStatus t = i->second->BackwardUpdate();
-	if (t==MODIFIED) s = MODIFIED;
+	bbtkDebugMessageDec("change",2,
+			    bbGetName()<<"."<<i->first
+			    <<" ["<<i->second<<"] "
+			    <<" status before update = '"
+			    <<GetIOStatusString(i->second->GetStatus())
+			    <<"'"<<std::endl);
+	i->second->BackwardUpdate();
+	IOStatus t = i->second->GetStatus();
+	if (t > s) s = t;
+	bbtkDebugMessageDec("change",2,
+			    bbGetName()<<"."<<i->first
+			    <<" ["<<i->second<<"] "
+			    <<" status before process = '"
+			    <<GetIOStatusString(i->second->GetStatus())
+			    <<"'"<<std::endl);
       }
     
-   bbtkDebugMessageDec("process",4,
+    bbtkDebugMessageDec("process",4,
 			"<= BlackBox::bbUpdateInputs() ["
 			<<bbGetFullName()<<"]"
 			<<std::endl);	
-
-
+    
+    
     return s;
   }
   //=========================================================================
 
- 
+  //==================================================================
+  /// Computes the final IOStatus of inputs and outputs after processing
+  void BlackBox::bbComputePostProcessStatus()
+  {
+    bbtkDebugMessageInc("process",4,
+			"=> BlackBox::bbComputePostProcessStatus() ["
+			<<bbGetFullName()<<"]"
+			<<std::endl);	
+
+    IOStatus new_output_status = UPTODATE;
+    if (bbBoxProcessModeIsAlways()) new_output_status = OUTOFDATE;
+
+    // Update the input statuses
+    InputConnectorMapType::iterator i;
+    for ( i = bbGetInputConnectorMap().begin(); 
+	  i!= bbGetInputConnectorMap().end(); ++i) 
+      {
+	IOStatus t = i->second->GetStatus();
+	if (t == OUTOFDATE) new_output_status = OUTOFDATE;
+	// A previously MODIFIED status turns to UPTODATE
+	if (t==MODIFIED) i->second->SetStatus(UPTODATE);
+	bbtkDebugMessage("change",2,
+			 bbGetName()<<"."<<i->first<<" : "
+			 << GetIOStatusString(t) << " -> "
+			 << GetIOStatusString(i->second->GetStatus())
+			 << std::endl);
+      }
+	bbtkDebugMessage("change",2,
+			 bbGetName()<<" new output status : "
+			 << GetIOStatusString(new_output_status)
+			 <<std::endl);
+    // Update the output statuses
+    OutputConnectorMapType::iterator o;
+    for ( o = bbGetOutputConnectorMap().begin(); 
+	  o!= bbGetOutputConnectorMap().end(); ++o) 
+      {
+	o->second->SetStatus(new_output_status);
+      }
+
+    bbtkDebugMessageInc("process",4,
+			"<= BlackBox::bbComputePostProcessStatus() ["
+			<<bbGetFullName()<<"]"
+			<<std::endl);	
+
+  }
+  //==================================================================
+
   //=========================================================================
   /// Connects the input <name> to the connection c
   void BlackBox::bbConnectInput( const std::string& name, Connection* c)
@@ -644,13 +836,14 @@ namespace bbtk
 	bbtkError("no input called '"<<name<<"'");
       }
     i->second->SetConnection(c);
+    // The input *MUST* be set OUTOFDATE to update its input on next execution
+    bbSetStatusAndPropagate(i->second,OUTOFDATE);
     
     bbtkDebugMessage("connection",2,
 			"<== BlackBox::bbConnectInput(\""
 			<<name<<"\","<<c->GetFullName()<<") ["
 			<<bbGetFullName()<<"]"
 			<<std::endl);       
-    //  bbSetModifiedStatus();
 
   }
   //=========================================================================
@@ -857,11 +1050,11 @@ namespace bbtk
     std::string ss("<");
     std::string::size_type pos = 0;
     pos = s.find(ss,0);
-    char* cr = "[";
+    std::string cr("[");
     while ( pos != std::string::npos )
       {
 	//	std::cout << "*** find one "<<std::endl;
-	s.replace(pos,1,cr,1);
+	s.replace(pos,1,cr.c_str(),1);
 	pos = s.find(ss, pos);
       } 
     ss = ">";
@@ -871,7 +1064,7 @@ namespace bbtk
     while ( pos != std::string::npos )
       {
 	//	std::cout << "*** find one "<<std::endl;
-	s.replace(pos,1,cr,1);
+	s.replace(pos,1,cr.c_str(),1);
 	pos = s.find(ss, pos);
       } 
     ss = ",";
@@ -881,7 +1074,7 @@ namespace bbtk
     while ( pos != std::string::npos )
       {
 	//	std::cout << "*** find one "<<std::endl;
-	s.replace(pos,1,cr,1);
+	s.replace(pos,1,cr.c_str(),1);
 	pos = s.find(ss, pos);
       }     //    std::cout << "AFTER=["<<s<<"]"<<std::endl;
   }
@@ -1021,12 +1214,25 @@ namespace bbtk
       {
 	bbtkMessage("Help",1,"Black Box <::"<<this->bbGetDescriptor()->GetTypeName()<<">"<<std::endl);
       }
+    /*
+    if (bbIsUpToDate())
+      {
+	bbtkMessage("Help",1,"Up-to-date ["<<mMaxInputChangeTime<<","
+		    <<mMinOutputChangeTime<<"]"<<std::endl);
+      }
+    else 
+      {
+	bbtkMessage("Help",1,"Out-of-date ["<<mMaxInputChangeTime<<","
+		    <<mMinOutputChangeTime<<"]"<<std::endl);
+      }
+    */
     //    bbtkMessage("Help",1," "<<GetDescription()<<std::endl);
     //    bbtkMessage("Help",1," By : "<<GetAuthor()<<std::endl);
 
     std::vector<std::string> iname;
     std::vector<std::string> ivalue;
     std::vector<std::string> iconn;
+    std::vector<std::string> istatus;
 
     InputConnectorMapType::iterator i;
     unsigned int namelmax = 0;
@@ -1046,11 +1252,13 @@ namespace bbtk
 	  s += con->GetOriginalBlackBoxFromOutput();
 	}  // if con
 	iconn.push_back(s);
+	istatus.push_back(GetIOStatusString(i->second->GetStatus()));
       }
     OutputConnectorMapType::iterator o;
     std::vector<std::string> oname;
     std::vector<std::string> ovalue;
     std::vector<std::vector<std::string> > oconn;
+    std::vector<std::string> ostatus;
     for ( o = mOutputConnectorMap.begin(); o != mOutputConnectorMap.end(); ++o ) 
       {
 	oname.push_back(o->first);
@@ -1070,6 +1278,7 @@ namespace bbtk
 	    ss.push_back(s);
 	}  // if con
 	oconn.push_back(ss);
+	ostatus.push_back(GetIOStatusString(o->second->GetStatus()));
       }
 
     if (iname.size()) 
@@ -1077,10 +1286,10 @@ namespace bbtk
     else 
       bbtkMessage("Help",1," * No inputs"<<std::endl);
 
-    std::vector<std::string>::iterator i1,i2,i3;
-    for (i1=iname.begin(),i2=ivalue.begin(),i3=iconn.begin();
-	 i1!=iname.end(),i2!=ivalue.end(),i3!=iconn.end();
-	 ++i1,++i2,++i3)
+    std::vector<std::string>::iterator i1,i2,i3,i4;
+    for (i1=iname.begin(),i2=ivalue.begin(),i3=iconn.begin(),i4=istatus.begin();
+	 i1!=iname.end(),i2!=ivalue.end(),i3!=iconn.end(),i4!=istatus.end();
+	 ++i1,++i2,++i3,++i4)
       {
 	std::string name(*i1);
 	name += "'";
@@ -1089,9 +1298,11 @@ namespace bbtk
 	value += "'";
 	value.append(1+valuelmax-value.size(),' ');
 	if (i3->size()) 
-	  bbtkMessage("Help",1,"    '"<<name<<" = '"<<value<<" <-- '"<<*i3<<"'"<<std::endl);
+	  bbtkMessage("Help",1,"    '"<<name<<" = '"<<value<<" <-- '"
+		      <<*i3<<"'");
 	else 
-	  bbtkMessage("Help",1,"    '"<<name<<" = '"<<value<<std::endl);
+	  bbtkMessage("Help",1,"    '"<<name<<" = '"<<value);
+	bbtkMessage("Help",1," ["<<*i4<<"]"<<std::endl);
       }
 
     if (oname.size()) 
@@ -1099,11 +1310,11 @@ namespace bbtk
     else 
       bbtkMessage("Help",1," * No outputs"<<std::endl);
 
-    std::vector<std::vector<std::string> >::iterator i4;
+    std::vector<std::vector<std::string> >::iterator i5;
 
-    for (i1=oname.begin(),i2=ovalue.begin(),i4=oconn.begin();
-	 i1!=oname.end(),i2!=ovalue.end(),i4!=oconn.end();
-	 ++i1,++i2,++i4)
+    for (i1=oname.begin(),i2=ovalue.begin(),i5=oconn.begin(),i4=ostatus.begin();
+	 i1!=oname.end(),i2!=ovalue.end(),i5!=oconn.end(),i4!=ostatus.end();
+	 ++i1,++i2,++i4,++i5)
       {
 	std::string name(*i1);
 	name += "'";
@@ -1111,38 +1322,55 @@ namespace bbtk
 	std::string value(*i2);
 	value += "'";
 	value.append(1+valuelmax-value.size(),' ');
-	if (!(*i4).size())
-	  bbtkMessage("Help",1,"    '"<<name<<" = '"<<value<<std::endl);
+	if (!(*i5).size())
+	  bbtkMessage("Help",1,"    '"<<name<<" = '"<<value);
 	else 
 	  {
 	    std::string pref = "    '"+name+" = '"+value;
-	    for (i3=i4->begin();i3!=i4->end();++i3)
+	    for (i3=i5->begin();i3!=i5->end();++i3)
 	      {
-		bbtkMessage("Help",1,pref<<" --> '"<<*i3<<"'"<<std::endl);
+		bbtkMessage("Help",1,pref<<" --> '"<<*i3<<"'");
 		pref.replace(0,pref.size(),pref.size(),' ');
 	      }
 	  }
+	bbtkMessage("Help",1," ["<<*i4<<"]"<<std::endl);
       }
 
    }
   //=========================================================================
 
+  static bool bbmgGlobalProcessingExecutionList = false;
 
   //=========================================================================
    void BlackBox::bbGlobalProcessExecutionList()
    {   
      bbtkDebugMessageInc("process",3,
 			 "=> BlackBox::bbGlobalProcessExecutionList()"
-			 <<std::endl);     
-     
-     std::set<BlackBox::Pointer>::iterator i;
-     for (i=bbmgExecutionList.begin();
-	  i!=bbmgExecutionList.end();
-	  ++i)
+			 <<std::endl);    
+     if (bbmgGlobalProcessingExecutionList) 
        {
-	 bbtkDebugMessage("process",4,
-			  " -> Executing "<<(*i)->bbGetFullName()<<std::endl);
-	 (*i)->bbExecute(true);
+	 bbtkDebugMessage("process",3,"BlackBox::bbGlobalProcessExecutionList() reentered !");
+	 return;
+       }
+     bbmgGlobalProcessingExecutionList = true;
+
+     std::set<BlackBox::WeakPointer>::iterator i; 
+     while (bbmgExecutionList.size()>0)
+       {
+	 i = bbmgExecutionList.begin();
+	 BlackBox::WeakPointer p = *i;
+	 bbmgExecutionList.erase(i);
+	 if (p.lock())
+	   {
+	     bbtkDebugMessage("process",4,
+			      " -> Executing "<<
+			      p.lock()->bbGetFullName()<<std::endl);
+	     p.lock()->bbExecute(true);
+	   }
+	 else 
+	   {
+	     bbtkGlobalError("Strange error in BlackBox::bbGlobalProcessExecutionList() : Weak bb pointer in bbmgExecutionList is no more valid...");
+	   }
        }
      
      bbmgExecutionList.clear();
@@ -1150,6 +1378,7 @@ namespace bbtk
 			 "<= BlackBox::bbGlobalProcessExecutionList()"
 			 <<std::endl);     
      
+     bbmgGlobalProcessingExecutionList = false;
      
    }
   //=========================================================================
@@ -1175,9 +1404,14 @@ namespace bbtk
 	}
 
   void BlackBox::bbGlobalAddToExecutionList( BlackBox::Pointer b )
-	{  
-		bbmgExecutionList.insert(b); 
-	} 
+  {  
+    bbtkDebugMessage("process",3,"* bbGlobalAddToExecutionList("<<b->bbGetFullName()<<")"<<std::endl);
+    if (bbmgGlobalProcessingExecutionList) 
+      {
+	bbtkDebugMessage("process",3,"bbGlobalAddToExecutionList called inside bbGlobalProcessExecutionList !");
+      }
+    bbmgExecutionList.insert(b); 
+  } 
 
 
    //=========================================================================