3 #include "DataFlowExecutor_DataFlow.hxx"
5 // Implementation de la classe GraphExecutor::Graph
7 GraphExecutor::DataFlow::DataFlow() :
9 cdebug_in << "GraphExecutor::DataFlow::DataFlowExecutor()" << endl;
11 _theNamingService = NULL ;
13 cdebug_out << "GraphExecutor::DataFlow::DataFlowExecutor()" << endl;
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(" ;
23 cdebug << DataFlowName ;
25 cdebug << ")" << endl;
27 _theNamingService = ptrNamingService ;
29 cdebug_out << "GraphExecutor::DataFlow::DataFlow" << endl;
32 GraphExecutor::DataFlow::DataFlow(
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;
54 _theNamingService = ptrNamingService ;
56 cdebug_out << "GraphExecutor::DataFlow::DataFlow" << endl;
59 GraphExecutor::DataFlow::~DataFlow() {
60 // delete _DataFlowNode ;
61 // delete _DataFlowDatas ;
65 bool GraphExecutor::DataFlow::Ping( const char *aNodeName ) {
66 cdebug_in << "GraphExecutor::DataFlow::Ping" << aNodeName << " )" << endl;
68 if ( GetGraphNode( aNodeName ) )
69 RetVal = ((GraphExecutor::InNode *) GetGraphNode( aNodeName )->GetInNode())->Ping() ;
70 cdebug_out << "GraphExecutor::DataFlow::Ping" << endl;
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;
81 bool GraphExecutor::DataFlow::ContainerKill( const char *aNodeName ) {
82 // cdebug_in << "GraphExecutor::DataFlow::ContainerKill( " << aNodeName << " )"<< endl;
84 GraphExecutor::InNode * aNode = ((GraphExecutor::InNode *) GetGraphNode( aNodeName )->GetInNode()) ;
86 RetVal = aNode->ContainerKill() ;
88 // cdebug_out << "GraphExecutor::DataFlow::ContainerKill" << endl;
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;
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()) ;
104 RetVal = aNode->Kill() ;
106 // cdebug_out << "GraphExecutor::DataFlow::Kill" << endl;
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()) ;
115 RetVal = aNode->KillDone() ;
117 // cdebug_out << "GraphExecutor::DataFlow::KillDone" << endl;
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;
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()) ;
135 RetVal = aNode->Suspend() ;
137 // cdebug_out << "GraphExecutor::DataFlow::Suspend" << endl;
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;
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()) ;
154 RetVal = aNode->SuspendDone() ;
156 // cdebug_out << "GraphExecutor::DataFlow::SuspendDone" << endl;
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;
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()) ;
173 RetVal = aNode->Resume() ;
175 // cdebug_out << "GraphExecutor::DataFlow::Resume" << endl;
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;
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()) ;
191 RetVal = aNode->Stop() ;
193 // cdebug_out << "GraphExecutor::DataFlow::Stop" << endl;