src/GraphBase/DataFlowBase_DataNode.cxx

   1 //  SUPERV GraphBase : contains fondamental classes for Services, Input Ports, Output Ports Links and Nodes.
   2 //
   3 //  Copyright (C) 2003  OPEN CASCADE, EADS/CCR, LIP6, CEA/DEN,
   4 //  CEDRAT, EDF R&D, LEG, PRINCIPIA R&D, BUREAU VERITAS
   5 //
   6 //  This library is free software; you can redistribute it and/or
   7 //  modify it under the terms of the GNU Lesser General Public
   8 //  License as published by the Free Software Foundation; either
   9 //  version 2.1 of the License.
  10 //
  11 //  This library is distributed in the hope that it will be useful,
  12 //  but WITHOUT ANY WARRANTY; without even the implied warranty of
  13 //  MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the GNU
  14 //  Lesser General Public License for more details.
  15 //
  16 //  You should have received a copy of the GNU Lesser General Public
  17 //  License along with this library; if not, write to the Free Software
  18 //  Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA  02111-1307 USA
  19 //
  20 //  See http://www.opencascade.org/SALOME/ or email : webmaster.salome@opencascade.org
  21 //
  22 //
  23 //
  24 //  File   : DataFlowBase_DataNode.cxx
  25 //  Author : Jean Rahuel, CEA
  26 //  Module : SUPERV
  27 //  $Header:
  28
  29 using namespace std;
  30 #include "DataFlowBase_DataNode.hxx"
  31
  32 GraphBase::DataNode::DataNode() :
  33            GOTONode() {
  34   MESSAGE( "GraphBase::DataNode::DataNode" );
  35   _Created = false ;
  36 }
  37
  38 GraphBase::DataNode::DataNode( CORBA::ORB_ptr ORB ,
  39                                SALOME_NamingService* ptrNamingService ,
  40                                const char *DataFlowName ,
  41                                const SUPERV::KindOfNode DataFlowkind ,
  42                                int * Graph_prof_debug ,
  43                                ofstream * Graph_fdebug ) :
  44            GOTONode( ORB , ptrNamingService , DataFlowName , DataFlowkind , Graph_prof_debug , Graph_fdebug ) {
  45 //  MESSAGE( "GraphBase::DataNode::DataNode" );
  46   cdebug << "GraphBase::DataNode::DataNode" << endl ;
  47   _Created = false ;
  48 }
  49
  50 GraphBase::DataNode::DataNode( CORBA::ORB_ptr ORB ,
  51                                SALOME_NamingService* ptrNamingService ,
  52                                const SALOME_ModuleCatalog::Service& DataFlowService ,
  53                                const char *DataFlowName ,
  54                                const SUPERV::KindOfNode DataFlowkind ,
  55                                const SUPERV::SDate DataFlowFirstCreation ,
  56                                const SUPERV::SDate DataFlowLastModification ,
  57                                const char * DataFlowEditorRelease ,
  58                                const char * DataFlowAuthor ,
  59                                const char * DataFlowComment ) :
  60            GOTONode( ORB , ptrNamingService ,
  61                      DataFlowName , SUPERV::ListOfStrings() , DataFlowName , DataFlowkind ,
  62                      DataFlowFirstCreation , DataFlowLastModification  ,
  63                      DataFlowEditorRelease , DataFlowAuthor ,
  64                      DataFlowComment , false , 0 , 0) {
  65 //  MESSAGE( "GraphBase::DataNode::DataNode" );
  66 }
  67
  68 GraphBase::DataNode::~DataNode() {
  69 //  MESSAGE( "GraphBase::DataNode::~DataNode" );
  70   cdebug << "GraphBase::DataNode::~DataNode" << endl ;
  71 }
  72
  73 void GraphBase::DataNode::DataService( CORBA::ORB_ptr ORB ,
  74                                        SALOME_ModuleCatalog::Service aService ,
  75                                        int * Graph_prof_debug ,
  76                                        ofstream * Graph_fdebug ) {
  77   cdebug << "GraphBase::DataNode::DataService : DataFlowPortsOfNode of "
  78          << aService << endl ;
  79   DefPortsOfNode( ORB , aService , NamePtr() , Kind() ,
  80                   Graph_prof_debug , Graph_fdebug ) ;
  81
  82   if ( _Created ) {
  83     delete _DataFlowDataPorts ;
  84   }
  85   SALOME_ModuleCatalog::Service aReversedService ;
  86   aReversedService.ServiceName = aService.ServiceName ;
  87   aReversedService.ServiceinParameter = aService.ServiceoutParameter ;
  88   aReversedService.ServiceoutParameter = aService.ServiceinParameter ;
  89   _DataFlowDataPorts = new PortsOfNode() ;
  90   cdebug << "GraphBase::DataNode::DataService : Mirrored DataFlowPortsOfNode of "
  91          << aReversedService << endl ;
  92   _DataFlowDataPorts->DefPortsOfNode( ORB , aReversedService , NamePtr() , Kind() ,
  93                                       Graph_prof_debug , Graph_fdebug ) ;
  94   _Created = true ;
  95 }
  96
  97 int GraphBase::DataNode::CheckDataServerNodes() const {
  98
  99   cdebug << "GraphBase::DataNode::CheckDataServerNodes :" << endl;
 100
 101   int i , ierr = 0 ;
 102
 103   for ( i = 0 ; i < _DataFlowDataPorts->GetNodeOutPortsSize() ; i++ ) {
 104 // Not a BUG : Reversed Service of the graph
 105     const GraphBase::OutPort * anOutPort = _DataFlowDataPorts->GetNodeOutPort(i) ;
 106 //    if ( !anOutPort->IsGate() && !anOutPort->IsDataStream() && !anOutPort->IsDataConnected() ) {
 107     if ( !anOutPort->IsGate() && !anOutPort->IsDataConnected() ) {
 108       if ( anOutPort->IsExternConnected() && GraphMacroLevel() != 0 ) {
 109         cdebug << "InPort " << anOutPort->PortName() << " " << anOutPort->PortType() << " "
 110                << anOutPort->PortStatus() << " of DataFlow " << Name()
 111                << " is ExternConnected. GraphMacroLevel " << GraphMacroLevel() << endl ;
 112       }
 113       else {
 114         cdebug << "InPort " << anOutPort->PortName() << " " << anOutPort->PortType() << " "
 115                << anOutPort->PortStatus() << " of DataFlow " << Name() << " has NO Data. GraphMacroLevel "
 116                << GraphMacroLevel() << endl ;
 117         ierr++ ;
 118       }
 119     }
 120     else {
 121       cdebug << "InPort " << anOutPort->PortName() << " " << anOutPort->PortType() << " "
 122              << anOutPort->PortStatus() << " of DataFlow " << Name()  << " has Data : "
 123              << endl ;
 124     }
 125   }
 126
 127   for ( i = 0 ; i < _DataFlowDataPorts->GetNodeInPortsSize() ; i++ ) {
 128     if ( _DataFlowDataPorts->GetNodeInPort(i)->IsPortConnected() ) {
 129       cdebug << "OutPort " << _DataFlowDataPorts->GetNodeInPort(i)->PortName()
 130              << " of DataFlow " << Name()  << " is Connected" << endl ;
 131     }
 132     else {
 133       cdebug << "OutPort " << _DataFlowDataPorts->GetNodeInPort(i)->PortName()
 134              << " of DataFlow " << Name()  << " is NOT Connected" << endl ;
 135     }
 136   }
 137
 138   if ( ierr ) {
 139     cdebug << "In the DataFlow " << Name() << " " << ierr << " Some Input Data is missing" << endl ;
 140   }
 141
 142   return ierr ;
 143 }
 144
 145 void GraphBase::DataNode::ListDatas(ostream & f ) const {
 146   _DataFlowDataPorts->ListPorts( f , false ) ;
 147 }
 148
 149 void GraphBase::DataNode::DataNodeInfo(ostream & s ) const {
 150   s << *this ;
 151   s << "Ports :" << endl ;
 152   ListPorts( s , true ) ;
 153   s << "Datas :" << endl ;
 154   _DataFlowDataPorts->ListPorts( s , false ) ;
 155   s << ends ;
 156 }
 157
 158 // inlined :
 159 //GraphBase::OutPort * GraphBase::DataNode::GetChangeInDataNodePort( const char * DataFlowInPortName ) {
 160 //  return _DataFlowDataPorts->GetChangeOutPort( DataFlowInPortName ) ;
 161 //}
 162
 163 //GraphBase::InPort * GraphBase::DataNode::GetChangeOutDataNodePort( const char * DataFlowOutPortName ) {
 164 //  return _DataFlowDataPorts->GetChangeInPort( DataFlowOutPortName ) ;
 165 //}
 166