1 // SUPERV Supervision : contains the implementation of interfaces of SuperVision described in SUPERV.idl
3 // Copyright (C) 2003 OPEN CASCADE, EADS/CCR, LIP6, CEA/DEN,
4 // CEDRAT, EDF R&D, LEG, PRINCIPIA R&D, BUREAU VERITAS
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.
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.
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
20 // See http://www.opencascade.org/SALOME/ or email : webmaster.salome@opencascade.org
24 // File : Graph_Impl.hxx
25 // Author : Jean Rahuel
29 #ifndef _GRAPH_IMPL_HXX_
30 #define _GRAPH_IMPL_HXX_
32 //#include <iostream.h>
36 #include <SALOMEconfig.h>
37 #include "SALOME_Component_i.hxx"
38 #include "SALOME_LifeCycleCORBA.hxx"
40 #include "StreamLink_Impl.hxx"
41 #include "FNode_Impl.hxx"
42 #include "GNode_Impl.hxx"
43 #include "LNode_Impl.hxx"
44 #include "ELNode_Impl.hxx"
45 #include "SNode_Impl.hxx"
46 #include "ESNode_Impl.hxx"
48 #include "DataFlowEditor_DataFlow.hxx"
49 #include "DataFlowExecutor_DataFlow.hxx"
51 class Graph_Impl : public POA_SUPERV::Graph ,
56 PortableServer::POA_ptr _Poa ;
57 PortableServer::ObjectId * _ContId ;
59 SALOME_NamingService * _NamingService ;
60 char * _DebugFileName ;
62 pthread_mutex_t _MutexExecutorWait ;
63 // GraphExecutor::DataFlow * _DataFlowExecutor ;
65 SUPERV::Graph_var myServant; // mpv 23.12.2002: store servant of graph to get constant IOR
69 Graph_Impl( CORBA::ORB_ptr orb ,
70 PortableServer::POA_ptr poa ,
71 PortableServer::ObjectId * contId ,
72 const char *instanceName ,
73 const char *interfaceName ,
74 const char *aDataFlowName ,
75 const SUPERV::KindOfNode aKindOfNode ) ;
76 Graph_Impl( CORBA::ORB_ptr orb ,
77 PortableServer::POA_ptr poa ,
78 PortableServer::ObjectId * contId ,
79 const char *instanceName ,
80 const char *interfaceName ,
81 GraphEditor::DataFlow * DataFlowEditor ,
82 GraphEditor::InNode * DataFlowNode ) ;
83 virtual SUPERV::Graph_ptr Copy() ;
85 virtual ~Graph_Impl() ;
86 virtual void destroy() ;
88 void DebugFileName( char * aDebugFileName ) {
89 _DebugFileName = my_strdup( aDebugFileName ) ; } ;
90 char * DebugFileName() {
91 return _DebugFileName ; } ;
93 virtual char* getIOR();
95 virtual void ReadOnly() ;
97 virtual SUPERV::INode_ptr Node() ;
99 // virtual char * DataFlowInfo() ;
100 // virtual char * DataNodeInfo() ;
101 // virtual char * NodeInfo( const char * aNodeName ) ;
103 virtual GraphBase::ListOfSGraphs * GetGraphs() ;
105 virtual bool LoadGraphs( GraphBase::ListOfSGraphs *aListOfGraphs ) ;
106 virtual bool Import(const char * aXmlFile ) ;
108 virtual bool Export(const char * aXmlFile ) ;
110 virtual char * SavePY( bool importSuperV ) ;
112 virtual SUPERV::CNode_ptr CNode(
113 const SALOME_ModuleCatalog::Service &NodeService ) ;
114 virtual SUPERV::FNode_ptr FNode(
115 const char * NodeComponentName ,
116 const char * InterfaceName ,
117 const SALOME_ModuleCatalog::Service &NodeService ,
118 bool isCimpl ) ; // mkr : PAL11273 : C++ implementation by default
119 virtual SUPERV::INode_ptr INode(
120 const char * FuncName ,
121 const SUPERV::ListOfStrings & PythonFunction ) ;
122 virtual SUPERV::GNode_ptr GNode(
123 const char * FuncName ,
124 const SUPERV::ListOfStrings & PythonFunction ,
125 const char * anInLineNode ) ;
126 virtual SUPERV::LNode_ptr LNode(
127 const char * InitName ,
128 const SUPERV::ListOfStrings & InitFunction ,
129 const char * MoreName ,
130 const SUPERV::ListOfStrings & MoreFunction ,
131 const char * NextName ,
132 const SUPERV::ListOfStrings & NextFunction ,
133 SUPERV::INode_out anEndOfLoop ) ;
134 virtual SUPERV::SNode_ptr SNode(
135 const char * FuncName ,
136 const SUPERV::ListOfStrings & PythonFunction ,
137 SUPERV::INode_out anEndOfSwitch ) ;
139 SUPERV::Graph_var LoadDataFlows( GraphEditor::DataFlow * aDataFlowEditor ,
140 GraphBase::ListOfSGraphs * aListOfDataFlows ,
142 SUPERV::Graph_var LoadDataFlows( GraphExecutor::DataFlow * aDataFlowExecutor ,
143 GraphBase::ListOfSGraphs * aListOfDataFlows ,
145 virtual SUPERV::Graph_ptr MNode( const char * aXmlFileName ) ;
147 virtual SUPERV::Graph_ptr MNode( GraphEditor::DataFlow * aDataFlowEditor ,
148 GraphBase::ListOfSGraphs * aListOfDataFlows ) ;
150 virtual SUPERV::Graph_ptr GraphMNode( SUPERV::Graph_ptr aGraph ) ;
152 virtual SUPERV::Graph_ptr FlowObjRef() ;
154 virtual SUPERV::StreamGraph_ptr StreamObjRef() ;
156 virtual SUPERV::CNode_ptr Node( const char * NodeName );
158 virtual SUPERV::Link_ptr Link( SUPERV::Port_ptr OutPort ,
159 SUPERV::Port_ptr InPort ) ;
161 virtual SUPERV::ListOfNodes_var Graph_Impl::SetNode( SUPERV::ListOfNodes_var RetVal ,
162 GraphBase::ComputingNode * aNode ) ;
163 virtual SUPERV::ListOfNodes * Nodes() ;
164 virtual void SetNodeObjRef( GraphEditor::InNode * anInNode ) ;
166 virtual SUPERV::ListOfLinks * GLinks() ;
167 virtual SUPERV::ListOfLinks * Links( GraphBase::ComputingNode * aNode ,
168 const char * anInputParam ) ;
170 virtual Engines::Component_ptr ComponentRef( const char * aComputerContainer ,
171 const char * aComponentName ) ;
173 virtual char * Messages() ;
175 virtual bool IsValid() ;
176 virtual bool IsExecutable() ;
178 virtual bool IsEditing() ;
179 virtual CORBA::Boolean IsExecuting() ;
181 virtual bool IsReadOnly() ;
183 virtual CORBA::Long LevelMax() ;
184 virtual SUPERV::ListOfNodes * LevelNodes(CORBA::Long aLevel ) ;
185 virtual CORBA::Long ThreadsMax() ;
186 virtual CORBA::Long Threads() ;
187 virtual CORBA::Long SuspendedThreads() ;
189 virtual bool Run() ; // called on "Execute Graph" command
190 virtual bool Start() ; // called on "Execute Graph Step-by-Step" command
192 virtual bool Begin() ;
193 virtual CORBA::Long LastLevelDone() ;
195 virtual bool EventNoW( SUPERV::CNode_out aNode ,
196 SUPERV::GraphEvent & anEvent ,
197 SUPERV::GraphState & aState ) ;
198 virtual bool Event( SUPERV::CNode_out aNode ,
199 SUPERV::GraphEvent & anEvent ,
200 SUPERV::GraphState & aState ) ;
201 virtual bool EventW( SUPERV::CNode_out aNode ,
202 SUPERV::GraphEvent & anEvent ,
203 SUPERV::GraphState & aState ) ;
204 virtual CORBA::Long EventQSize() ;
206 virtual CORBA::Long SubGraphsNumber() ;
207 virtual SUPERV::ListOfNodes * SubGraphsNodes( CORBA::Long aSubGraphNumber ) ;
209 virtual bool Merge(const SUPERV::Graph_ptr aGraph ) ;
210 virtual bool Merge(const SUPERV::Graph_ptr aGraph , map< string , int > & aMapOfNodes ) ;
212 virtual SUPERV::StreamGraph_ptr ToStreamGraph() ;
214 virtual void Editing(); // Destroy Executor and use only Editor and its data model
217 bool run( const bool andSuspend = false ); // Run() calls run( false ), Start() calls run( true );