]> SALOME platform Git repositories - modules/superv.git/blob - src/Supervision/GNode_Impl.cxx
Salome HOME
DCQ:prepare 2.0.0
[modules/superv.git] / src / Supervision / GNode_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   : GNode_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 "GNode_Impl.hxx"
21
22 GNode_Impl::GNode_Impl() {
23 }
24
25 GNode_Impl::GNode_Impl( CORBA::ORB_ptr orb ,
26                        PortableServer::POA_ptr poa ,
27                        PortableServer::ObjectId * contId , 
28                        const char *instanceName ,
29                        const char *interfaceName ,
30                        const char *aDataFlowName ,
31                        const SUPERV::KindOfNode aKindOfNode ) :
32   INode_Impl( orb , poa , contId , instanceName , interfaceName , aDataFlowName , aKindOfNode ) {
33 //  MESSAGE("GNode_Impl::GNode_Impl activate object instanceName("
34 //          << instanceName << ") interfaceName(" << interfaceName << ") --> "
35 //          << hex << (void *) this << dec )
36 //  _thisObj = this ;
37 //  _id = _poa->activate_object(_thisObj);
38 //  MESSAGE( "GNode_Impl::GNode_Impl " << aDataFlowName );
39 //  beginService( "GNode_Impl::GNode_Impl" );
40   _Orb = CORBA::ORB::_duplicate(orb);
41   _Poa = poa ;
42   _ContId = contId ;
43 //  endService( "INode_Impl::INode_Impl" );  
44 }
45
46 GNode_Impl::GNode_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 & PythonFunction ,
54                         const SUPERV::KindOfNode NodeKindOfNode ) :
55 //  Engines_Component_i(orb, poa, contId, instanceName, interfaceName, false, false) {
56   INode_Impl( orb , poa , contId , instanceName , interfaceName , aDataFlowEditor , FuncName , PythonFunction , NodeKindOfNode ) {
57 //  MESSAGE( NodeName << " " );
58 //  beginService( "GNode_Impl::GNode_Impl" );
59   if ( FuncName ) {
60 //    cout << "GNode_Impl::GNode_Impl " << (void *) FuncName << " " << FuncName
61 //         << " " << strlen( FuncName ) << endl ;
62   }
63   if ( NodeKindOfNode == SUPERV::GOTONode ) {
64     _thisObj = this ;
65     _id = _poa->activate_object(_thisObj);
66   }
67   _Orb = CORBA::ORB::_duplicate(orb);
68   _Poa = poa ;
69   _ContId = contId ;
70 //  DataFlowNode( DataFlowEditor()->AddNode( NodeService , NodeComponentName ,
71 //                                           NodeInterfaceName , NodeName ,
72 //                                           NodeKindOfNode ) );
73 //  DataFlowNode( DataFlowEditor()->AddNode( SALOME_ModuleCatalog::Service() ,
74 //                                           "" , "" , "" ,
75 //                                           NodeKindOfNode ) ) ;
76 //  endService( "GNode_Impl::GNode_Impl" );  
77 }
78
79 GNode_Impl::GNode_Impl( CORBA::ORB_ptr orb ,
80                         PortableServer::POA_ptr poa ,
81                         PortableServer::ObjectId * contId , 
82                         const char *instanceName ,
83                         const char *interfaceName ,
84                         GraphEditor::DataFlow * aDataFlowEditor ,
85                         GraphBase::ListOfFuncName FuncNameList ,
86                         GraphBase::ListOfPythonFunctions PythonFunctionList ,
87                         const SUPERV::KindOfNode NodeKindOfNode ) :
88 //  Engines_Component_i(orb, poa, contId, instanceName, interfaceName, false, false) {
89   INode_Impl( orb , poa , contId , instanceName , interfaceName , aDataFlowEditor , FuncNameList , PythonFunctionList , NodeKindOfNode ) {
90 //  MESSAGE( NodeName << " " );
91 //  beginService( "GNode_Impl::GNode_Impl" );
92   if ( NodeKindOfNode == SUPERV::GOTONode ) {
93     _thisObj = this ;
94     _id = _poa->activate_object(_thisObj);
95   }
96   _Orb = CORBA::ORB::_duplicate(orb);
97   _Poa = poa ;
98   _ContId = contId ;
99 //  DataFlowNode( DataFlowEditor()->AddNode( NodeService , NodeComponentName ,
100 //                                           NodeInterfaceName , NodeName ,
101 //                                           NodeKindOfNode ) );
102 //  DataFlowNode( DataFlowEditor()->AddNode( SALOME_ModuleCatalog::Service() ,
103 //                                           "" , "" , "" ,
104 //                                           NodeKindOfNode ) ) ;
105 //  endService( "GNode_Impl::GNode_Impl" );  
106 }
107
108 GNode_Impl::GNode_Impl( CORBA::ORB_ptr orb ,
109                       PortableServer::POA_ptr poa ,
110                       PortableServer::ObjectId * contId , 
111                       const char *instanceName ,
112                       const char *interfaceName ,
113                       GraphEditor::DataFlow * aDataFlowEditor ,
114                       GraphEditor::InNode * aDataFlowNode ) :
115 //  Engines_Component_i(orb, poa, contId, instanceName, interfaceName, false, false) {
116   INode_Impl( orb , poa , contId , instanceName , interfaceName , aDataFlowEditor , aDataFlowNode ) {
117 //  beginService( "GNode_Impl::GNode_Impl" );
118   if ( DataFlowNode() && DataFlowNode()->IsGOTONode() ) {
119 //    MESSAGE( "GNode_Impl::GNode_Impl " << DataFlowNode()->PyFuncName()
120 //             << " _poa->activate_object" );
121     _thisObj = this ;
122     _id = _poa->activate_object(_thisObj);
123   }
124   else {
125 //    MESSAGE( "GNode_Impl::GNode_Impl NO _poa->activate_object" );
126   }
127   _Orb = CORBA::ORB::_duplicate(orb);
128   _Poa = poa ;
129   _ContId = contId ;
130 //  endService( "GNode_Impl::GNode_Impl" );  
131 }
132
133 GNode_Impl::GNode_Impl( CORBA::ORB_ptr orb ,
134                       PortableServer::POA_ptr poa ,
135                       PortableServer::ObjectId * contId , 
136                       const char *instanceName ,
137                       const char *interfaceName ,
138                       GraphExecutor::DataFlow * aDataFlowExecutor ,
139                       GraphExecutor::InNode * aDataFlowExecutorNode ) :
140 //  Engines_Component_i(orb, poa, contId, instanceName, interfaceName, false, false) {
141   INode_Impl( orb , poa , contId , instanceName , interfaceName , aDataFlowExecutor , aDataFlowExecutorNode ) {
142 //  beginService( "GNode_Impl::GNode_Impl" );
143   if ( DataFlowExecutorNode() && DataFlowExecutorNode()->IsGOTONode() ) {
144 //    MESSAGE( "GNode_Impl::GNode_Impl " << DataFlowExecutorNode()->Name()
145 //             << " _poa->activate_object" );
146     _thisObj = this ;
147     _id = _poa->activate_object(_thisObj);
148   }
149   else {
150 //    MESSAGE( "GNode_Impl::GNode_Impl NO _poa->activate_object" );
151   }
152   _Orb = CORBA::ORB::_duplicate(orb);
153   _Poa = poa ;
154   _ContId = contId ;
155 //  endService( "GNode_Impl::GNode_Impl" );  
156 }
157
158 GNode_Impl::~GNode_Impl() {
159   beginService( "GNode_Impl::~GNode_Impl" );
160   endService( "GNode_Impl::~GNode_Impl" );
161 }
162
163 void GNode_Impl::destroy() {
164   beginService( "GNode_Impl::Destroy" );
165   if ( DataFlowEditor()->IsEditing() ) {
166     if ( Delete() ) {
167       _poa->deactivate_object(*_id) ;
168       CORBA::release(_poa) ;
169       delete(_id) ;
170       _thisObj->_remove_ref();
171     }
172   }
173 //  endService( "GNode_Impl::Destroy" );
174 }
175
176 bool GNode_Impl::Delete() {
177   beginService( "GNode_Impl::Delete" );
178   bool RetVal = false ;
179   if ( DataFlowEditor()->IsEditing() ) {
180     DeletePorts() ;
181     RetVal = DataFlowEditor()->RemoveNode( Name() ) ;
182     if ( RetVal )
183       RetVal = DataFlowEditor()->IsValid() ;
184   }
185   endService( "GNode_Impl::Delete" );
186   return RetVal ;
187 }
188
189 SUPERV::INode_ptr GNode_Impl::Coupled() {
190 //  beginService( "GNode_Impl::Coupled" );
191   SUPERV::INode_var iobject = SUPERV::INode::_nil() ;
192   if ( DataFlowNode() ) {
193     if ( DataFlowNode()->CoupledNode() ) {
194       if ( CORBA::is_nil( DataFlowNode()->CoupledNode()->ObjRef() ) ) {
195         INode_Impl * myNode = new INode_Impl( _Orb , _Poa , _ContId ,
196                                               instanceName() , interfaceName() ,
197                                               DataFlowEditor() ,
198                                               (GraphEditor::InNode *) DataFlowNode()->CoupledNode()->GetInNode() ) ;
199         PortableServer::ObjectId * id = myNode->getId() ;
200         CORBA::Object_var obj = _poa->id_to_reference(*id);
201         iobject = SUPERV::INode::_narrow(obj) ;
202         myNode->SetObjRef( SUPERV::INode::_duplicate( iobject ) ) ;
203       }
204       else {
205         iobject = SUPERV::INode::_narrow( DataFlowNode()->CoupledNode()->ObjRef() ) ;
206       }
207     }
208   }
209   else {
210     if ( DataFlowEditor()->Graph()->CoupledNode() ) {
211       if ( CORBA::is_nil( DataFlowEditor()->Graph()->CoupledNode()->ObjRef() ) ) {
212         INode_Impl * myNode = new INode_Impl( _Orb , _Poa , _ContId ,
213                                               instanceName() , interfaceName() ,
214                                               DataFlowEditor() ,
215                                               (GraphEditor::InNode *) DataFlowEditor()->Graph()->CoupledNode()->GetInNode() ) ;
216         PortableServer::ObjectId * id = myNode->getId() ;
217         CORBA::Object_var obj = _poa->id_to_reference(*id);
218         iobject = SUPERV::INode::_narrow(obj) ;
219         myNode->SetObjRef( SUPERV::INode::_duplicate( iobject ) ) ;
220       }
221       else {
222         iobject = SUPERV::INode::_narrow( DataFlowEditor()->Graph()->CoupledNode()->ObjRef() ) ;
223       }
224     }
225   }
226 //  endService( "GNode_Impl::Coupled" );
227   return SUPERV::INode::_duplicate( iobject ) ;
228 }
229