X-Git-Url: https://git.creatis.insa-lyon.fr/pubgit/?a=blobdiff_plain;f=kernel%2Fsrc%2FbbtkBlackBox.cxx;h=0206b2924369b54871e9eba5df07b74a59de64c4;hb=ffe082cfc10dbb2c326c513563286caa2606110f;hp=04d146c6ca2780483e5171b71430655adca552c7;hpb=0a7afaadd37a67878b1dfe9166c1c7abd867e53f;p=bbtk.git

diff --git a/kernel/src/bbtkBlackBox.cxx b/kernel/src/bbtkBlackBox.cxx
index 04d146c..0206b29 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/12/09 12:54:02 $
-  Version:   $Revision: 1.34 $
+  Date:      $Date: 2009/03/23 13:06:41 $
+  Version:   $Revision: 1.40 $
 =========================================================================*/
 
 /* ---------------------------------------------------------------------
@@ -54,6 +54,7 @@ namespace bbtk
   static std::set<BlackBox::WeakPointer> bbmgExecutionList;
 
   //=========================================================================
+
   BlackBox::Deleter::Deleter()
   {
   }
@@ -78,7 +79,7 @@ namespace bbtk
     
     b->bbDelete();
 
-    bbtkDebugMessage("object",2,"##> BlackBox::Deleter(\""<<name<<"\") : releasing descriptor ["<<desc.lock()<<"]"<<std::endl);
+    bbtkDebugMessage("object",2,"##> BlackBox::Deleter(\""<<name<<"\") : releasing descriptor"<<std::endl);
     
     if (!desc.expired()) 
       {
@@ -153,42 +154,6 @@ namespace bbtk
   //=========================================================================
 
 
-  //=========================================================================
-  /// Main processing method of the box.
-  void BlackBox::bbExecute(bool force)
-  {
-    bbtkDebugMessageInc("process",2,
-			"=> 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()) 
-      {
-	bbtkDebugMessage("process",2,
-			 " -> FreezeExecution global flag is 'true' : abort execution"<<std::endl);
-      }
-
-    BBTK_BUSY_CURSOR;
-
-    // If force is true then update is triggered even if the box is UPTODATE
-    //    if (force) bbSetModifiedStatus();
-
-    // Calls the main recursive update method 
-    bbBackwardUpdate(Connection::Pointer());
-
-    bbtkDebugMessageDec("process",2,
-			"<= BlackBox::bbExecute() ["
-			<<bbGetFullName()<<"]"<<std::endl);
-  }
-  //=========================================================================
 
   //=========================================================================
   std::string BlackBox::bbGetFullName() const
@@ -382,7 +347,7 @@ namespace bbtk
   bool BlackBox::bbCanReact() const 
   { 
     return ( bbGlobalGetSomeBoxExecuting() 
-#ifdef _USE_WXWIDGETS_
+#ifdef USE_WXWIDGETS
 	     || Wx::IsSomeWindowAlive() 
 #endif
 	     ); 
@@ -444,16 +409,18 @@ namespace bbtk
 
 
   //=========================================================================
-  void BlackBox::AddChangeObserver(const std::string& output_name, 
+  void BlackBox::bbAddOutputObserver(const std::string& output, 
 				   OutputChangeCallbackType f)
   {
+    bbGetOutputConnector(output).AddChangeObserver(f);
   }  
   //=========================================================================
 
   //=========================================================================
-  void BlackBox::RemoveChangeObserver(const std::string& output_name, 
+  void BlackBox::bbRemoveOutputObserver(const std::string& output_name, 
 				      OutputChangeCallbackType f)
   {
+    bbtkError("BlackBox::RemoveChangeObserver NOT IMPLEMENTED");
   }
   //=========================================================================
 
@@ -583,7 +550,6 @@ namespace bbtk
     for ( o = bbGetOutputConnectorMap().begin(); 
 	  o != bbGetOutputConnectorMap().end(); ++o )			
       {									
-	//	bbSetStatusAndPropagate(o->second, OUTOFDATE);
 	if (o->second->GetStatus()==UPTODATE) 
 	  {
 	    o->second->SetStatus(OUTOFDATE);
@@ -605,81 +571,6 @@ namespace bbtk
   }
   //=========================================================================
 
-  //=========================================================================
-  void BlackBox::bbSetStatusAndPropagate(BlackBoxOutputConnector* c,
-					 IOStatus s)
-  {
-    bbtkError("bbSetStatusAndPropagate(BlackBoxOutputConnector* c,IOStatus s)");
-    /*
-    if (i->GetStatus()==UPTODATE) 
-      {
-	i->second->SetStatus(s);
-	i->second->SignalChange(GetThisPointer<BlackBox>(),i->first); 
-      }
-    */
-  }
-  //=========================================================================
- 
-
- ///  Signals that the BlackBox has been modified
-  /*
-  void BlackBox::bbSetModifiedStatus(BlackBoxInputConnector* c)
-  {
-    bbtkDebugMessage("modified",1,
-		     "==> BlackBox::bbSetModifiedStatus("<<c<<") ["
-		     <<bbGetFullName()<<"]"<<std::endl);
-    
-    if ( (c==bbGetInputConnectorMap().find("WinHide")->second) )
-      //	 && (bbCanReact()))
-      {
-	bbtkDebugMessage("modified",2,
-			 "-> Hide triggered by WinHide input change"
-			 <<std::endl);
-	this->bbHideWindow();
-	this->bbSetStatus(MODIFIED); 
-	return;
-      }
-    if ( (c==bbGetInputConnectorMap().find("WinClose")->second) )
-      //	 && (bbCanReact()))
-      {
-	bbtkDebugMessage("modified",2,
-			 "-> Close triggered by WinClose input change"
-			 <<std::endl);
-	this->bbHideWindow();
-	this->bbSetStatus(MODIFIED); 
-	return;
-      }
-    
-    if ( ( bbBoxProcessModeIsReactive()  ||
-	   (c==bbGetInputConnectorMap().find("BoxExecute")->second))
-	 && (bbCanReact() ) )
-      {
-	bbtkDebugMessage("modified",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<<") ["
-			<<bbGetFullName()<<"]"<<std::endl);
-  }  
-*/
-  //=========================================================================
 
   //=========================================================================  
   void BlackBox::bbSignalOutputModification(bool reaction)
@@ -693,11 +584,15 @@ namespace bbtk
     for ( i  = bbGetOutputConnectorMap().begin(); 
 	  i != bbGetOutputConnectorMap().end(); ++i) 
       {
-	if (i->second->GetStatus()==UPTODATE) 
-	  {
-	    //	    i->second->SetStatus(MODIFIED);
+	//	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();
@@ -726,9 +621,8 @@ namespace bbtk
 	  bbtkError("BlackBox["<<bbGetFullName()<<"]::bbSignalOutputModification("<<output<<") : unknown output");
 	}
 
-    if (i->second->GetStatus()==UPTODATE) 
-      {
-	//	i->second->SetStatus(MODIFIED);
+    //    if (i->second->GetStatus()==UPTODATE) 
+    //      {
 	i->second->SignalChange(GetThisPointer<BlackBox>(),i->first); 
 	// Has to notify the output "BoxChange" also
 	if (output != "BoxChange") 
@@ -736,12 +630,11 @@ namespace bbtk
 	    i = bbGetOutputConnectorMap().find("BoxChange");
 	    if ( i != bbGetOutputConnectorMap().end() ) 
 	      {
-		//		i->second->SetStatus(MODIFIED);
 		i->second->SignalChange(GetThisPointer<BlackBox>(),i->first); 
 	      }
 	  }
 	if (reaction) bbGlobalProcessExecutionList();
-      }
+	//      }
 
     bbtkDebugMessageDec("change",5,
 			"<= BlackBox::bbSignalOutputModification("
@@ -770,25 +663,22 @@ namespace bbtk
 	  {
 	    bbtkError("BlackBox["<<bbGetFullName()<<"]::bbSignalOutputModification("<<*o<<") : unknown output");
 	  }
-	// Already OUTOFDATE : noting to do
-	if (i->second->GetStatus()==UPTODATE)
-	  {
-	    //	i->second->SetStatus(MODIFIED);
+
+	//	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 ( changed && (i != bbGetOutputConnectorMap().end())) 
       {
-	// Already OUTOFDATE : noting to do
-	if (i->second->GetStatus()==UPTODATE) 
-	  {
-	    //	i->second->SetStatus(MODIFIED);
+	// if (i->second->GetStatus()==UPTODATE) 
+	//	  {
 	    i->second->SignalChange(GetThisPointer<BlackBox>(),i->first); 
 	    if (reaction) bbGlobalProcessExecutionList();
-	  }
+	    //  }
       }
 
     bbtkDebugMessageDec("change",5,
@@ -798,9 +688,133 @@ namespace bbtk
   }  
   //=========================================================================   
 
+
+
+
+
+
+
+  //=========================================================================
+  /// Main processing method of the box.
+  void BlackBox::bbExecute(bool force)
+  {
+    bbtkDebugMessageInc("process",2,
+			"=> BlackBox::bbExecute("<<(int)force<<") ["
+			<<bbGetFullName()<<"]"<<std::endl);
+ 
+    // If already executing : return
+    /*
+    if (bbGetExecuting()) 
+      {
+	bbtkDebugMessage("process",2,
+			 " -> already executing : abort"<<std::endl);
+	return;
+      }
+    */
+
+    // If execution frozen : return
+    if (bbGlobalGetFreezeExecution()) 
+      {
+	bbtkDebugMessage("process",2,
+			 " -> FreezeExecution global flag is 'true' : abort execution"<<std::endl);
+      }
+
+    BBTK_BUSY_CURSOR;
+
+    // If force is true then update is triggered even if the box is UPTODATE
+    //    if (force) bbSetModifiedStatus();
+
+    // Calls the main recursive execution method 
+    bbRecursiveExecute(Connection::Pointer());
+
+    bbtkDebugMessageDec("process",2,
+			"<= BlackBox::bbExecute() ["
+			<<bbGetFullName()<<"]"<<std::endl);
+  }
+  //=========================================================================
+
+
+  //=========================================================================
+  /// Main recursive processing method of the box.
+  void BlackBox::bbRecursiveExecute( Connection::Pointer caller )
+  {
+    bbtkDebugMessageInc("process",3,
+			"=> BlackBox::bbRecursiveExecute("
+			<<(caller?caller->GetFullName():"0")<<") ["
+			<<bbGetFullName()<<"]"<<std::endl);
+
+    // If already executing : return
+    if (bbGetExecuting()) 
+      {
+	bbtkDebugMessage("process",3,
+			 " -> already executing : abort"<<std::endl);
+	return; 
+      }
+
+    bbSetExecuting(true);
+    bool wasExecuting = bbGlobalGetSomeBoxExecuting();
+    bbGlobalSetSomeBoxExecuting(true);
+
+	this->bbCreateWidget();
+
+    // Updates its inputs
+    IOStatus s = bbUpdateInputs();
+    
+    if ( (s != UPTODATE) ||
+	 bbBoxProcessModeIsAlways() )
+      {
+	  // Displays the window (WxBlackbox)
+ 	  //	bbShowWindow(caller);
+
+	  // Actual processing (virtual)
+	  this->bbProcess();
+	
+	
+	  // Update the I/O statuses
+	  bbComputePostProcessStatus();
+      }
+    else 
+      {
+	// Test output status...
+	OutputConnectorMapType::iterator o;
+	for ( o = bbGetOutputConnectorMap().begin(); 
+	      o!= bbGetOutputConnectorMap().end(); ++o) 
+	  {
+	    if (o->second->GetStatus() != UPTODATE)
+	      {
+		bbtkWarning("BlackBox::bbRecursiveExecute ["
+			    <<bbGetFullName()
+			    <<"] : all inputs are Up-to-date but output '"
+			    <<o->first<<"' is Out-of-date ???");
+	      }
+	  }
+	
+        bbtkDebugMessage("process",3," -> Up-to-date : nothing to do"
+			 <<std::endl);
+      }
+
+	  this->bbShowWidget(); 
+
+	  
+    bbtkDebugMessage("process",3,
+            "<= BlackBox::bbRecursiveExecute() ["
+            <<bbGetFullName()<<"]"<<std::endl);
+
+    bbSetExecuting(false);
+    bbGlobalSetSomeBoxExecuting(wasExecuting);
+
+    return; 
+
+  }
+  //=========================================================================
+  
+   
+
+
+
   //=========================================================================
   /// Updates the BlackBox inputs
-  /// Calls BackwardUpdate on all BlackBoxInputConnector
+  /// Calls RecursiveExecute on all BlackBoxInputConnector
   /// \returns The maximum of final IOStatus after each input update
   IOStatus BlackBox::bbUpdateInputs()
   {
@@ -826,7 +840,7 @@ namespace bbtk
 			    <<" status before update = '"
 			    <<GetIOStatusString(i->second->GetStatus())
 			    <<"'"<<std::endl);
-	i->second->BackwardUpdate();
+	i->second->RecursiveExecute();
 	IOStatus t = i->second->GetStatus();
 	if (t > s) s = t;
 	bbtkDebugMessageDec("change",2,