X-Git-Url: http://git.salome-platform.org/gitweb/?a=blobdiff_plain;f=src%2FGraphExecutor%2FDataFlowExecutor_OutNode.hxx;h=5716375e421469aed9fd977a605f89d34b6f1d16;hb=787989820026cbd647c7bdb7159beed8e12e4944;hp=277d93f027d727c155c8372c5a053d9a900fa9c9;hpb=f76e05ca31e340f77860feb7188fcdd4ae255edc;p=modules%2Fsuperv.git diff --git a/src/GraphExecutor/DataFlowExecutor_OutNode.hxx b/src/GraphExecutor/DataFlowExecutor_OutNode.hxx index 277d93f..5716375 100644 --- 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 ) ; };