src/Supervision/INode_Impl.cxx

   1 //  SUPERV Supervision : contains the implementation of interfaces of SuperVision described in SUPERV.idl
   2 //
   3 //  Copyright (C) 2003  CEA/DEN, EDF R&D
   4 //
   5 //
   6 //
   7 //  File   : INode_Impl.cxx
   8 //  Author : Jean Rahuel
   9 //  Module : SUPERV
  10 //  $Header:
  11
  12 using namespace std;
  13 #include <stdio.h>
  14 #include <fstream>
  15 //#include <sstream>
  16 #include <string>
  17
  18 //#include "utilities.h"
  19
  20 #include "LNode_Impl.hxx"
  21
  22 INode_Impl::INode_Impl( CORBA::ORB_ptr orb ,
  23                        PortableServer::POA_ptr poa ,
  24                        PortableServer::ObjectId * contId ,
  25                        const char *instanceName ,
  26                        const char *interfaceName ,
  27                        const char *aDataFlowName ) :
  28 //  Engines_Component_i(orb, poa, contId, instanceName, interfaceName, false, false) {
  29   CNode_Impl( orb , poa , contId , instanceName , interfaceName , aDataFlowName ) {
  30 //  MESSAGE("INode_Impl::INode_Impl activate object instanceName("
  31 //          << instanceName << ") interfaceName(" << interfaceName << ") --> "
  32 //          << hex << (void *) this << dec )
  33 //  _thisObj = this ;
  34 //  _id = _poa->activate_object(_thisObj);
  35   MESSAGE( "INode_Impl::INode_Impl " << aDataFlowName );
  36   beginService( "INode_Impl::INode_Impl" );
  37   _Orb = CORBA::ORB::_duplicate(orb);
  38   _Poa = poa ;
  39   _ContId = contId ;
  40   endService( "INode_Impl::INode_Impl" );
  41 }
  42
  43 INode_Impl::INode_Impl() {
  44 }
  45
  46 INode_Impl::INode_Impl( CORBA::ORB_ptr orb ,
  47                         PortableServer::POA_ptr poa ,
  48                         PortableServer::ObjectId * contId ,
  49                         const char *instanceName ,
  50                         const char *interfaceName ,
  51                         GraphEditor::DataFlow * aDataFlowEditor ,
  52                         const char * FuncName ,
  53                         const SUPERV::ListOfStrings & aPythonFunction ,
  54                         const SUPERV::KindOfNode NodeKindOfNode ) :
  55 //  Engines_Component_i(orb, poa, contId, instanceName, interfaceName, false, false) {
  56   CNode_Impl( orb , poa , contId , instanceName , interfaceName , aDataFlowEditor , SALOME_ModuleCatalog::Service() , FuncName , NodeKindOfNode , FuncName , aPythonFunction ) {
  57   beginService( "INode_Impl::INode_Impl" );
  58   if ( FuncName ) {
  59 //    cout << "INode_Impl::CNode_Impl " << (void *) FuncName << " " << FuncName
  60 //         << " " << strlen( FuncName ) << endl ;
  61   }
  62   if ( NodeKindOfNode == SUPERV::InLineNode ) {
  63     MESSAGE( "INode_Impl::INode_Impl " << FuncName << " _poa->activate_object" );
  64     _thisObj = this ;
  65     _id = _poa->activate_object(_thisObj);
  66   }
  67   MESSAGE("INode_Impl::INode_Impl " << FuncName << " " << strlen( FuncName ) ) ;
  68   _Orb = CORBA::ORB::_duplicate(orb);
  69   _Poa = poa ;
  70   _ContId = contId ;
  71 //  DataFlowNode()->SetPythonFunction( FuncName , aPythonFunction ) ;
  72   endService( "INode_Impl::INode_Impl" );
  73 }
  74
  75 INode_Impl::INode_Impl( CORBA::ORB_ptr orb ,
  76                         PortableServer::POA_ptr poa ,
  77                         PortableServer::ObjectId * contId ,
  78                         const char *instanceName ,
  79                         const char *interfaceName ,
  80                         GraphEditor::DataFlow * aDataFlowEditor ,
  81                         const GraphBase::ListOfFuncName FuncName ,
  82                         const GraphBase::ListOfPythonFunctions aPythonFunction ,
  83                         const SUPERV::KindOfNode NodeKindOfNode ) :
  84 //  Engines_Component_i(orb, poa, contId, instanceName, interfaceName, false, false) {
  85   CNode_Impl( orb , poa , contId , instanceName , interfaceName , aDataFlowEditor , SALOME_ModuleCatalog::Service() , FuncName[0].c_str() , NodeKindOfNode , FuncName , aPythonFunction ) {
  86   beginService( "INode_Impl::INode_Impl" );
  87   if ( NodeKindOfNode == SUPERV::InLineNode ) {
  88     MESSAGE( "INode_Impl::INode_Impl " << FuncName[0] << " _poa->activate_object" );
  89     _thisObj = this ;
  90     _id = _poa->activate_object(_thisObj);
  91   }
  92   MESSAGE("INode_Impl::INode_Impl " << FuncName[0].c_str() << " " << strlen( FuncName[0].c_str() ) ) ;
  93   _Orb = CORBA::ORB::_duplicate(orb);
  94   _Poa = poa ;
  95   _ContId = contId ;
  96 //  DataFlowNode()->SetPythonFunction( FuncName , aPythonFunction ) ;
  97   endService( "INode_Impl::INode_Impl" );
  98 }
  99
 100 INode_Impl::INode_Impl( CORBA::ORB_ptr orb ,
 101                         PortableServer::POA_ptr poa ,
 102                         PortableServer::ObjectId * contId ,
 103                         const char *instanceName ,
 104                         const char *interfaceName ,
 105                         GraphEditor::DataFlow * aDataFlowEditor ,
 106                         GraphEditor::InNode * aDataFlowNode ) :
 107 //  Engines_Component_i(orb, poa, contId, instanceName, interfaceName, false, false) {
 108   CNode_Impl( orb , poa , contId , instanceName , interfaceName , aDataFlowEditor , aDataFlowNode ) {
 109   MESSAGE( DataFlowNode()->Name() << " " );
 110   beginService( "INode_Impl::INode_Impl" );
 111   if ( DataFlowNode()->IsInLineNode() ) {
 112     MESSAGE( "INode_Impl::INode_Impl " << DataFlowNode()->PyFuncName()
 113              << " _poa->activate_object" );
 114     _thisObj = this ;
 115     _id = _poa->activate_object(_thisObj);
 116   }
 117   _Orb = CORBA::ORB::_duplicate(orb);
 118   _Poa = poa ;
 119   _ContId = contId ;
 120   endService( "INode_Impl::INode_Impl" );
 121 }
 122
 123 INode_Impl::~INode_Impl() {
 124   beginService( "INode_Impl::~INode_Impl" );
 125   endService( "INode_Impl::~INode_Impl" );
 126 }
 127
 128 void INode_Impl::destroy() {
 129   beginService( "INode_Impl::Destroy" );
 130   if ( DataFlowEditor()->IsEditing() ) {
 131     if ( Delete() ) {
 132       _poa->deactivate_object(*_id) ;
 133       CORBA::release(_poa) ;
 134       delete(_id) ;
 135       _thisObj->_remove_ref();
 136     }
 137   }
 138   endService( "INode_Impl::Destroy" );
 139 }
 140
 141 bool INode_Impl::Delete() {
 142 //  beginService( "INode_Impl::Delete" );
 143   bool RetVal = false ;
 144   if ( DataFlowEditor()->IsEditing() ) {
 145     RetVal = DataFlowEditor()->RemoveNode( Name() ) ;
 146     if ( RetVal )
 147       RetVal = DataFlowEditor()->IsValid() ;
 148   }
 149 //  endService( "INode_Impl::Delete" );
 150   return RetVal ;
 151 }
 152
 153 void INode_Impl::SetPyFunction( const char * FuncName ,
 154                                 const SUPERV::ListOfStrings & aPyFunction ) {
 155   beginService( "INode_Impl::SetPyFunction" );
 156   if ( DataFlowEditor()->IsEditing() ) {
 157     DataFlowNode()->SetPythonFunction( FuncName , aPyFunction ) ;
 158   }
 159   endService( "INode_Impl::SetPyFunction" );
 160   return ;
 161 }
 162
 163 SUPERV::ListOfStrings * INode_Impl::PyFunction() {
 164   beginService( "INode_Impl::PyFunction" );
 165   SUPERV::ListOfStrings * aPyFunc = NULL ;
 166   if ( DataFlowEditor()->IsEditing() ) {
 167     aPyFunc = new SUPERV::ListOfStrings( *DataFlowNode()->PythonFunction() ) ;
 168   }
 169   else {
 170     aPyFunc = new SUPERV::ListOfStrings() ;
 171   }
 172   endService( "INode_Impl::PyFunction" );
 173   return aPyFunc ;
 174 }
 175
 176 char * INode_Impl::PyFuncName() {
 177   return CORBA::string_dup( DataFlowNode()->PyFuncName() ) ;
 178 }
 179
 180 #if 0
 181 bool INode_Impl::BusPort( const char * InOutParameterName ,
 182                          const char * InOutParameterType ,
 183                          SUPERV::Port_out InputPort ,
 184                          SUPERV::Port_out OutputPort ) {
 185   return BusPorts( InOutParameterName , InOutParameterType ,
 186                    InOutParameterName , InOutParameterType ,
 187                    InputPort , OutputPort ) ;
 188 }
 189
 190 bool INode_Impl::BusPorts( const char * InputParameterName ,
 191                           const char * InputParameterType ,
 192                           const char * OutputParameterName ,
 193                           const char * OutputParameterType ,
 194                           SUPERV::Port_out InputPort ,
 195                           SUPERV::Port_out OutputPort ) {
 196   beginService( "INode_Impl::BusPorts" );
 197   bool RetVal = false ;
 198   Port_Impl * myInPort = NULL ;
 199   Port_Impl * myOutPort = NULL ;
 200   SUPERV::Port_var Inobject = SUPERV::Port::_nil() ;
 201   SUPERV::Port_var Outobject = SUPERV::Port::_nil() ;
 202 //  if ( DataFlowNode()->GetInPort( InputParameterName ) ||
 203 //       DataFlowNode()->GetOutPort( OutputParameterName ) ) {
 204 //  }
 205 //  else {
 206     GraphBase::InPort * anInPort = DataFlowNode()->AddInPort( InputParameterName ,
 207                                                              InputParameterType ) ;
 208     if ( anInPort ) {
 209       myInPort = new Port_Impl( _Orb , _Poa , _ContId ,
 210                                 instanceName() , interfaceName() ,
 211                                 DataFlowEditor() ,
 212                                 DataFlowNode() ,
 213 //                                InputParameterName ) ;
 214                                 (GraphBase::Port * ) anInPort ,
 215                                 true ) ;
 216       GraphBase::OutPort * anOutPort = DataFlowNode()->AddOutPort( OutputParameterName ,
 217                                                                   OutputParameterType ) ;
 218       if ( anOutPort ) {
 219         const CORBA::Any * anAny = anOutPort->Value() ;
 220         myOutPort = new Port_Impl( _Orb , _Poa , _ContId ,
 221                                   instanceName() , interfaceName() ,
 222                                   DataFlowEditor() ,
 223                                   DataFlowNode() ,
 224 //                                  OutputParameterName ,
 225                                   (GraphBase::Port * ) anOutPort ,
 226                                   false ,
 227                                   anAny ) ;
 228         DataFlowNode()->InOutPort( anInPort , anOutPort ) ;
 229         RetVal = true ;
 230       }
 231     }
 232 //  }
 233   if ( RetVal && myInPort && myOutPort ) {
 234     if ( DataFlowNode()->CoupledNode() ) {
 235       GraphBase::InPort * anInPort ;
 236       anInPort = DataFlowNode()->CoupledNode()->AddInPort( OutputParameterName ,
 237                                                           OutputParameterType ) ;
 238       GraphBase::OutPort * anOutPort ;
 239       anOutPort = DataFlowNode()->CoupledNode()->AddOutPort( InputParameterName ,
 240                                                             InputParameterType ) ;
 241       DataFlowNode()->CoupledNode()->InOutPort( anInPort , anOutPort ) ;
 242     }
 243     PortableServer::ObjectId * id = myInPort->getId() ;
 244     CORBA::Object_var obj = _poa->id_to_reference(*id) ;
 245     Inobject = SUPERV::Port::_narrow(obj) ;
 246     InputPort = SUPERV::Port::_duplicate( Inobject ) ;
 247     id = myOutPort->getId() ;
 248     obj = _poa->id_to_reference(*id);
 249     Outobject = SUPERV::Port::_narrow(obj) ;
 250     OutputPort = SUPERV::Port::_duplicate( Outobject ) ;
 251   }
 252   endService( "INode_Impl::BusPorts" );
 253   return RetVal ;
 254 }
 255 #endif
 256