SMH: 3.0.0 preparation = merged version (POLYWORK + RTVDEBUG01) + adopation for new GUI

[modules/superv.git] / src / GraphExecutor / DataFlowExecutor_OutNode.hxx

diff --git a/src/GraphExecutor/DataFlowExecutor_OutNode.hxx b/src/GraphExecutor/DataFlowExecutor_OutNode.hxx
index 277d93f027d727c155c8372c5a053d9a900fa9c9..5716375e421469aed9fd977a605f89d34b6f1d16 100644 (file)
--- a/src/GraphExecutor/DataFlowExecutor_OutNode.hxx
+++ b/src/GraphExecutor/DataFlowExecutor_OutNode.hxx
@@ -63,6 +63,7 @@ namespace GraphExecutor {
       pthread_cond_t                   _JoinWait ;
       bool                             _JustStarted ;
       int                              _Threads ; // Number of threads
+      long                             _CreatedThreads ; 
       int                              _SuspendedThreads ;
       list< char * >                   _EventNodes ;
       list< GraphExecutor::NodeEvent > _Events ;
@@ -171,6 +172,11 @@ namespace GraphExecutor {
                 return _Graph->ThreadNo() ; } ;
       long Thread( const char * NodeName ) ;
 
+      void IncrCreatedThreads() {
+           _CreatedThreads += 1 ; } ;
+      long CreatedThreads() {
+           return _CreatedThreads ; } ;
+
       bool PushEvent( GraphExecutor::InNode * aNode ,
                       GraphExecutor::NodeEvent anEvent ,
                       GraphExecutor::AutomatonState aState ) ;
@@ -232,8 +238,8 @@ namespace GraphExecutor {
       bool IsRunning( const char * NodeName ) ;
       bool IsDone( const char * NodeName ) ;
       bool IsSuspended( const char * NodeName ) ;
-      bool IsDone( const char * NodeName ,
-                   const char * ServiceParameterName ) ;
+      bool PortDone( const char * NodeName ,
+                     const char * ServiceParameterName ) ;
       long LastLevelDone() ;
 
       bool ReadyWait() ;
@@ -245,10 +251,12 @@ namespace GraphExecutor {
       bool DoneWait( const char * NodeName ) ;
       bool SuspendedWait( const char * NodeName ) ;
 
-      const CORBA::Any *GetInData( const char *ToNodeName ,
-                                   const char *ToParameterName ) ;
-      const CORBA::Any *GetOutData( const char *FromNodeName ,
-                                    const char *FromParameterName ) ;
+//JR 30.03.2005      const CORBA::Any *GetInData( const char *ToNodeName ,
+      const CORBA::Any GetInData( const char *ToNodeName ,
+                                  const char *ToParameterName ) ;
+//JR 30.03.2005      const CORBA::Any *GetOutData( const char *FromNodeName ,
+      const CORBA::Any GetOutData( const char *FromNodeName ,
+                                   const char *FromParameterName ) ;
       const long CpuUsed() ;
       const long CpuUsed( const char *aNodeName ) ;
   };