GraphExecutor.OutNode Class Reference

#include <DataFlowExecutor_OutNode.hxx>

Inheritance diagram for GraphExecutor.OutNode:

Inheritance graph

Public Member Functions

 OutNode ()
 OutNode (CORBA::ORB_ptr ORB, SALOME_NamingService *ptrNamingService, const char *DataFlowName, const char *DebugFileName, const SUPERV::KindOfNode aKindOfNode)
 OutNode (CORBA::ORB_ptr ORB, SALOME_NamingService *ptrNamingService, const SALOME_ModuleCatalog::Service &DataFlowService, const char *DataFlowComponentName, const char *DataFlowInterfaceName, const char *DataFlowName, const SUPERV::KindOfNode DataFlowkind, const SUPERV::SDate DataFlowFirstCreation, const SUPERV::SDate DataFlowLastModification, const char *DataFlowEditorRelease, const char *DataFlowAuthor, const char *DataFlowComputer, const char *DataFlowComment, const char *DebugFileName)
virtual ~OutNode ()
void Set_prof_debug (CORBA::ORB_ptr ORB, const char *DebugFileName)
GraphBase::StreamGraphStreamGraph ()
GraphBase::StreamGraphStreamGraph () const
GraphBase::GraphGraph ()
GraphBase::GraphGraph () const
char * Name ()
bool LoadDataFlow (const GraphBase::SGraph *aDataFlow)
bool LoadInfo (const GraphBase::SNode &aDataFlowInfo)
GraphExecutor::InNodeAddNode (const SALOME_ModuleCatalog::Service &NodeService, GraphBase::ListOfFuncName aFuncName, GraphBase::ListOfPythonFunctions aPythonFunction, const char *NodeComponentName, const char *NodeInterfaceName, const char *NodeName, const SUPERV::KindOfNode NodeKindOfNode=SUPERV::ComputingNode, const SUPERV::SDate NodeFirstCreation=SUPERV::SDate(), const SUPERV::SDate NodeLastModification=SUPERV::SDate(), const char *NodeEditorRelease=NULLSTRING, const char *NodeAuthor=NULLSTRING, const char *NodeComputer=NULLSTRING, const char *NodeComment=NULLSTRING, const int NodeX=0, const int NodeY=0)
bool IsValid ()
bool IsExecutable ()
bool Run (const bool AndSuspend)
void PyInitialized (bool init)
bool PyInitialized ()
void CheckAllDone ()
void PThreadLock (pthread_mutex_t *aMutex, char *errmsg)
void PThreadUnLock (pthread_mutex_t *aMutex, char *errmsg)
void PyThreadLock ()
void PyThreadUnLock ()
void NewThread ()
void ExitThread (pthread_t ThreadNumber=0)
void SuspendThread ()
void ResumeThread ()
long Threads ()
long SuspendedThreads ()
void JoinedWait ()
pthread_t ThreadNo ()
long Thread (const char *NodeName)
void IncrCreatedThreads ()
long CreatedThreads ()
bool PushEvent (GraphExecutor::InNode *aNode, GraphExecutor::NodeEvent anEvent, GraphExecutor::AutomatonState aState)
int GetListSize ()
bool StateWait (SUPERV::GraphState aState)
bool Event (char **aNodeName, SUPERV::GraphEvent &anEvent, SUPERV::GraphState &aState, bool WithWait)
bool EventW (char **aNodeName, SUPERV::GraphEvent &anEvent, SUPERV::GraphState &aState)
bool EventWait (char **aNodeName, SUPERV::GraphEvent &anEvent, SUPERV::GraphState &aState)
long EventQSize ()
void EventList ()
void SendSomeDataReady (const char *aNodeName)
void State (GraphExecutor::AutomatonState aState)
const char * StateName (GraphExecutor::AutomatonState aState)
SUPERV::GraphState State ()
SUPERV::GraphState State (const char *NodeName)
SUPERV::GraphState State (const char *NodeName, const char *ServiceParameterName)
SUPERV::GraphEvent AutomatonGraphEvent (GraphExecutor::NodeEvent anEvent)
SUPERV::GraphState AutomatonGraphState (GraphExecutor::AutomatonState anAutomatonState)
GraphExecutor::AutomatonState AutomatonState ()
GraphExecutor::AutomatonState AutomatonState (const char *NodeName)
SUPERV::ControlState ControlState ()
SUPERV::ControlState ControlState (const char *aNodeName)
void ControlClear ()
void ControlClear (const char *aNodeName)
bool ContainerKill ()
bool Suspend ()
bool Resume ()
bool Kill ()
bool Stop ()
void NodeAborted (const char *aNodeName)
bool IsNodeAborted ()
bool IsWaiting ()
bool IsReady ()
bool IsRunning ()
void Done (bool aDone)
bool Done ()
bool IsDone ()
bool IsSuspended ()
bool IsKilled ()
bool IsStopped ()
bool IsWaiting (const char *NodeName)
bool IsReady (const char *NodeName)
bool IsRunning (const char *NodeName)
bool IsDone (const char *NodeName)
bool IsSuspended (const char *NodeName)
bool PortDone (const char *NodeName, const char *ServiceParameterName)
long LastLevelDone ()
bool ReadyWait ()
bool RunningWait ()
bool DoneWait ()
bool SuspendedWait ()
bool ReadyWait (const char *NodeName)
bool RunningWait (const char *NodeName)
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)
const long CpuUsed ()
const long CpuUsed (const char *aNodeName)
void SetDebug (CORBA::ORB_ptr ORB, int *prof_debug, ofstream *fdebug)
char * ObjectToString (CORBA::Object_ptr obj) const
CORBA::Object_ptr StringToObject (char *obj) const
ostream & AnyValue (const CORBA::Any &anAny)

Data Fields

int * _prof_debug
ofstream * _fdebug

Private Member Functions

bool Valid ()
void UnValid ()
bool Executable ()
bool LoadNodes (const GraphBase::ListOfSNodes &aNodes)
bool LoadLinks (const GraphBase::ListOfSLinks &aLinks)
bool LoadDatas (const GraphBase::ListOfSLinks &aDatas)
void siftEvents ()

Private Attributes

GraphBase::StreamGraph_StreamGraph
GraphBase::Graph_Graph
int _Graph_prof_debug
bool _PyInitialized
bool _Valid
bool _Executable
GraphExecutor::AutomatonState _State
SUPERV::ControlState _ControlState
bool _Done
bool _NodeAborted
pthread_mutex_t _PyMutexWait
pthread_mutex_t _MutexWait
pthread_cond_t _EventWait
pthread_cond_t _JoinWait
bool _JustStarted
int _Threads
long _CreatedThreads
int _SuspendedThreads
list< char * > _EventNodes
list< GraphExecutor::NodeEvent_Events
list< GraphExecutor::AutomatonState_States
CORBA::ORB_ptr _Orb

Constructor & Destructor Documentation

GraphExecutor.OutNode::OutNode  ) 
 

GraphExecutor.OutNode::OutNode CORBA::ORB_ptr  ORB,
SALOME_NamingService *  ptrNamingService,
const char *  DataFlowName,
const char *  DebugFileName,
const SUPERV::KindOfNode  aKindOfNode
 

GraphExecutor.OutNode::OutNode CORBA::ORB_ptr  ORB,
SALOME_NamingService *  ptrNamingService,
const SALOME_ModuleCatalog::Service &  DataFlowService,
const char *  DataFlowComponentName,
const char *  DataFlowInterfaceName,
const char *  DataFlowName,
const SUPERV::KindOfNode  DataFlowkind,
const SUPERV::SDate  DataFlowFirstCreation,
const SUPERV::SDate  DataFlowLastModification,
const char *  DataFlowEditorRelease,
const char *  DataFlowAuthor,
const char *  DataFlowComputer,
const char *  DataFlowComment,
const char *  DebugFileName
 

GraphExecutor.OutNode::~OutNode  )  [virtual]
 


Member Function Documentation

bool GraphExecutor.OutNode::Valid  )  [private]
 

void GraphExecutor.OutNode.UnValid  )  [private]
 

bool GraphExecutor.OutNode::Executable  )  [private]
 

bool GraphExecutor.OutNode::LoadNodes const GraphBase::ListOfSNodes aNodes  )  [private]
 

bool GraphExecutor.OutNode::LoadLinks const GraphBase::ListOfSLinks aLinks  )  [private]
 

bool GraphExecutor.OutNode::LoadDatas const GraphBase::ListOfSLinks aDatas  )  [private]
 

void GraphExecutor.OutNode::siftEvents  )  [private]
 

void GraphExecutor.OutNode::Set_prof_debug CORBA::ORB_ptr  ORB,
const char *  DebugFileName
 

GraphBase::StreamGraph* GraphExecutor.OutNode.StreamGraph  ) 
 

GraphBase::StreamGraph* GraphExecutor.OutNode.StreamGraph  )  const
 

GraphBase::Graph* GraphExecutor.OutNode.Graph  ) 
 

GraphBase::Graph* GraphExecutor.OutNode.Graph  )  const
 

char* GraphExecutor.OutNode.Name  ) 
 

bool GraphExecutor.OutNode::LoadDataFlow const GraphBase::SGraph aDataFlow  ) 
 

Reimplemented in GraphExecutor.DataFlow.

bool GraphExecutor.OutNode::LoadInfo const GraphBase::SNode aDataFlowInfo  ) 
 

GraphExecutor::InNode * GraphExecutor.OutNode::AddNode const SALOME_ModuleCatalog::Service &  NodeService,
GraphBase::ListOfFuncName  aFuncName,
GraphBase::ListOfPythonFunctions  aPythonFunction,
const char *  NodeComponentName,
const char *  NodeInterfaceName,
const char *  NodeName,
const SUPERV::KindOfNode  NodeKindOfNode = SUPERV::ComputingNode,
const SUPERV::SDate  NodeFirstCreation = SUPERV::SDate(),
const SUPERV::SDate  NodeLastModification = SUPERV::SDate(),
const char *  NodeEditorRelease = NULLSTRING,
const char *  NodeAuthor = NULLSTRING,
const char *  NodeComputer = NULLSTRING,
const char *  NodeComment = NULLSTRING,
const int  NodeX = 0,
const int  NodeY = 0
 

bool GraphExecutor.OutNode.IsValid  ) 
 

Reimplemented in GraphExecutor.DataFlow.

bool GraphExecutor.OutNode.IsExecutable  ) 
 

Reimplemented in GraphExecutor.DataFlow.

bool GraphExecutor.OutNode::Run const bool  AndSuspend  ) 
 

Reimplemented in GraphExecutor.DataFlow.

void GraphExecutor.OutNode.PyInitialized bool  init  ) 
 

bool GraphExecutor.OutNode.PyInitialized  ) 
 

void GraphExecutor.OutNode::CheckAllDone  ) 
 

void GraphExecutor.OutNode::PThreadLock pthread_mutex_t *  aMutex,
char *  errmsg
 

void GraphExecutor.OutNode::PThreadUnLock pthread_mutex_t *  aMutex,
char *  errmsg
 

void GraphExecutor.OutNode::PyThreadLock  ) 
 

void GraphExecutor.OutNode::PyThreadUnLock  ) 
 

void GraphExecutor.OutNode::NewThread  ) 
 

void GraphExecutor.OutNode::ExitThread pthread_t  ThreadNumber = 0  ) 
 

void GraphExecutor.OutNode::SuspendThread  ) 
 

void GraphExecutor.OutNode::ResumeThread  ) 
 

long GraphExecutor.OutNode.Threads  ) 
 

Reimplemented in GraphExecutor.DataFlow.

long GraphExecutor.OutNode.SuspendedThreads  ) 
 

void GraphExecutor.OutNode::JoinedWait  ) 
 

pthread_t GraphExecutor.OutNode.ThreadNo  ) 
 

long GraphExecutor.OutNode::Thread const char *  NodeName  ) 
 

Reimplemented in GraphExecutor.DataFlow.

void GraphExecutor.OutNode.IncrCreatedThreads  ) 
 

long GraphExecutor.OutNode.CreatedThreads  ) 
 

bool GraphExecutor.OutNode::PushEvent GraphExecutor::InNode aNode,
GraphExecutor::NodeEvent  anEvent,
GraphExecutor::AutomatonState  aState
 

int GraphExecutor.OutNode::GetListSize  ) 
 

bool GraphExecutor.OutNode::StateWait SUPERV::GraphState  aState  ) 
 

bool GraphExecutor.OutNode::Event char **  aNodeName,
SUPERV::GraphEvent anEvent,
SUPERV::GraphState aState,
bool  WithWait
 

Reimplemented in GraphExecutor.DataFlow.

bool GraphExecutor.OutNode::EventW char **  aNodeName,
SUPERV::GraphEvent anEvent,
SUPERV::GraphState aState
 

Reimplemented in GraphExecutor.DataFlow.

bool GraphExecutor.OutNode::EventWait char **  aNodeName,
SUPERV::GraphEvent anEvent,
SUPERV::GraphState aState
 

long GraphExecutor.OutNode::EventQSize  ) 
 

Reimplemented in GraphExecutor.DataFlow.

void GraphExecutor.OutNode::EventList  ) 
 

void GraphExecutor.OutNode::SendSomeDataReady const char *  aNodeName  ) 
 

void GraphExecutor.OutNode::State GraphExecutor::AutomatonState  aState  ) 
 

Reimplemented in GraphExecutor.DataFlow.

const char* GraphExecutor.OutNode.StateName GraphExecutor::AutomatonState  aState  ) 
 

SUPERV::GraphState GraphExecutor.OutNode::State  ) 
 

Reimplemented in GraphExecutor.DataFlow.

SUPERV::GraphState GraphExecutor.OutNode::State const char *  NodeName  ) 
 

Reimplemented in GraphExecutor.DataFlow.

SUPERV::GraphState GraphExecutor.OutNode::State const char *  NodeName,
const char *  ServiceParameterName
 

Reimplemented in GraphExecutor.DataFlow.

SUPERV::GraphEvent GraphExecutor.OutNode::AutomatonGraphEvent GraphExecutor::NodeEvent  anEvent  ) 
 

SUPERV::GraphState GraphExecutor.OutNode::AutomatonGraphState GraphExecutor::AutomatonState  anAutomatonState  ) 
 

GraphExecutor::AutomatonState GraphExecutor.OutNode::AutomatonState  ) 
 

Reimplemented in GraphExecutor.DataFlow.

GraphExecutor::AutomatonState GraphExecutor.OutNode::AutomatonState const char *  NodeName  ) 
 

Reimplemented in GraphExecutor.DataFlow.

SUPERV::ControlState GraphExecutor.OutNode::ControlState  ) 
 

Reimplemented in GraphExecutor.DataFlow.

SUPERV::ControlState GraphExecutor.OutNode::ControlState const char *  aNodeName  ) 
 

Reimplemented in GraphExecutor.DataFlow.

void GraphExecutor.OutNode::ControlClear  ) 
 

Reimplemented in GraphExecutor.DataFlow.

void GraphExecutor.OutNode::ControlClear const char *  aNodeName  ) 
 

Reimplemented in GraphExecutor.DataFlow.

bool GraphExecutor.OutNode::ContainerKill  ) 
 

Reimplemented in GraphExecutor.DataFlow.

bool GraphExecutor.OutNode::Suspend  ) 
 

Reimplemented in GraphExecutor.DataFlow.

bool GraphExecutor.OutNode::Resume  ) 
 

Reimplemented in GraphExecutor.DataFlow.

bool GraphExecutor.OutNode::Kill  ) 
 

Reimplemented in GraphExecutor.DataFlow.

bool GraphExecutor.OutNode::Stop  ) 
 

Reimplemented in GraphExecutor.DataFlow.

void GraphExecutor.OutNode.NodeAborted const char *  aNodeName  ) 
 

bool GraphExecutor.OutNode.IsNodeAborted  ) 
 

bool GraphExecutor.OutNode::IsWaiting  ) 
 

Reimplemented in GraphExecutor.DataFlow.

bool GraphExecutor.OutNode::IsReady  ) 
 

Reimplemented in GraphExecutor.DataFlow.

bool GraphExecutor.OutNode::IsRunning  ) 
 

Reimplemented in GraphExecutor.DataFlow.

void GraphExecutor.OutNode.Done bool  aDone  ) 
 

bool GraphExecutor.OutNode.Done  ) 
 

bool GraphExecutor.OutNode::IsDone  ) 
 

Reimplemented in GraphExecutor.DataFlow.

bool GraphExecutor.OutNode::IsSuspended  ) 
 

Reimplemented in GraphExecutor.DataFlow.

bool GraphExecutor.OutNode::IsKilled  ) 
 

bool GraphExecutor.OutNode::IsStopped  ) 
 

bool GraphExecutor.OutNode::IsWaiting const char *  NodeName  ) 
 

Reimplemented in GraphExecutor.DataFlow.

bool GraphExecutor.OutNode::IsReady const char *