GraphExecutor.DataFlow

GraphExecutor.DataFlow Class Reference

#include <DataFlowExecutor_DataFlow.hxx>

Inheritance diagram for GraphExecutor.DataFlow:

Inheritance graph

Public Member Functions

 DataFlow ()
 DataFlow (CORBA::ORB_ptr ORB, SALOME_NamingService *ptrNamingService, const char *DataFlowName, const char *DebugFileName, const SUPERV::KindOfNode aKindOfNode)
 DataFlow (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=SUPERV::ComputingNode, const SUPERV::SDate DataFlowFirstCreation=SUPERV::SDate(), const SUPERV::SDate DataFlowLastModification=SUPERV::SDate(), const char *DataFlowEditorRelease=NULLSTRING, const char *DataFlowAuthor=NULLSTRING, const char *DataFlowComputer=NULLSTRING, const char *DataFlowComment=NULLSTRING, const char *DebugFileName=NULLSTRING)
virtual ~DataFlow ()
bool LoadDataFlow (const GraphBase::SGraph *aDataFlow)
const SALOME_ModuleCatalog::Service * NodeService (const char *NodeName)
bool AddInputData (const char *ToNodeName, const char *ToParameterName, const CORBA::Any aValue=CORBA::Any())
bool ChangeInputData (const char *ToNodeName, const char *ToParameterName, const CORBA::Any aValue=CORBA::Any())
bool InputOfAny (const char *ToServiceParameterName, const CORBA::Any &aValue, const bool SomeDataReady=true)
bool OutputOfAny (const char *aNodeName, const char *ToServiceParameterName, const CORBA::Any &aValue)
bool SetWaitingStates (const char *ToServiceParameterName)
bool IsValid ()
bool IsExecutable ()
bool Run (const bool AndSuspend)
long LastLevelDone ()
void State (GraphExecutor::AutomatonState aState)
SUPERV::GraphState State ()
SUPERV::GraphState State (const char *aNodeName)
SUPERV::GraphState State (const char *aNodeName, const char *anOutServiceParameterName)
long Thread ()
long Thread (const char *aNodeName)
GraphExecutor::AutomatonState AutomatonState ()
GraphExecutor::AutomatonState AutomatonState (const char *aNodeName)
SUPERV::ControlState ControlState ()
SUPERV::ControlState ControlState (const char *aNodeName)
void ControlClear ()
void ControlClear (const char *aNodeName)
bool Event (char **aNodeName, SUPERV::GraphEvent &anEvent, SUPERV::GraphState &aState, bool WithWait=true)
bool EventW (char **aNodeName, SUPERV::GraphEvent &anEvent, SUPERV::GraphState &aState)
long EventQSize ()
bool IsWaiting ()
bool IsReady ()
bool IsRunning ()
bool IsDone ()
bool IsSuspended ()
bool IsWaiting (const char *aNodeName)
bool IsReady (const char *aNodeName)
bool IsRunning (const char *aNodeName)
bool IsDone (const char *aNodeName)
bool IsSuspended (const char *aNodeName)
bool PortDone (const char *aNodeName, const char *anOutServiceParameterName)
const CORBA::Any GetInData (const char *ToNodeName, const char *ToParameterName)
const CORBA::Any GetOutData (const char *FromNodeName, const char *FromParameterName)
long Threads ()
bool ReadyWait ()
bool RunningWait ()
bool DoneWait ()
bool SuspendedWait ()
bool ReadyWait (const char *aNodeName)
bool RunningWait (const char *aNodeName)
bool DoneWait (const char *aNodeName)
bool SuspendedWait (const char *aNodeName)
bool Ping (const char *aNodeName)
bool ContainerKill ()
bool ContainerKill (const char *aNodeName)
bool Kill ()
bool Kill (const char *aNodeName)
bool KillDone (const char *aNodeName)
bool Suspend ()
bool Suspend (const char *aNodeName)
bool SuspendDone ()
bool SuspendDone (const char *aNodeName)
bool Resume ()
bool Resume (const char *aNodeName)
bool Stop ()
bool Stop (const char *aNodeName)
void Set_prof_debug (CORBA::ORB_ptr ORB, const char *DebugFileName)
GraphBase::StreamGraph * StreamGraph ()
GraphBase::StreamGraph * StreamGraph () const
GraphBase::Graph * Graph ()
GraphBase::Graph * Graph () const
char * Name ()
bool LoadInfo (const GraphBase::SNode &aDataFlowInfo)
GraphExecutor::InNode * 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)
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 SuspendedThreads ()
void JoinedWait ()
pthread_t ThreadNo ()
void IncrCreatedThreads ()
long CreatedThreads ()
bool PushEvent (GraphExecutor::InNode *aNode, GraphExecutor::NodeEvent anEvent, GraphExecutor::AutomatonState aState)
int GetListSize ()
bool StateWait (SUPERV::GraphState aState)
bool EventWait (char **aNodeName, SUPERV::GraphEvent &anEvent, SUPERV::GraphState &aState)
void EventList ()
void SendSomeDataReady (const char *aNodeName)
const char * StateName (GraphExecutor::AutomatonState aState)
SUPERV::GraphEvent AutomatonGraphEvent (GraphExecutor::NodeEvent anEvent)
SUPERV::GraphState AutomatonGraphState (GraphExecutor::AutomatonState anAutomatonState)
void NodeAborted (const char *aNodeName)
bool IsNodeAborted ()
void Done (bool aDone)
bool Done ()
bool IsKilled ()
bool IsStopped ()
const long CpuUsed ()
const long CpuUsed (const char *aNodeName)
void setRunFuncThread (pthread_t theThread)
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 Attributes

SALOME_NamingService * _theNamingService

Constructor & Destructor Documentation

GraphExecutor.DataFlow::DataFlow (   ) 
 

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

GraphExecutor.DataFlow::DataFlow (  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 = SUPERV::ComputingNode,
const SUPERV::SDate  DataFlowFirstCreation = SUPERV::SDate(),
const SUPERV::SDate  DataFlowLastModification = SUPERV::SDate(),
const char *  DataFlowEditorRelease = NULLSTRING,
const char *  DataFlowAuthor = NULLSTRING,
const char *  DataFlowComputer = NULLSTRING,
const char *  DataFlowComment = NULLSTRING,
const char *  DebugFileName = NULLSTRING
) 
 

GraphExecutor.DataFlow::~DataFlow (   )  [virtual]
 

Member Function Documentation

bool GraphExecutor.DataFlow.LoadDataFlow (  const GraphBase::SGraph *  aDataFlow  ) 
 

Reimplemented from GraphExecutor.OutNode.

const SALOME_ModuleCatalog::Service* GraphExecutor.DataFlow.NodeService (  const char *  NodeName  ) 
 

bool GraphExecutor.DataFlow.AddInputData (  const char *  ToNodeName,
const char *  ToParameterName,
const CORBA::Any  aValue = CORBA::Any()
) 
 

bool GraphExecutor.DataFlow.ChangeInputData (  const char *  ToNodeName,
const char *  ToParameterName,
const CORBA::Any  aValue = CORBA::Any()
) 
 

bool GraphExecutor.DataFlow::InputOfAny (  const char *  ToServiceParameterName,
const CORBA::Any &  aValue,
const bool  SomeDataReady = true
) 
 

bool GraphExecutor.DataFlow::OutputOfAny (  const char *  aNodeName,
const char *  ToServiceParameterName,
const CORBA::Any &  aValue
) 
 

bool GraphExecutor.DataFlow::SetWaitingStates (  const char *  ToServiceParameterName  ) 
 

bool GraphExecutor.DataFlow.IsValid (   ) 
 

Reimplemented from GraphExecutor.OutNode.

bool GraphExecutor.DataFlow.IsExecutable (   ) 
 

Reimplemented from GraphExecutor.OutNode.

bool GraphExecutor.DataFlow.Run (  const bool  AndSuspend  ) 
 

Reimplemented from GraphExecutor.OutNode.

long GraphExecutor.DataFlow.LastLevelDone (   ) 
 

Reimplemented from GraphExecutor.OutNode.

void GraphExecutor.DataFlow.State (  GraphExecutor::AutomatonState  aState  ) 
 

Reimplemented from GraphExecutor.OutNode.

SUPERV::GraphState GraphExecutor.DataFlow.State (   ) 
 

Reimplemented from GraphExecutor.OutNode.

SUPERV::GraphState GraphExecutor.DataFlow.State (  const char *  aNodeName  ) 
 

Reimplemented from GraphExecutor.OutNode.

SUPERV::GraphState GraphExecutor.DataFlow.State (  const char *  aNodeName,
const char *  anOutServiceParameterName
) 
 

Reimplemented from GraphExecutor.OutNode.

long GraphExecutor.DataFlow.Thread (   ) 
 

long GraphExecutor.DataFlow.Thread (  const char *  aNodeName  ) 
 

Reimplemented from GraphExecutor.OutNode.

GraphExecutor::AutomatonState GraphExecutor.DataFlow.AutomatonState (   ) 
 

Reimplemented from GraphExecutor.OutNode.

GraphExecutor::AutomatonState GraphExecutor.DataFlow.AutomatonState (  const char *  aNodeName  ) 
 

Reimplemented from GraphExecutor.OutNode.

SUPERV::ControlState GraphExecutor.DataFlow.ControlState (   ) 
 

Reimplemented from GraphExecutor.OutNode.

SUPERV::ControlState GraphExecutor.DataFlow.ControlState (  const char *  aNodeName  ) 
 

Reimplemented from GraphExecutor.OutNode.

void GraphExecutor.DataFlow.ControlClear (   ) 
 

Reimplemented from GraphExecutor.OutNode.

void GraphExecutor.DataFlow.ControlClear (  const char *  aNodeName  ) 
 

Reimplemented from GraphExecutor.OutNode.

bool GraphExecutor.DataFlow.Event (  char **  aNodeName,
SUPERV::GraphEvent &  anEvent,
SUPERV::GraphState &  aState,
bool  WithWait = true
) 
 

Reimplemented from GraphExecutor.OutNode.

bool GraphExecutor.DataFlow.EventW (  char **  aNodeName,
SUPERV::GraphEvent &  anEvent,
SUPERV::GraphState &  aState
) 
 

Reimplemented from GraphExecutor.OutNode.

long GraphExecutor.DataFlow.EventQSize (   ) 
 

Reimplemented from GraphExecutor.OutNode.

bool GraphExecutor.DataFlow.IsWaiting (   ) 
 

Reimplemented from GraphExecutor.OutNode.

bool GraphExecutor.DataFlow.IsReady (   ) 
 

Reimplemented from GraphExecutor.OutNode.

bool GraphExecutor.DataFlow.IsRunning (   ) 
 

Reimplemented from GraphExecutor.OutNode.

bool GraphExecutor.DataFlow.IsDone (   ) 
 

Reimplemented from GraphExecutor.OutNode.

bool GraphExecutor.DataFlow.IsSuspended (   ) 
 

Reimplemented from GraphExecutor.OutNode.

bool GraphExecutor.DataFlow.IsWaiting (  const char *  aNodeName  ) 
 

Reimplemented from GraphExecutor.OutNode.

bool GraphExecutor.DataFlow.IsReady (  const char *  aNodeName  ) 
 

Reimplemented from GraphExecutor.OutNode.

bool GraphExecutor.DataFlow.IsRunning (  const char *  aNodeName  ) 
 

Reimplemented from GraphExecutor.OutNode.

bool GraphExecutor.DataFlow.IsDone (  const char *  aNodeName  ) 
 

Reimplemented from GraphExecutor.OutNode.

bool GraphExecutor.DataFlow.IsSuspended (  const char *  aNodeName  ) 
 

Reimplemented from GraphExecutor.OutNode.

bool GraphExecutor.DataFlow.PortDone (  const char *  aNodeName,
const char *  anOutServiceParameterName
) 
 

Reimplemented from GraphExecutor.OutNode.

const CORBA::Any GraphExecutor.DataFlow.GetInData (  const char *  ToNodeName,
const char *  ToParameterName
) 
 

Reimplemented from GraphExecutor.OutNode.

const CORBA::Any GraphExecutor.DataFlow.GetOutData (  const char *  FromNodeName,
const char *  FromParameterName
) 
 

Reimplemented from GraphExecutor.OutNode.

long GraphExecutor.DataFlow.Threads (   ) 
 

Reimplemented from GraphExecutor.OutNode.

bool GraphExecutor.DataFlow.ReadyWait (   ) 
 

Reimplemented from GraphExecutor.OutNode.

bool GraphExecutor.DataFlow.RunningWait (   ) 
 

Reimplemented from GraphExecutor.OutNode.

bool GraphExecutor.DataFlow.DoneWait (   ) 
 

Reimplemented from GraphExecutor.OutNode.

bool GraphExecutor.DataFlow.SuspendedWait (   ) 
 

Reimplemented from GraphExecutor.OutNode.

bool GraphExecutor.DataFlow.ReadyWait (  const char *  aNodeName  ) 
 

Reimplemented from GraphExecutor.OutNode.

bool GraphExecutor.DataFlow.RunningWait (  const char *  aNodeName  ) 
 

Reimplemented from GraphExecutor.OutNode.

bool GraphExecutor.DataFlow.DoneWait (  const char *  aNodeName  ) 
 

Reimplemented from GraphExecutor.OutNode.

bool GraphExecutor.DataFlow.SuspendedWait (  const char *  aNodeName  ) 
 

Reimplemented from GraphExecutor.OutNode.

bool GraphExecutor.DataFlow::Ping (  const char *  aNodeName  ) 
 

bool GraphExecutor.DataFlow::ContainerKill (   ) 
 

Reimplemented from GraphExecutor.OutNode.

bool GraphExecutor.DataFlow::ContainerKill (  const char *  aNodeName  ) 
 

bool GraphExecutor.DataFlow::Kill (   ) 
 

Reimplemented from GraphExecutor.OutNode.

bool GraphExecutor.DataFlow::Kill (  const char *  aNodeName  ) 
 

bool GraphExecutor.DataFlow::KillDone (  const char *  aNodeName  ) 
 

bool GraphExecutor.DataFlow::Suspend (   ) 
 

Reimplemented from GraphExecutor.OutNode.

bool GraphExecutor.DataFlow::Suspend (  const char *  aNodeName  ) 
 

bool GraphExecutor.DataFlow::SuspendDone (   ) 
 

bool GraphExecutor.DataFlow::SuspendDone (  const char *  aNodeName  ) 
 

bool GraphExecutor.DataFlow::Resume (   ) 
 

Reimplemented from GraphExecutor.OutNode.

bool GraphExecutor.DataFlow::Resume (  const char *  aNodeName  ) 
 

bool GraphExecutor.DataFlow::Stop (   ) 
 

Reimplemented from GraphExecutor.OutNode.

bool GraphExecutor.DataFlow::Stop (  const char *  aNodeName  ) 
 

void GraphExecutor.OutNode::Set_prof_debug (  CORBA::ORB_ptr  ORB,
const char *  DebugFileName
)  [inherited]
 

GraphBase::StreamGraph* GraphExecutor.OutNode.StreamGraph (   )  [inherited]
 

GraphBase::StreamGraph* GraphExecutor.OutNode.StreamGraph (   )  const [inherited]
 

GraphBase::Graph* GraphExecutor.OutNode.Graph (   )  [inherited]
 

GraphBase::Graph* GraphExecutor.OutNode.Graph (   )  const [inherited]
 

char* GraphExecutor.OutNode.Name (   )  [inherited]
 

bool GraphExecutor.OutNode::LoadInfo (  const GraphBase::SNode &  aDataFlowInfo  )  [inherited]
 

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
)  [inherited]
 

void GraphExecutor.OutNode.PyInitialized (  bool  init  )  [inherited]
 

bool GraphExecutor.OutNode.PyInitialized (   )  [inherited]
 

void GraphExecutor.OutNode::CheckAllDone (   )  [inherited]
 

void GraphExecutor.OutNode::PThreadLock (  pthread_mutex_t *  aMutex,