X-Git-Url: https://git.creatis.insa-lyon.fr/pubgit/?a=blobdiff_plain;f=kernel%2Fsrc%2FbbtkConnection.cxx;h=bc6b3b1c001561de5335fb3311f7d027118dea5f;hb=8822f9075c66dcf742b9edae47271bb46af6a9b7;hp=9c8487ace1fe496f21762f539e1f6bd1bc5fc93b;hpb=d7a6d341e2d11c175351212f0bf4812784dc57e5;p=bbtk.git

diff --git a/kernel/src/bbtkConnection.cxx b/kernel/src/bbtkConnection.cxx
index 9c8487a..bc6b3b1 100644
--- a/kernel/src/bbtkConnection.cxx
+++ b/kernel/src/bbtkConnection.cxx
@@ -1,20 +1,33 @@
-/*=========================================================================
-                                                                                
+/*=========================================================================                                                                               
   Program:   bbtk
   Module:    $RCSfile: bbtkConnection.cxx,v $
   Language:  C++
-  Date:      $Date: 2008/04/22 06:59:31 $
-  Version:   $Revision: 1.8 $
-                                                                                
-  Copyright (c) CREATIS (Centre de Recherche et d'Applications en Traitement de
-  l'Image). All rights reserved. See doc/license.txt or
-  http://www.creatis.insa-lyon.fr/Public/bbtk/License.html for details.
-                                                                                
-     This software is distributed WITHOUT ANY WARRANTY; without even
-     the implied warranty of MERCHANTABILITY or FITNESS FOR A PARTICULAR
-     PURPOSE.  See the above copyright notices for more information.
-                                                                                
+  Date:      $Date: 2008/12/11 09:50:35 $
+  Version:   $Revision: 1.19 $
 =========================================================================*/
+
+/* ---------------------------------------------------------------------
+
+* Copyright (c) CREATIS-LRMN (Centre de Recherche en Imagerie Medicale)
+* Authors : Eduardo Davila, Laurent Guigues, Jean-Pierre Roux
+*
+*  This software is governed by the CeCILL-B license under French law and 
+*  abiding by the rules of distribution of free software. You can  use, 
+*  modify and/ or redistribute the software under the terms of the CeCILL-B 
+*  license as circulated by CEA, CNRS and INRIA at the following URL 
+*  http://www.cecill.info/licences/Licence_CeCILL-B_V1-en.html 
+*  or in the file LICENSE.txt.
+*
+*  As a counterpart to the access to the source code and  rights to copy,
+*  modify and redistribute granted by the license, users are provided only
+*  with a limited warranty  and the software's author,  the holder of the
+*  economic rights,  and the successive licensors  have only  limited
+*  liability. 
+*
+*  The fact that you are presently reading this means that you have had
+*  knowledge of the CeCILL-B license and that you accept its terms.
+* ------------------------------------------------------------------------ */                                                                         
+
 /**
  *\file
  *\brief Class bbtk::Connection
@@ -24,9 +37,17 @@
 #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,
 				      BlackBox::Pointer to, 
@@ -45,6 +66,7 @@ namespace bbtk
 		     <<std::endl);
     return p;
   }
+  //==================================================================
 
   //==================================================================
   /// Ctor with the black box from and to and their input and output.
@@ -142,9 +164,11 @@ Connection::Connection(BlackBox::Pointer from, const std::string& output,
     mOutput = mOriginalOutput = output;
 
      // Lock this pointer !!!
-    Pointer p = MakePointer(this,true);
-    from->bbConnectOutput(output,p);
-    to->bbConnectInput(input,p);
+    //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(\""
@@ -159,6 +183,124 @@ Connection::Connection(BlackBox::Pointer from, const std::string& output,
   }
  //==================================================================
  
+  //==================================================================
+  Connection::Pointer Connection::New(BlackBox::Pointer from, 
+				      const std::string& output,
+				      BlackBox::Pointer to, 
+				      const std::string& input )
+  {
+    bbtkDebugMessage("object",1,"##> Connection::Connection(\""
+		     <<from->bbGetName()<<"\",\""<<output<<"\",\""
+		     <<to->bbGetName()<<"\",\""<<input<<"\")"
+		     <<std::endl);
+    Connection::Pointer p = 
+      MakePointer(new Connection(from,output,to,input));
+    bbtkDebugMessage("object",1,"<## Connection::Connection(\""
+		     <<from->bbGetName()<<"\",\""<<output<<"\",\""
+		     <<to->bbGetName()<<"\",\""<<input<<"\")"
+		     <<std::endl);
+    return p;
+  }
+  //==================================================================
+
+  //==================================================================
+  /// Ctor with the black box from and to and their input and output.
+/// Check the input and output compatibility
+Connection::Connection(BlackBox::Pointer from, const std::string& output,
+		       BlackBox::Pointer to, const std::string& input )
+  : mAdaptor(),
+      mFactory(),
+      mFromAny(false),
+      mToAny(false)
+  {
+    bbtkDebugMessage("object",2,"==> Connection::Connection(\""
+		     <<from->bbGetName()<<"\",\""<<output<<"\",\""
+		     <<to->bbGetName()<<"\",\""<<input<<"\")"
+		     <<std::endl);    
+
+    bbtkDebugMessage("connection",1,"==> Connection::Connection(\""
+		     <<from->bbGetFullName()<<"\",\""<<output<<"\",\""
+		     <<to->bbGetFullName()<<"\",\""<<input<<"\")"
+		     <<std::endl);    
+
+    
+
+    if (! from->bbHasOutput(output) )
+      {
+	bbtkError("The box \""<<from->bbGetTypeName()<<
+		  "\" has no output \""<<output<<"\"");
+      }
+    if (! to->bbHasInput(input) )
+      {
+	bbtkError("The box \""<<to->bbGetTypeName()<<
+		  "\" has no input \""<<input<<"\"");
+      } 
+
+    if (to->bbGetInputConnectorMap().find(input)->second->IsConnected())
+      {
+	bbtkError("The input \""<<input<<"\" of the box \""<<to->bbGetName()
+		  <<"\" is already connected");
+      }
+    
+    //  std::string t1 ( from->bbGetOutputType(output).name() );
+    //   std::string t2 ( to->bbGetInputType(input).name() );
+    // if  //( t1 != t2 ) 
+    if ( from->bbGetOutputType(output) !=
+	 to->bbGetInputType(input) )
+      {
+	if ( from->bbGetOutputType(output) == typeid(Data) )
+	  {
+	    bbtkWarning("Connection '"
+			<<GetFullName()
+			<<"' : '"<<from->bbGetName()<<"."<<output
+			<<"' is of type <"
+			<<HumanTypeName<Data>()
+			<<"> : type compatibility with '"
+			<<to->bbGetName()<<"."<<input
+			<<"' will be resolved at run time"
+			);
+	    mFromAny = true;
+	  }
+	else if (  to->bbGetInputType(input) == typeid(Data) )
+	  {   
+	    bbtkDebugMessage("Kernel",8," -> '"<<input<<"' type is "
+			     <<TypeName<Data>()<<" : can receive any data"
+			     <<std::endl);
+	    mToAny = true;
+	  }
+	else 
+	  {
+	    bbtkError("Connection created between different types without Factory provided");
+	  }
+      }
+
+
+    mFrom = from;
+    mOriginalFrom = from;
+    mTo = to;
+    mOriginalTo = to;
+    mInput = mOriginalInput = input;
+    mOutput = mOriginalOutput = output;
+
+     // Lock this pointer !!!
+    //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(\""
+		     <<from->bbGetFullName()<<"\",\""<<output<<"\",\""
+		     <<to->bbGetFullName()<<"\",\""<<input<<"\")"
+		     <<std::endl);    
+
+    bbtkDebugMessage("object",2,"==> Connection::Connection(\""
+		     <<from->bbGetName()<<"\",\""<<output<<"\",\""
+		     <<to->bbGetName()<<"\",\""<<input<<"\")"
+		     <<std::endl);    
+  }
+ //==================================================================
+ 
   //==================================================================
   /// Dtor 
   Connection::~Connection()
@@ -168,12 +310,11 @@ Connection::Connection(BlackBox::Pointer from, const std::string& output,
 		     <<GetFullName()<<"]"<<std::endl);
 
     if (mAdaptor) mAdaptor.reset();
-    mOriginalFrom.reset();
-    mOriginalTo.reset();
     if (mFrom!=0) 
       {
-	mFrom->bbDisconnectOutput(mOutput,
-				  GetThisPointer<Connection>());
+	mFrom->bbDisconnectOutput(mOutput,this);
+	//				  GetThisPointer<Connection>());
+	mFrom.reset();
       }
     else 
       {
@@ -181,15 +322,14 @@ Connection::Connection(BlackBox::Pointer from, const std::string& output,
       }
     if (mTo!=0) 
       {
-	mTo->bbDisconnectInput(mInput,
-			       GetThisPointer<Connection>());
+	mTo->bbDisconnectInput(mInput,this);//   GetThisPointer<Connection>());
+	mTo.reset();
       }
     else 
       {
 	bbtkInternalError("Connection::~Connection() : invalid final box pointer");
       }
-   mFrom.reset();
-    mTo.reset();
+
 
     bbtkDebugMessage("object",2,
 		     "<== Connection::~Connection() ["
@@ -198,51 +338,48 @@ Connection::Connection(BlackBox::Pointer from, const std::string& output,
   //==================================================================
   
   //==================================================================
-  /// Backward Update
-  IOStatus Connection::BackwardUpdate()
+  /// Recursive execution
+  void Connection::RecursiveExecute()
   {
-    bbtkDebugMessageInc("Process",2,
-			"Connection::BackwardUpdate() ["
-			<<GetFullName()<<"]"<<std::endl);
+    bbtkDebugMessage("process",4,
+		     "===> Connection::RecursiveExecute() ["
+		     <<GetFullName()<<"]"<<std::endl);
 
-    IOStatus s = UPTODATE;
-    s = mFrom->bbBackwardUpdate(GetThisPointer<Connection>());
+    mFrom->bbRecursiveExecute(GetThisPointer<Connection>());
 
     TransferData();
 
-    if (mAdaptor && (s==MODIFIED)) mAdaptor->bbSetModifiedStatus();
-
-    bbtkDebugDecTab("Process",2);
-
-    return s;
+    // Transfer status
+    IOStatus s = MODIFIED;
+    if ( mFrom->bbGetOutputConnector(mOutput).GetStatus() == OUTOFDATE) 
+      {
+	s = OUTOFDATE;
+      }
+    mTo->bbGetInputConnector(mInput).SetStatus(s);
+    
+    bbtkDebugMessage("process",4,
+		     " --> '"<<mTo->bbGetName()<<"."<<mInput
+		     <<" ["<<&mTo->bbGetInputConnector(mInput)<<"] "
+		     <<"' new status '"
+		     <<GetIOStatusString(s)
+		     <<"'"
+		     << std::endl);
+
+    bbtkDebugMessage("process",4,
+		     "<=== Connection::RecursiveExecute() ["
+		     <<GetFullName()<<"]"<<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("Process",3,
+    bbtkDebugMessageInc("data",3,
 			"Connection::TransferData() ["
 			<<GetFullName()<<"]"<<std::endl);
     
@@ -259,16 +396,13 @@ 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,
-			 "Connection::TransferData() ["
-			 <<GetFullName()<<"]"<<std::endl);
-	bbtkDebugMessage("Data",3,
+	bbtkDebugMessage("data",3,
 			 " * Source type is an "
 			 <<HumanTypeName<Data>()
 			 <<" which contains a <"
 			 <<HumanTypeName(mFrom->bbGetOutput(mOutput).type())
 			 <<">"<<std::endl);
-	bbtkDebugMessage("Data",3,
+	bbtkDebugMessage("data",3,
 			 " * Target type is <"
 			 <<HumanTypeName(mTo->bbGetInputType(mInput))
 			 <<">"<<std::endl);
@@ -277,7 +411,7 @@ Connection::Connection(BlackBox::Pointer from, const std::string& output,
 	if (mFrom->bbGetOutput(mOutput)
 	    .contains( mTo->bbGetInputType(mInput) ) )
 	  {
-	    bbtkDebugMessage("Data",3,
+	    bbtkDebugMessage("data",3,
 			     " -> Equal types : transfer ok"<<std::endl);
 	    mTo->bbSetInput( mInput, 
 			     mFrom->bbGetOutput(mOutput),
@@ -299,7 +433,7 @@ Connection::Connection(BlackBox::Pointer from, const std::string& output,
 	      }
 	    if (adaptor)  
 	      {
-		bbtkDebugMessage("Data",3," -> Adaptor found : using it"
+		bbtkDebugMessage("data",3," -> Adaptor found : using it"
 				 <<std::endl);
 		  adaptor->bbSetInput("In",mFrom->bbGetOutput(mOutput),false);
 		adaptor->bbExecute();
@@ -313,7 +447,7 @@ Connection::Connection(BlackBox::Pointer from, const std::string& output,
 		      (mTo->bbGetDescriptor()->GetInputDescriptor(mInput)
 		       ->IsPointerType()) )
 	      {
-		bbtkDebugMessage("Data",3,
+		bbtkDebugMessage("data",3,
 				 " -> No adaptor found but source and target types are both pointers : trying up or down cast"<<std::endl);
 		
 		void* nptr = 
@@ -350,23 +484,27 @@ Connection::Connection(BlackBox::Pointer from, const std::string& output,
 	mTo->bbSetInput(mInput, mFrom->bbGetOutput(mOutput),false);
       }
 
-    bbtkDebugDecTab("Process",3);
   }
   //==================================================================
-  
+
   //==================================================================
-  /// Modified
-  void Connection::SetModifiedStatus()
+  /// From.Output change propagation
+  void Connection::OnOutputChange(bbtk::BlackBox::Pointer, const std::string&, 
+				  IOStatus status)
   {
-    bbtkDebugMessageInc("Process",5,
-			"Connection::SetModifiedStatus() ["
-			<<GetFullName()<<"]"<<std::endl);
-    
-    if (mAdaptor) mAdaptor->bbSetModifiedStatus();
+    bbtkDebugMessage("change",2,
+		     "==> Connection::OnOutputChange("
+		     <<GetIOStatusString(status)<<") ["
+		     <<GetFullName()<<"]"<<std::endl);
+    if (mAdaptor) 
+      {
+	    BlackBoxInputConnector* ac = mAdaptor->bbGetInputConnectorMap().find("In")->second;
+	    mAdaptor->bbSetStatusAndPropagate(ac,status);
+      }
     
-    mTo->bbSetModifiedStatus(  mTo->bbGetInputConnectorMap().find(mInput)->second );
+    mTo->bbSetStatusAndPropagate( mTo->bbGetInputConnectorMap().find(mInput)->second, status);
     
-    bbtkDebugDecTab("Process",5);
+ 
   }
   //==================================================================
 
@@ -393,15 +531,15 @@ 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) 
       {
-	bbtkMessage("Debug",2," - From = 0"<<std::endl);
+	bbtkMessage("debug",2," - From = 0"<<std::endl);
       }
     else
       {
-	bbtkMessage("Debug",2," - From : "<<mFrom->bbGetFullName()<<std::endl);
+	bbtkMessage("debug",2," - From : "<<mFrom->bbGetFullName()<<std::endl);
 	if (!mFrom->bbHasOutput(mOutput))
 	  {
 	    bbtkError("** Checking Connection "<<(void*)this
@@ -409,7 +547,7 @@ Connection::Connection(BlackBox::Pointer from, const std::string& output,
 		      << mFrom->bbGetFullName()<<" does not have output '"
 		      <<mOutput<<"'");
 	  }	
-	bbtkMessage("Debug",2," - From : Output '"<<mOutput<<"' exists"<<std::endl);
+	bbtkMessage("debug",2," - From : Output '"<<mOutput<<"' exists"<<std::endl);
 	BlackBox::OutputConnectorMapType::const_iterator i 
 	  = mFrom->bbGetOutputConnectorMap().find(mOutput);
 	if (i== mFrom->bbGetOutputConnectorMap().end())
@@ -419,21 +557,22 @@ Connection::Connection(BlackBox::Pointer from, const std::string& output,
 		       <<mFrom->bbGetFullName()<<" output '"
 		       <<mOutput<<"' is not in OutputConnectorMap");
 	  }
-	bbtkMessage("Debug",2," - From : Output '"<<mOutput
+	bbtkMessage("debug",2," - From : Output '"<<mOutput
 		    <<"' is in OutputConnectorMap"<<std::endl);
 
-        std::vector< Connection::WeakPointer >::const_iterator j;
+        std::vector< Connection* >::const_iterator j;
+	/*
 	for (j  = i->second->GetConnectionVector().begin();
 	     j != i->second->GetConnectionVector().end();
 	     ++j)
 	  {
-	    if ((*j).lock()==GetThisPointer<Connection>()) break;
+	    if ((*j)==this) break;
 	  }
-	/*
+	*/
 	j = find(i->second->GetConnectionVector().begin(),
 		 i->second->GetConnectionVector().end(),
-		 GetThisPointer<Connection>());
-	*/
+		 this);
+       
 	if (j==i->second->GetConnectionVector().end())
 	  {
 	    bbtkError("** Checking Connection "<<(void*)this
@@ -444,23 +583,23 @@ Connection::Connection(BlackBox::Pointer from, const std::string& output,
 		      <<" does not point to this connection");
 	    
 	  }
-	bbtkMessage("Debug",2," - From : This connection is in OutputConnector connection vector"<<std::endl);
-	bbtkMessage("Debug",1," * Box from : Check successfull"<<std::endl);
+	bbtkMessage("debug",2," - From : This connection is in OutputConnector connection vector"<<std::endl);
+	bbtkMessage("debug",2," * Box from : Check successfull"<<std::endl);
 
       }
 
     if (mTo==0) 
       {
-	bbtkMessage("Debug",2," - To   = 0"<<std::endl);
+	bbtkMessage("debug",2," - To   = 0"<<std::endl);
       }
     else
       {
-	bbtkMessage("Debug",2," - To   : "<<mTo->bbGetName()<<std::endl);
+	bbtkMessage("debug",2," - To   : "<<mTo->bbGetName()<<std::endl);
 	//	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);
+	bbtkMessage("debug",2," - To   : "<<mTo->bbGetFullName()<<std::endl);
 	if (!mTo->bbHasInput(mInput))
 	  {
 	    bbtkError("** Checking Connection "<<(void*)this
@@ -468,7 +607,7 @@ Connection::Connection(BlackBox::Pointer from, const std::string& output,
 		      <<mTo->bbGetFullName()<<" does not have input '"
 		      <<mInput<<"'");
 	  }	
-	bbtkMessage("Debug",2," - To   : Input '"<<mInput<<"' exists"<<std::endl);
+	bbtkMessage("debug",2," - To   : Input '"<<mInput<<"' exists"<<std::endl);
 	BlackBox::InputConnectorMapType::const_iterator i 
 	  = mTo->bbGetInputConnectorMap().find(mInput);
 	if (i== mTo->bbGetInputConnectorMap().end())
@@ -478,7 +617,7 @@ Connection::Connection(BlackBox::Pointer from, const std::string& output,
 		       <<mTo->bbGetFullName()<<" input '"
 		       <<mInput<<"' is not in InputConnectorMap");
 	  }
-	bbtkMessage("Debug",2," - To   : Input '"<<mInput
+	bbtkMessage("debug",2," - To   : Input '"<<mInput
 		    <<"' is in InputConnectorMap"<<std::endl);
 
 	if (i->second->GetConnection()==0)
@@ -491,8 +630,8 @@ Connection::Connection(BlackBox::Pointer from, const std::string& output,
 		      <<" does not point to this connection");
     
 	  }
-	bbtkMessage("Debug",2," - To   : This connection is in InputConnector connection vector"<<std::endl);
-	bbtkMessage("Debug",1," * Box to   : Check successfull"<<std::endl);
+	bbtkMessage("debug",2," - To   : This connection is in InputConnector connection vector"<<std::endl);
+	bbtkMessage("debug",2," * Box to   : Check successfull"<<std::endl);
 
       }
   }