X-Git-Url: https://git.creatis.insa-lyon.fr/pubgit/?a=blobdiff_plain;f=kernel%2Fsrc%2FbbtkConnection.cxx;h=e6ee23851e7288d08e4cfc37a460528bb797867d;hb=3dcc408acd2264664ca6431a501378ea64233dd6;hp=0b8fb9c11dc890b0ee3ffe9b5a24d491a9828e07;hpb=6575a389b71b1b85c79e4444885becb76ecf16e4;p=bbtk.git diff --git a/kernel/src/bbtkConnection.cxx b/kernel/src/bbtkConnection.cxx index 0b8fb9c..e6ee238 100644 --- a/kernel/src/bbtkConnection.cxx +++ b/kernel/src/bbtkConnection.cxx @@ -1,32 +1,39 @@ -/*========================================================================= +/* + # --------------------------------------------------------------------- + # + # Copyright (c) CREATIS (Centre de Recherche en Acquisition et Traitement de l'Image + # pour la SantÈ) + # Authors : Eduardo Davila, Frederic Cervenansky, Claire Mouton + # Previous Authors : Laurent Guigues, Jean-Pierre Roux + # CreaTools website : www.creatis.insa-lyon.fr/site/fr/creatools_accueil + # + # 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. + # ------------------------------------------------------------------------ */ + + +/*========================================================================= Program: bbtk Module: $RCSfile: bbtkConnection.cxx,v $ Language: C++ - Date: $Date: 2008/10/17 08:18:13 $ - Version: $Revision: 1.15 $ + Date: $Date: 2012/11/16 08:49:01 $ + Version: $Revision: 1.22 $ =========================================================================*/ -/* --------------------------------------------------------------------- - -* 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 @@ -37,9 +44,21 @@ #include "bbtkFactory.h" #include "bbtkBlackBox.h" #include "bbtkMessageManager.h" +#include "bbtkBlackBoxOutputConnector.h" + +#define bbtkCMessage(key,level,mess) \ + bbtkMessage(key,level,"["< Connection::Connection(\"" + bbtkDebugMessage("object",1,"##> Connection(\"" <bbGetName()<<"\",\""<bbGetName()<<"\",\""<bbGetName()<<"\",\""<bbGetName()<<"\",\""< Connection::Connection(\"" + bbtkDebugMessage("object",2,"==> Connection(\"" <bbGetName()<<"\",\""<bbGetName()<<"\",\""< Connection::Connection(\"" - <bbGetFullName()<<"\",\""<bbGetFullName()<<"\",\""< Connection(\"" + <bbGetName()<<"\",\""<bbGetName()<<"\",\""<bbGetOutputType(output) == typeid(Data) ) { - bbtkWarning("Connection '" - <bbGetName()<<"."<bbGetName()<<"."<() <<"> : type compatibility with '" @@ -122,7 +139,7 @@ Connection::Connection(BlackBox::Pointer from, const std::string& output, } else if ( to->bbGetInputType(input) == typeid(Data) ) { - bbtkDebugMessage("Kernel",8," -> '"< '"<()<<" : can receive any data" <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(\"" - <bbGetFullName()<<"\",\""<bbGetFullName()<<"\",\""<bbGetName()<<"\",\""<bbGetName()<<"\",\""< Connection::Connection(\"" + bbtkDebugMessage("object",2,"<== Connection(\"" <bbGetName()<<"\",\""<bbGetName()<<"\",\""< Connection::Connection(\"" + bbtkDebugMessage("object",1,"##> Connection(\"" <bbGetName()<<"\",\""<bbGetName()<<"\",\""<bbGetName()<<"\",\""<bbGetName()<<"\",\""< Connection::Connection(\"" + bbtkDebugMessage("object",2,"==> Connection(\"" <bbGetName()<<"\",\""<bbGetName()<<"\",\""< Connection::Connection(\"" - <bbGetFullName()<<"\",\""<bbGetFullName()<<"\",\""< Connection(\"" + <bbGetName()<<"\",\""<bbGetName()<<"\",\""<bbGetInputType(input) == typeid(Data) ) { - bbtkDebugMessage("Kernel",8," -> '"< '"<()<<" : can receive any data" <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(\"" - <bbGetFullName()<<"\",\""<bbGetFullName()<<"\",\""<bbGetName()<<"\",\""<bbGetName()<<"\",\""< Connection::Connection(\"" + bbtkDebugMessage("object",2,"==> Connection(\"" <bbGetName()<<"\",\""<bbGetName()<<"\",\""< Connection::~Connection() [" - < ~Connection()" + < Connection::BackwardUpdate() [" - <bbBackwardUpdate(GetThisPointer()); - - TransferData(); + bbtkCDebugMessage("process",4, + "===> Connection::RecursiveExecute()" + <bbSetModifiedStatus(); + /* + // If box from already executing : nothing to do + if (mFrom->bbGetExecuting()) + { + bbtkDebugMessage("process",3, + " -> "<bbGetName() + <<" already executing : abort"<bbRecursiveExecute(GetThisPointer()); - TransferData(); - mTo->bbForwardUpdate(this); - - bbtkDebugDecTab("process",2); + // Transfer status + IOStatus s = MODIFIED; + if ( mFrom->bbGetOutputConnector(mOutput).GetStatus() == OUTOFDATE) + { + s = OUTOFDATE; + } + mTo->bbGetInputConnector(mInput).SetStatus(s); + + bbtkCDebugMessage("process",4, + " --> '"<bbGetName()<<"."<bbGetInputConnector(mInput)<<"] " + <<"' new status '" + <() <<" which contains a <" <bbGetOutput(mOutput).type()) <<">"<bbGetInputType(mInput)) <<">"<bbGetOutput(mOutput).type() == typeid(void)) + { + bbtkCDebugMessage("data",3, + " -> Source is void : nothing to transfer!"<bbGetOutput(mOutput) + else if (mFrom->bbGetOutput(mOutput) .contains( mTo->bbGetInputType(mInput) ) ) { - bbtkDebugMessage("data",3, + bbtkCDebugMessage("data",3, " -> Equal types : transfer ok"<bbSetInput( mInput, mFrom->bbGetOutput(mOutput), @@ -427,7 +461,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" <bbSetInput("In",mFrom->bbGetOutput(mOutput),false); adaptor->bbExecute(); @@ -441,7 +475,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"< Connection::SetModifiedStatus() [" - <bbSetModifiedStatus(); + bbtkCDebugMessage("change",2, + "==> Connection::OnOutputChange(" + <bbGetInputConnectorMap().find("In")->second; + mAdaptor->bbSetStatusAndPropagate(ac,status); + } - mTo->bbSetModifiedStatus( mTo->bbGetInputConnectorMap().find(mInput)->second ); + mTo->bbSetStatusAndPropagate( mTo->bbGetInputConnectorMap().find(mInput)->second, status); - /* - bbtkDebugMessage("modified",2, - "==> Connection::SetModifiedStatus() [" - <bbGetFullName()<bbGetName()<bbHasOutput(mOutput)) { bbtkError("** Checking Connection "<<(void*)this <<" ["<bbGetFullName()<<" does not have output '" + << mFrom->bbGetName()<<" does not have output '" <bbGetFullName()<<" output '" + <bbGetName()<<" output '" <bbGetFullName() + <bbGetName() <<" does not point to this connection"); } @@ -591,13 +626,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 : "<bbGetFullName()<bbGetName(); + bbtkMessage("debug",2," - To : "<bbGetName()<bbHasInput(mInput)) { bbtkError("** Checking Connection "<<(void*)this <<" ["<bbGetFullName()<<" does not have input '" + <bbGetName()<<" does not have input '" <bbGetFullName()<<" input '" + <bbGetName()<<" input '" <bbGetFullName() + <bbGetName() <<" does not point to this connection"); }