src/GraphExecutor/DataFlowExecutor_DataFlow.cxx

   1 using namespace std;
   2
   3 #include "DataFlowExecutor_DataFlow.hxx"
   4
   5 // Implementation de la classe GraphExecutor::Graph
   6
   7 GraphExecutor::DataFlow::DataFlow() :
   8   OutNode() {
   9   cdebug_in << "GraphExecutor::DataFlow::DataFlowExecutor()" << endl;
  10
  11   _theNamingService = NULL ;
  12
  13   cdebug_out << "GraphExecutor::DataFlow::DataFlowExecutor()" << endl;
  14 }
  15
  16 GraphExecutor::DataFlow::DataFlow( CORBA::ORB_ptr ORB,
  17                                    SALOME_NamingService* ptrNamingService ,
  18                                    const char *DataFlowName ,
  19                                    const char * DebugFileName ) :
  20   OutNode( ORB, ptrNamingService , DataFlowName , DebugFileName ) {
  21   cdebug_in << "GraphExecutor::DataFlow::DataFlow(" ;
  22   if ( DataFlowName ) {
  23     cdebug << DataFlowName ;
  24   }
  25   cdebug << ")" << endl;
  26
  27   _theNamingService = ptrNamingService ;
  28
  29   cdebug_out << "GraphExecutor::DataFlow::DataFlow" << endl;
  30 }
  31
  32 GraphExecutor::DataFlow::DataFlow(
  33                      CORBA::ORB_ptr ORB,
  34                      SALOME_NamingService* ptrNamingService ,
  35                      const SALOME_ModuleCatalog::Service& DataFlowService ,
  36                      const char *DataFlowComponentName ,
  37                      const char *DataFlowInterfaceName ,
  38                      const char *DataFlowName ,
  39                      const SUPERV::KindOfNode DataFlowkind ,
  40                      const SUPERV::SDate DataFlowFirstCreation ,
  41                      const SUPERV::SDate DataFlowLastModification ,
  42                      const char * DataFlowExecutorRelease ,
  43                      const char * DataFlowAuthor ,
  44                      const char * DataFlowComputer ,
  45                      const char * DataFlowComment ,
  46                      const char * DebugFileName ) :
  47      OutNode( ORB, ptrNamingService , DataFlowService , DataFlowComponentName ,
  48               DataFlowInterfaceName , DataFlowName , DataFlowkind ,
  49               DataFlowFirstCreation , DataFlowLastModification  ,
  50               DataFlowExecutorRelease , DataFlowAuthor ,
  51               DataFlowComputer , DataFlowComment , DebugFileName ) {
  52   cdebug_in << "GraphExecutor::DataFlow::DataFlow(" << DataFlowName << ")" << endl;
  53
  54   _theNamingService = ptrNamingService ;
  55
  56   cdebug_out << "GraphExecutor::DataFlow::DataFlow" << endl;
  57 } ;
  58
  59 GraphExecutor::DataFlow::~DataFlow() {
  60 //  delete _DataFlowNode ;
  61 //  delete _DataFlowDatas ;
  62 //  delete _GT ;
  63 }
  64
  65 bool GraphExecutor::DataFlow::Ping( const char *aNodeName ) {
  66   cdebug_in << "GraphExecutor::DataFlow::Ping" << aNodeName << " )" << endl;
  67   bool RetVal = false ;
  68   if ( GetGraphNode( aNodeName ) )
  69     RetVal = ((GraphExecutor::InNode *) GetGraphNode( aNodeName )->GetInNode())->Ping() ;
  70   cdebug_out << "GraphExecutor::DataFlow::Ping" << endl;
  71   return RetVal ;
  72 }
  73
  74 bool GraphExecutor::DataFlow::ContainerKill() {
  75   cdebug_in << "GraphExecutor::DataFlow::ContainerKill()" << endl;
  76   bool RetVal = GraphExecutor::OutNode::ContainerKill() ;
  77   cdebug_out << "GraphExecutor::DataFlow::ContainerKill()" << endl;
  78   return RetVal ;
  79 }
  80
  81 bool GraphExecutor::DataFlow::ContainerKill( const char *aNodeName ) {
  82 //  cdebug_in << "GraphExecutor::DataFlow::ContainerKill( " << aNodeName << " )"<< endl;
  83   bool RetVal = false ;
  84   GraphExecutor::InNode * aNode = ((GraphExecutor::InNode *) GetGraphNode( aNodeName )->GetInNode()) ;
  85   if ( aNode ) {
  86     RetVal = aNode->ContainerKill() ;
  87   }
  88 //  cdebug_out << "GraphExecutor::DataFlow::ContainerKill" << endl;
  89   return RetVal ;
  90 }
  91
  92 bool GraphExecutor::DataFlow::Kill() {
  93   cdebug_in << "GraphExecutor::DataFlow::Kill()" << endl;
  94   bool RetVal = GraphExecutor::OutNode::Kill() ;
  95   cdebug_out << "GraphExecutor::DataFlow::Kill()" << endl;
  96   return RetVal ;
  97 }
  98
  99 bool GraphExecutor::DataFlow::Kill( const char *aNodeName ) {
 100 //  cdebug_in << "GraphExecutor::DataFlow::Kill( " << aNodeName << " )"<< endl;
 101   bool RetVal = false ;
 102   GraphExecutor::InNode * aNode = ((GraphExecutor::InNode *) GetGraphNode( aNodeName )->GetInNode()) ;
 103   if ( aNode ) {
 104     RetVal = aNode->Kill() ;
 105   }
 106 //  cdebug_out << "GraphExecutor::DataFlow::Kill" << endl;
 107   return RetVal ;
 108 }
 109
 110 bool GraphExecutor::DataFlow::KillDone( const char *aNodeName ) {
 111 //  cdebug_in << "GraphExecutor::DataFlow::KillDone( " << aNodeName << " )"<< endl;
 112   bool RetVal = false ;
 113   GraphExecutor::InNode * aNode = ((GraphExecutor::InNode *) GetGraphNode( aNodeName )->GetInNode()) ;
 114   if ( aNode ) {
 115     RetVal = aNode->KillDone() ;
 116   }
 117 //  cdebug_out << "GraphExecutor::DataFlow::KillDone" << endl;
 118   return RetVal ;
 119 }
 120
 121 bool GraphExecutor::DataFlow::Suspend() {
 122   cdebug_in << "GraphExecutor::DataFlow::Suspend()" << endl;
 123   bool RetVal = false ;
 124   MESSAGE("Suspend not yet implemented.") ;
 125   cdebug << "Suspend not yet implemented." << endl;
 126   cdebug_out << "GraphExecutor::DataFlow::Suspend()" << endl;
 127   return RetVal ;
 128 }
 129
 130 bool GraphExecutor::DataFlow::Suspend( const char *aNodeName ) {
 131 //  cdebug_in << "GraphExecutor::DataFlow::Suspend( " << aNodeName << " )"<< endl;
 132   bool RetVal = false ;
 133   GraphExecutor::InNode * aNode = ((GraphExecutor::InNode *) GetGraphNode( aNodeName )->GetInNode()) ;
 134   if ( aNode ) {
 135     RetVal = aNode->Suspend() ;
 136   }
 137 //  cdebug_out << "GraphExecutor::DataFlow::Suspend" << endl;
 138   return RetVal ;
 139 }
 140
 141 bool GraphExecutor::DataFlow::SuspendDone() {
 142   cdebug_in << "GraphExecutor::DataFlow::SuspendDone()" << endl;
 143   bool RetVal = false ;
 144   cdebug << "Kill not yet implemented." << endl;
 145   cdebug_out << "GraphExecutor::DataFlow::SuspendDone()" << endl;
 146   return RetVal ;
 147 }
 148
 149 bool GraphExecutor::DataFlow::SuspendDone( const char *aNodeName ) {
 150 //  cdebug_in << "GraphExecutor::DataFlow::SuspendDone( " << aNodeName << " )"<< endl;
 151   bool RetVal = false ;
 152   GraphExecutor::InNode * aNode = ((GraphExecutor::InNode *) GetGraphNode( aNodeName )->GetInNode()) ;
 153   if ( aNode ) {
 154     RetVal = aNode->SuspendDone() ;
 155   }
 156 //  cdebug_out << "GraphExecutor::DataFlow::SuspendDone" << endl;
 157   return RetVal ;
 158 }
 159
 160 bool GraphExecutor::DataFlow::Resume() {
 161   cdebug_in << "GraphExecutor::DataFlow::Resume()" << endl;
 162   bool RetVal = false ;
 163   cdebug << "Resume not yet implemented." << endl;
 164   cdebug_out << "GraphExecutor::DataFlow::Resume()" << endl;
 165   return RetVal ;
 166 }
 167
 168 bool GraphExecutor::DataFlow::Resume( const char *aNodeName ) {
 169 //  cdebug_in << "GraphExecutor::DataFlow::Resume( " << aNodeName << " )"<< endl;
 170   bool RetVal = false ;
 171   GraphExecutor::InNode * aNode = ((GraphExecutor::InNode *) GetGraphNode( aNodeName )->GetInNode()) ;
 172   if ( aNode ) {
 173     RetVal = aNode->Resume() ;
 174   }
 175 //  cdebug_out << "GraphExecutor::DataFlow::Resume" << endl;
 176   return RetVal ;
 177 }
 178
 179 bool GraphExecutor::DataFlow::Stop() {
 180   cdebug_in << "GraphExecutor::DataFlow::Stop()" << endl;
 181   bool RetVal = GraphExecutor::OutNode::Stop() ;
 182   cdebug_out << "GraphExecutor::DataFlow::Stop()" << endl;
 183   return RetVal ;
 184 }
 185
 186 bool GraphExecutor::DataFlow::Stop( const char *aNodeName ) {
 187 //  cdebug_in << "GraphExecutor::DataFlow::Stop( " << aNodeName << " )"<< endl;
 188   bool RetVal = false ;
 189   GraphExecutor::InNode * aNode = ((GraphExecutor::InNode *) GetGraphNode( aNodeName )->GetInNode()) ;
 190   if ( aNode ) {
 191     RetVal = aNode->Stop() ;
 192   }
 193 //  cdebug_out << "GraphExecutor::DataFlow::Stop" << endl;
 194   return RetVal ;
 195 }
 196