X-Git-Url: https://git.creatis.insa-lyon.fr/pubgit/?a=blobdiff_plain;ds=sidebyside;f=kernel%2Fsrc%2FbbtkConnection.cxx;h=9b1d3eb11ab306beccedb3b82cdb696bad350716;hb=6ac9074f717f22c4ffdc6a70d0704c1b1f8fe842;hp=4e39eb45668d740ace70c5f68f1f7149e7333ece;hpb=13aaa782a7f5942f5072728201750c06afbdfb2d;p=bbtk.git

diff --git a/kernel/src/bbtkConnection.cxx b/kernel/src/bbtkConnection.cxx
index 4e39eb4..9b1d3eb 100644
--- 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/12/09 11:48:31 $
-  Version:   $Revision: 1.18 $
+  Date:      $Date: 2009/05/28 08:12:05 $
+  Version:   $Revision: 1.21 $
 =========================================================================*/
 
 /* ---------------------------------------------------------------------
@@ -39,6 +39,11 @@
 #include "bbtkMessageManager.h"
 #include "bbtkBlackBoxOutputConnector.h"
 
+#define bbtkCMessage(key,level,mess) \
+  bbtkMessage(key,level,"["<<GetFullName()<<"] "<<mess)
+#define bbtkCDebugMessage(key,level,mess)	\
+  bbtkDebugMessage(key,level,"["<<GetFullName()<<"] "<<mess)
+
 namespace bbtk
 {
   const std::string IOSTATUS_STRING[3] = 
@@ -54,13 +59,13 @@ namespace bbtk
 				      const std::string& input ,
 				      const Factory::Pointer f  )
   {
-    bbtkDebugMessage("object",1,"##> Connection::Connection(\""
+    bbtkDebugMessage("object",1,"##> Connection(\""
 		     <<from->bbGetName()<<"\",\""<<output<<"\",\""
 		     <<to->bbGetName()<<"\",\""<<input<<"\")"
 		     <<std::endl);
     Connection::Pointer p = 
       MakePointer(new Connection(from,output,to,input,f));
-    bbtkDebugMessage("object",1,"<## Connection::Connection(\""
+    bbtkDebugMessage("object",1,"<## Connection(\""
 		     <<from->bbGetName()<<"\",\""<<output<<"\",\""
 		     <<to->bbGetName()<<"\",\""<<input<<"\")"
 		     <<std::endl);
@@ -79,14 +84,14 @@ Connection::Connection(BlackBox::Pointer from, const std::string& output,
       mFromAny(false),
       mToAny(false)
   {
-    bbtkDebugMessage("object",2,"==> Connection::Connection(\""
+    bbtkDebugMessage("object",2,"==> Connection(\""
 		     <<from->bbGetName()<<"\",\""<<output<<"\",\""
 		     <<to->bbGetName()<<"\",\""<<input<<"\")"
 		     <<std::endl);    
 
-    bbtkDebugMessage("connection",1,"==> Connection::Connection(\""
-		     <<from->bbGetFullName()<<"\",\""<<output<<"\",\""
-		     <<to->bbGetFullName()<<"\",\""<<input<<"\")"
+    bbtkDebugMessage("connection",1,"==> Connection(\""
+		     <<from->bbGetName()<<"\",\""<<output<<"\",\""
+		     <<to->bbGetName()<<"\",\""<<input<<"\")"
 		     <<std::endl);    
 
     
@@ -116,9 +121,7 @@ Connection::Connection(BlackBox::Pointer from, const std::string& output,
       {
 	if ( from->bbGetOutputType(output) == typeid(Data) )
 	  {
-	    bbtkWarning("Connection '"
-			<<GetFullName()
-			<<"' : '"<<from->bbGetName()<<"."<<output
+	    bbtkWarning("Connection: '"<<from->bbGetName()<<"."<<output
 			<<"' is of type <"
 			<<HumanTypeName<Data>()
 			<<"> : type compatibility with '"
@@ -129,7 +132,7 @@ Connection::Connection(BlackBox::Pointer from, const std::string& output,
 	  }
 	else if (  to->bbGetInputType(input) == typeid(Data) )
 	  {   
-	    bbtkDebugMessage("Kernel",8," -> '"<<input<<"' type is "
+	    bbtkDebugMessage("kernel",8," -> '"<<input<<"' type is "
 			     <<TypeName<Data>()<<" : can receive any data"
 			     <<std::endl);
 	    mToAny = true;
@@ -171,12 +174,12 @@ Connection::Connection(BlackBox::Pointer from, const std::string& output,
     from->bbGetOutputConnector(output).AddChangeObserver(boost::bind(&bbtk::Connection::OnOutputChange,this, _1, _2, _3));
 
     
-    bbtkDebugMessage("connection",1,"<== Connection::Connection(\""
-		     <<from->bbGetFullName()<<"\",\""<<output<<"\",\""
-		     <<to->bbGetFullName()<<"\",\""<<input<<"\")"
+    bbtkDebugMessage("connection",1,"<== Connection(\""
+		     <<from->bbGetName()<<"\",\""<<output<<"\",\""
+		     <<to->bbGetName()<<"\",\""<<input<<"\")"
 		     <<std::endl);    
 
-    bbtkDebugMessage("object",2,"==> Connection::Connection(\""
+    bbtkDebugMessage("object",2,"<== Connection(\""
 		     <<from->bbGetName()<<"\",\""<<output<<"\",\""
 		     <<to->bbGetName()<<"\",\""<<input<<"\")"
 		     <<std::endl);    
@@ -189,13 +192,13 @@ Connection::Connection(BlackBox::Pointer from, const std::string& output,
 				      BlackBox::Pointer to, 
 				      const std::string& input )
   {
-    bbtkDebugMessage("object",1,"##> Connection::Connection(\""
+    bbtkDebugMessage("object",1,"##> Connection(\""
 		     <<from->bbGetName()<<"\",\""<<output<<"\",\""
 		     <<to->bbGetName()<<"\",\""<<input<<"\")"
 		     <<std::endl);
     Connection::Pointer p = 
       MakePointer(new Connection(from,output,to,input));
-    bbtkDebugMessage("object",1,"<## Connection::Connection(\""
+    bbtkDebugMessage("object",1,"<## Connection(\""
 		     <<from->bbGetName()<<"\",\""<<output<<"\",\""
 		     <<to->bbGetName()<<"\",\""<<input<<"\")"
 		     <<std::endl);
@@ -213,14 +216,14 @@ Connection::Connection(BlackBox::Pointer from, const std::string& output,
       mFromAny(false),
       mToAny(false)
   {
-    bbtkDebugMessage("object",2,"==> Connection::Connection(\""
+    bbtkDebugMessage("object",2,"==> Connection(\""
 		     <<from->bbGetName()<<"\",\""<<output<<"\",\""
 		     <<to->bbGetName()<<"\",\""<<input<<"\")"
 		     <<std::endl);    
 
-    bbtkDebugMessage("connection",1,"==> Connection::Connection(\""
-		     <<from->bbGetFullName()<<"\",\""<<output<<"\",\""
-		     <<to->bbGetFullName()<<"\",\""<<input<<"\")"
+    bbtkDebugMessage("connection",1,"==> Connection(\""
+		     <<from->bbGetName()<<"\",\""<<output<<"\",\""
+		     <<to->bbGetName()<<"\",\""<<input<<"\")"
 		     <<std::endl);    
 
     
@@ -263,7 +266,7 @@ Connection::Connection(BlackBox::Pointer from, const std::string& output,
 	  }
 	else if (  to->bbGetInputType(input) == typeid(Data) )
 	  {   
-	    bbtkDebugMessage("Kernel",8," -> '"<<input<<"' type is "
+	    bbtkDebugMessage("kernel",8," -> '"<<input<<"' type is "
 			     <<TypeName<Data>()<<" : can receive any data"
 			     <<std::endl);
 	    mToAny = true;
@@ -289,12 +292,12 @@ Connection::Connection(BlackBox::Pointer from, const std::string& output,
 
     from->bbGetOutputConnector(output).AddChangeObserver(boost::bind(&bbtk::Connection::OnOutputChange,this, _1, _2, _3));
     
-    bbtkDebugMessage("connection",1,"<== Connection::Connection(\""
-		     <<from->bbGetFullName()<<"\",\""<<output<<"\",\""
-		     <<to->bbGetFullName()<<"\",\""<<input<<"\")"
+    bbtkDebugMessage("connection",1,"<== Connection(\""
+		     <<from->bbGetName()<<"\",\""<<output<<"\",\""
+		     <<to->bbGetName()<<"\",\""<<input<<"\")"
 		     <<std::endl);    
 
-    bbtkDebugMessage("object",2,"==> Connection::Connection(\""
+    bbtkDebugMessage("object",2,"==> Connection(\""
 		     <<from->bbGetName()<<"\",\""<<output<<"\",\""
 		     <<to->bbGetName()<<"\",\""<<input<<"\")"
 		     <<std::endl);    
@@ -305,9 +308,9 @@ Connection::Connection(BlackBox::Pointer from, const std::string& output,
   /// Dtor 
   Connection::~Connection()
   {
-    bbtkDebugMessage("object",2,
-		     "==> Connection::~Connection() ["
-		     <<GetFullName()<<"]"<<std::endl);
+    bbtkCDebugMessage("object",4,
+		     "==> ~Connection()"
+		     <<std::endl);
 
     if (mAdaptor) mAdaptor.reset();
     if (mFrom!=0) 
@@ -318,7 +321,7 @@ Connection::Connection(BlackBox::Pointer from, const std::string& output,
       }
     else 
       {
-	bbtkInternalError("Connection::~Connection() : invalid initial box pointer");
+	bbtkInternalError("~Connection() : invalid initial box pointer");
       }
     if (mTo!=0) 
       {
@@ -327,25 +330,37 @@ Connection::Connection(BlackBox::Pointer from, const std::string& output,
       }
     else 
       {
-	bbtkInternalError("Connection::~Connection() : invalid final box pointer");
+	bbtkInternalError("~Connection() : invalid final box pointer");
       }
 
 
-    bbtkDebugMessage("object",2,
-		     "<== Connection::~Connection() ["
-		     <<GetFullName()<<"]"<<std::endl);
+    bbtkCDebugMessage("object",4,
+		      "<== ~Connection()"
+		      <<std::endl);
   }
   //==================================================================
   
   //==================================================================
-  /// Backward Update
-  void Connection::BackwardUpdate()
+  /// Recursive execution
+  void Connection::RecursiveExecute()
   {
-    bbtkDebugMessage("process",3,
-		     "===> Connection::BackwardUpdate() ["
-		     <<GetFullName()<<"]"<<std::endl);
+    bbtkCDebugMessage("process",4,
+		      "===> Connection::RecursiveExecute()"
+		      <<std::endl);
+
+    /*
+    // If box from already executing : nothing to do
+    if (mFrom->bbGetExecuting()) 
+      {
+	bbtkDebugMessage("process",3,
+			 " -> "<<mFrom->bbGetName()
+			 <<" already executing : abort"<<std::endl);
+	return; 
 
-    mFrom->bbBackwardUpdate(GetThisPointer<Connection>());
+      }
+    */
+
+    mFrom->bbRecursiveExecute(GetThisPointer<Connection>());
 
     TransferData();
 
@@ -357,7 +372,7 @@ Connection::Connection(BlackBox::Pointer from, const std::string& output,
       }
     mTo->bbGetInputConnector(mInput).SetStatus(s);
     
-    bbtkDebugMessage("process",3,
+    bbtkCDebugMessage("process",4,
 		     " --> '"<<mTo->bbGetName()<<"."<<mInput
 		     <<" ["<<&mTo->bbGetInputConnector(mInput)<<"] "
 		     <<"' new status '"
@@ -365,40 +380,23 @@ Connection::Connection(BlackBox::Pointer from, const std::string& output,
 		     <<"'"
 		     << std::endl);
 
-    bbtkDebugMessage("process",3,
-		     "<=== Connection::BackwardUpdate() ["
-		     <<GetFullName()<<"]"<<std::endl);
-    return; // s;
+    bbtkCDebugMessage("process",4,
+		     "<=== Connection::RecursiveExecute()"
+		      <<std::endl);
+    return; 
   }
   //==================================================================
 
-  /*
-  //==================================================================
-  /// Forward Update
-  void Connection::ForwardUpdate()
-  {
-    bbtkDebugMessageInc("process",2,
-			"Connection::ForwardUpdate() ["
-			<<GetFullName()<<"]"<<std::endl);
 
-  
-    TransferData();
-
-    mTo->bbForwardUpdate(this);
-
-    bbtkDebugDecTab("process",2);
-  }
-  //==================================================================
-  */
 
   //==================================================================
   /// Transfers the data from the source output to the target input
   /// doing necessary conversions (adaptation or pointer cast)
   void Connection::TransferData()
   {
-    bbtkDebugMessageInc("data",3,
-			"Connection::TransferData() ["
-			<<GetFullName()<<"]"<<std::endl);
+    bbtkCDebugMessage("data",3,
+		      "Connection::TransferData()"
+		      <<std::endl);
     
     
     // If an adaptor was created we need to adapt the data
@@ -413,22 +411,28 @@ Connection::Connection(BlackBox::Pointer from, const std::string& output,
     // If no adaptor but source type is an any and target is not an any
     else if ( mFromAny && (! mToAny) )
       {
-	bbtkDebugMessage("data",3,
+	bbtkCDebugMessage("data",3,
 			 " * Source type is an "
 			 <<HumanTypeName<Data>()
 			 <<" which contains a <"
 			 <<HumanTypeName(mFrom->bbGetOutput(mOutput).type())
 			 <<">"<<std::endl);
-	bbtkDebugMessage("data",3,
+	bbtkCDebugMessage("data",3,
 			 " * Target type is <"
 			 <<HumanTypeName(mTo->bbGetInputType(mInput))
 			 <<">"<<std::endl);
 	
+	// 0) If from any contents void : nothing to do 
+	if (mFrom->bbGetOutput(mOutput).type() == typeid(void)) 
+	  {
+	    bbtkCDebugMessage("data",3,
+			     " -> Source is void : nothing to transfer!"<<std::endl);
+	  }
 	// 1) Test strict type matching between any content and target
-	if (mFrom->bbGetOutput(mOutput)
+	else if (mFrom->bbGetOutput(mOutput)
 	    .contains( mTo->bbGetInputType(mInput) ) )
 	  {
-	    bbtkDebugMessage("data",3,
+	    bbtkCDebugMessage("data",3,
 			     " -> Equal types : transfer ok"<<std::endl);
 	    mTo->bbSetInput( mInput, 
 			     mFrom->bbGetOutput(mOutput),
@@ -450,7 +454,7 @@ Connection::Connection(BlackBox::Pointer from, const std::string& output,
 	      }
 	    if (adaptor)  
 	      {
-		bbtkDebugMessage("data",3," -> Adaptor found : using it"
+		bbtkCDebugMessage("data",3," -> Adaptor found : using it"
 				 <<std::endl);
 		  adaptor->bbSetInput("In",mFrom->bbGetOutput(mOutput),false);
 		adaptor->bbExecute();
@@ -464,7 +468,7 @@ Connection::Connection(BlackBox::Pointer from, const std::string& output,
 		      (mTo->bbGetDescriptor()->GetInputDescriptor(mInput)
 		       ->IsPointerType()) )
 	      {
-		bbtkDebugMessage("data",3,
+		bbtkCDebugMessage("data",3,
 				 " -> No adaptor found but source and target types are both pointers : trying up or down cast"<<std::endl);
 		
 		void* nptr = 
@@ -503,33 +507,16 @@ Connection::Connection(BlackBox::Pointer from, const std::string& output,
 
   }
   //==================================================================
-  
-  /*
-  //==================================================================
-  /// Modified
-  void Connection::SetModifiedStatus()
-  {
-    bbtkDebugMessage("modified",2,
-		     "==> Connection::SetModifiedStatus() ["
-		     <<GetFullName()<<"]"<<std::endl);
-    
-    if (mAdaptor) mAdaptor->bbSetModifiedStatus();
-    
-    mTo->bbSetModifiedStatus(  mTo->bbGetInputConnectorMap().find(mInput)->second );
-    
- 
-  }
-  //==================================================================
-  */
+
   //==================================================================
   /// From.Output change propagation
   void Connection::OnOutputChange(bbtk::BlackBox::Pointer, const std::string&, 
 				  IOStatus status)
   {
-    bbtkDebugMessage("change",2,
+    bbtkCDebugMessage("change",2,
 		     "==> Connection::OnOutputChange("
-		     <<GetIOStatusString(status)<<") ["
-		     <<GetFullName()<<"]"<<std::endl);
+		     <<GetIOStatusString(status)<<")"
+		     <<std::endl);
     if (mAdaptor) 
       {
 	    BlackBoxInputConnector* ac = mAdaptor->bbGetInputConnectorMap().find("In")->second;
@@ -565,7 +552,8 @@ Connection::Connection(BlackBox::Pointer from, const std::string& output,
   //==================================================================
   void Connection::Check() const
   {
-    bbtkMessage("debug",1,"** Checking Connection "<<(void*)this<<" ["<<GetFullName()<<"]"
+    bbtkMessage("debug",1,"** Checking Connection "<<(void*)this<<" ["
+		<<GetFullName()<<"]"
 		<<std::endl);
     if (mFrom==0) 
       {
@@ -573,12 +561,12 @@ Connection::Connection(BlackBox::Pointer from, const std::string& output,
       }
     else
       {
-	bbtkMessage("debug",2," - From : "<<mFrom->bbGetFullName()<<std::endl);
+	bbtkMessage("debug",2," - From : "<<mFrom->bbGetName()<<std::endl);
 	if (!mFrom->bbHasOutput(mOutput))
 	  {
 	    bbtkError("** Checking Connection "<<(void*)this
 		       <<" ["<<GetFullName()<<"] : "
-		      << mFrom->bbGetFullName()<<" does not have output '"
+		      << mFrom->bbGetName()<<" does not have output '"
 		      <<mOutput<<"'");
 	  }	
 	bbtkMessage("debug",2," - From : Output '"<<mOutput<<"' exists"<<std::endl);
@@ -588,7 +576,7 @@ Connection::Connection(BlackBox::Pointer from, const std::string& output,
 	  {
 	     bbtkError("** Checking Connection "<<(void*)this
 		       <<" ["<<GetFullName()<<"] : "
-		       <<mFrom->bbGetFullName()<<" output '"
+		       <<mFrom->bbGetName()<<" output '"
 		       <<mOutput<<"' is not in OutputConnectorMap");
 	  }
 	bbtkMessage("debug",2," - From : Output '"<<mOutput
@@ -611,9 +599,8 @@ Connection::Connection(BlackBox::Pointer from, const std::string& output,
 	  {
 	    bbtkError("** Checking Connection "<<(void*)this
 		      <<" ["<<GetFullName()<<"] : "
-		      << "Connection ["<<GetFullName()<<"] : "
 		      <<" OutputConnector '"
-		      <<mOutput<<"' of "<<mFrom->bbGetFullName()
+		      <<mOutput<<"' of "<<mFrom->bbGetName()
 		      <<" does not point to this connection");
 	    
 	  }
@@ -632,13 +619,13 @@ Connection::Connection(BlackBox::Pointer from, const std::string& output,
 	//	std::cout << mTo << std::endl;
 	//	std::cout << mTo->bbGetDescriptor() << std::endl;
 	//	std::cout << mTo->bbGetDescriptor()->GetTypeName() << std::endl;
-	//	mTo->bbGetFullName();
-	bbtkMessage("debug",2," - To   : "<<mTo->bbGetFullName()<<std::endl);
+	//	mTo->bbGetName();
+	bbtkMessage("debug",2," - To   : "<<mTo->bbGetName()<<std::endl);
 	if (!mTo->bbHasInput(mInput))
 	  {
 	    bbtkError("** Checking Connection "<<(void*)this
 		      <<" ["<<GetFullName()<<"] : "
-		      <<mTo->bbGetFullName()<<" does not have input '"
+		      <<mTo->bbGetName()<<" does not have input '"
 		      <<mInput<<"'");
 	  }	
 	bbtkMessage("debug",2," - To   : Input '"<<mInput<<"' exists"<<std::endl);
@@ -648,7 +635,7 @@ Connection::Connection(BlackBox::Pointer from, const std::string& output,
 	  {
 	     bbtkError("** Checking Connection "<<(void*)this
 		       <<" ["<<GetFullName()<<"] : "
-		       <<mTo->bbGetFullName()<<" input '"
+		       <<mTo->bbGetName()<<" input '"
 		       <<mInput<<"' is not in InputConnectorMap");
 	  }
 	bbtkMessage("debug",2," - To   : Input '"<<mInput
@@ -658,9 +645,8 @@ Connection::Connection(BlackBox::Pointer from, const std::string& output,
 	  {
 	    bbtkError("** Checking Connection "<<(void*)this
 		      <<" ["<<GetFullName()<<"] : "
-		      <<"Connection "<<GetFullName()<<" : "
 		      <<" InputConnector '"
-		      <<mInput<<"' of "<<mTo->bbGetFullName()
+		      <<mInput<<"' of "<<mTo->bbGetName()
 		      <<" does not point to this connection");
     
 	  }