#include <GuiExecutor.hxx>

Inheritance diagram for YACS::HMI::GuiExecutor:

Collaboration diagram for YACS::HMI::GuiExecutor:

[legend]

Public Member Functions
	GuiExecutor (YACS::ENGINE::Proc *proc)

virtual	~GuiExecutor ()

void	closeContext ()

void	startResumeDataflow (bool initialize=false)

bool	checkEndOfDataflow (bool display=true)

void	killDataflow ()

void	suspendDataflow ()

void	resumeDataflow ()

void	stopDataflow ()

void	resetDataflow ()

void	setStepByStepMode ()

void	setContinueMode ()

void	setBreakpointMode ()

void	setStopOnError (bool aMode)

void	unsetStopOnError ()

void	saveState (const std::string &xmlFile)

void	setLoadStateFile (std::string xmlFile)

YACS_ORB::executionMode	getCurrentExecMode ()

int	getExecutorState ()

void	setBreakpointList (std::list< std::string > breakpointList)

void	addBreakpoint (std::string breakpoint)

void	removeBreakpoint (std::string breakpoint)

void	setNextStepList (std::list< std::string > nextStepList)

void	setInPortValue (YACS::ENGINE::DataPort *port, std::string value)

void	registerStatusObservers ()

bool	isRunning () const

bool	isStopOnError () const

void	setEngineRef (YACS_ORB::YACS_Gen_ptr ref)

YACS::ENGINE::Proc *	getProc ()

std::string	getErrorDetails (YACS::ENGINE::Node *node)

std::string	getErrorReport (YACS::ENGINE::Node *node)

std::string	getContainerLog ()

std::string	getContainerLog (YACS::ENGINE::Node *node)

void	shutdownProc ()

void	setShutdownLevel (int level)

int	getShutdownLevel ()

YACS::ExecutorState	updateSchema (std::string jobState)

virtual bool	event (QEvent *e)

Protected Member Functions
void	setBPList ()

Protected Attributes
YACS::ENGINE::Proc *	_proc

QtGuiContext *	_context

YACS_ORB::YACS_Gen_var	_engineRef

YACS_ORB::ProcExec_var	_procRef

YACS_ORB::Observer_var	_observerRef

YACS::ExecutionMode	_execMode

GuiObserver_i *	_serv

bool	_isRunning

bool	_isSuspended

bool	_isStopOnError

int	_shutdownLevel

std::list< std::string >	_breakpointList

std::string	_loadStateFile

Detailed Description

Definition at line 46 of file GuiExecutor.hxx.

Constructor & Destructor Documentation

◆ GuiExecutor()

GuiExecutor::GuiExecutor ( YACS::ENGINE::Proc * proc )

Definition at line 46 of file GuiExecutor.cxx.

 {
   DEBTRACE("GuiExecutor::GuiExecutor");
  
   _proc = proc;
   _context = QtGuiContext::getQtCurrent();
  
   _engineRef = YACS_ORB::YACS_Gen::_nil();
   _procRef = YACS_ORB::ProcExec::_nil();
   _observerRef = YACS_ORB::Observer::_nil();
  
   _execMode = YACS::CONTINUE;
   _serv = 0;
  
   _isRunning = false;
   _isSuspended = false;
   _isStopOnError = false;
   _shutdownLevel=1;
  
   _loadStateFile = "";
   _breakpointList.clear();
   if(getSSLMode())
   {
     KERNEL::getLauncherSA();
   }
 }

References driver_internal::_proc, YACS::CONTINUE, and DEBTRACE.

◆ ~GuiExecutor()

GuiExecutor::~GuiExecutor ( )

virtual

Definition at line 74 of file GuiExecutor.cxx.

 {
   DEBTRACE("GuiExecutor::~GuiExecutor");
 }

References DEBTRACE.

Member Function Documentation

◆ addBreakpoint()

void GuiExecutor::addBreakpoint ( std::string breakpoint )

Definition at line 348 of file GuiExecutor.cxx.

 {
   DEBTRACE("addBreakpoint " << breakpoint);
   if (!_context)
     {
       DEBTRACE("context closed");
       return;
     }
   _breakpointList.push_back(breakpoint);
   setBPList();
   if ((_execMode == YACS::CONTINUE) && ! _breakpointList.empty())
     {
       _context->getGMain()->_breakpointsModeAct->setChecked(true);
       setBreakpointMode();
     }
 }

References YACS::CONTINUE, and DEBTRACE.

Referenced by YACS::HMI::SchemaNodeItem::toggleState().

◆ checkEndOfDataflow()

bool GuiExecutor::checkEndOfDataflow ( bool display = true )

Definition at line 161 of file GuiExecutor.cxx.

 {
   DEBTRACE("GuiExecutor::checkEndOfDataFlow");
   if (_isRunning)
     {
       if (CORBA::is_nil(_procRef))
         {
           DEBTRACE("Runtime error: connection lost on a running scheme");
           _isRunning = false;
           return false;              
         }
       if (_procRef->isNotFinished())
         {
           DEBTRACE("Remote Execution Already running...");
           return false;
         }
       else
         {
           _isRunning = false;
           // --- TODO: cleaning on server ...
         }
     }
   return true;
 }

References DEBTRACE.

◆ closeContext()

void GuiExecutor::closeContext ( )

Definition at line 79 of file GuiExecutor.cxx.

 {
   DEBTRACE("GuiExecutor::closeContext");
   _context = 0;
 }

References DEBTRACE.

◆ event()

bool GuiExecutor::event ( QEvent * e )

virtual

Definition at line 498 of file GuiExecutor.cxx.

 {
   DEBTRACE("GuiExecutor::event");
   YACSEvent *yev = dynamic_cast<YACSEvent*>(e);
   if (!yev) return false;
   int numid = yev->getYACSEvent().first;
   string event = yev->getYACSEvent().second;
   DEBTRACE("<" << numid << "," << event << ">");
   if (!_context)
     {
       DEBTRACE("context closed");
       return true;
     }
   if (event == "executor") // --- Executor notification: state
     {
       int execState = _procRef->getExecutorState();
       list<string> nextSteps;
       if ((execState == YACS::WAITINGTASKS) || (execState == YACS::PAUSED))
         {
           YACS_ORB::stringArray_var nstp = _procRef->getTasksToLoad();
           for (CORBA::ULong i=0; i<nstp->length(); i++)
             nextSteps.push_back(nstp[i].in());
           if (execState == YACS::PAUSED)
             _isSuspended = true;
         }
       SubjectProc *sproc = _context->getSubjectProc();
       sproc->update(YACS::HMI::UPDATEPROGRESS, execState, sproc);
     }
   else // --- Node notification
     {
       if (! _serv->_engineToGuiMap.count(numid))
         return true;
       int state = _procRef->getNodeState(numid);
       int iGui = _serv->_engineToGuiMap[numid];
       YASSERT(_context->_mapOfExecSubjectNode.count(iGui));
       SubjectNode *snode = _context->_mapOfExecSubjectNode[iGui];
       DEBTRACE("node " << snode->getName() << " state=" << state);
  
       if (event == "progress") { // --- Update progress bar
         std::string progress = _procRef->getNodeProgress(numid);
         snode->setProgress( progress );
         snode->update(YACS::HMI::PROGRESS, state, snode);
       }
       else { // --- Update node ports
         YACS::ENGINE::Node *node = snode->getNode();
         list<InputPort*> inports = node->getLocalInputPorts();
         list<InputPort*>::iterator iti = inports.begin();
         for ( ; iti != inports.end(); ++iti)
           {
             string val = _procRef->getInPortValue(numid, (*iti)->getName().c_str());
             DEBTRACE("node " << snode->getName() << " inport " << (*iti)->getName() 
                      << " value " << val);
             YASSERT(_context->_mapOfSubjectDataPort.count(*iti));
             SubjectDataPort* port = _context->_mapOfSubjectDataPort[*iti];
             port->setExecValue(val);
             port->update(YACS::HMI::UPDATEPROGRESS, 0, port);
           }
         list<OutputPort*> outports = node->getLocalOutputPorts();
         list<OutputPort*>::iterator ito = outports.begin();
         for ( ; ito != outports.end(); ++ito)
           {
             string val = _procRef->getOutPortValue(numid, (*ito)->getName().c_str());
             DEBTRACE("node " << snode->getName() << " outport " << (*ito)->getName() 
                      << " value " << val);
             YASSERT(_context->_mapOfSubjectDataPort.count(*ito));
             SubjectDataPort* port = _context->_mapOfSubjectDataPort[*ito];
             port->setExecValue(val);
             port->update(YACS::HMI::UPDATEPROGRESS, 0, port);
           }
         snode->update(YACS::HMI::UPDATEPROGRESS, state, snode);
       }
    }
  
   return true;
 }

References DEBTRACE, YACS::ENGINE::Node::getLocalInputPorts(), YACS::ENGINE::Node::getLocalOutputPorts(), YACS::HMI::SubjectNode::getName(), YACS::HMI::SubjectNode::getNode(), YACS::HMI::YACSEvent::getYACSEvent(), yacsorb.CORBAEngineTest::i, YACS::PAUSED, YACS::HMI::PROGRESS, YACS::HMI::SubjectDataPort::setExecValue(), YACS::HMI::Subject::setProgress(), yacsorb.CORBAEngineTest::state, YACS::HMI::Subject::update(), YACS::HMI::SubjectNode::update(), YACS::HMI::UPDATEPROGRESS, YACS::WAITINGTASKS, and YASSERT.

◆ getContainerLog() [1/2]

std::string GuiExecutor::getContainerLog ( )

Definition at line 443 of file GuiExecutor.cxx.

 {
   DEBTRACE("GuiExecutor::getContainerLog");
   std::string msg="";
   if (!CORBA::is_nil(_engineRef))
     {
       Engines::Container_var cont= _engineRef->GetContainerRef();
       CORBA::String_var logname = cont->logfilename();
       DEBTRACE(logname);
       msg=logname;
       std::string::size_type pos = msg.find(":");
       msg=msg.substr(pos+1);
     }
   return msg;
 }

References DEBTRACE.

◆ getContainerLog() [2/2]

std::string GuiExecutor::getContainerLog ( YACS::ENGINE::Node * node )

Definition at line 459 of file GuiExecutor.cxx.

 {
   DEBTRACE("GuiExecutor::getContainerLog(YACS::ENGINE::Node* node)");
   std::string msg;
   if (_serv)
     {
       int engineId=_serv->getEngineId(node->getNumId());
       CORBA::String_var logname = _procRef->getContainerLog(engineId);
       msg=logname;
       std::string::size_type pos = msg.find(":");
       msg=msg.substr(pos+1);
     }
   return msg;
 }

References DEBTRACE, and YACS::ENGINE::Node::getNumId().

◆ getCurrentExecMode()

YACS_ORB::executionMode GuiExecutor::getCurrentExecMode ( )

Definition at line 306 of file GuiExecutor.cxx.

 {
   DEBTRACE("GuiExecutor::getCurrentExecMode");
   switch (_execMode)
     {
     case YACS::CONTINUE: return YACS_ORB::CONTINUE;
     case YACS::STEPBYSTEP: return YACS_ORB::STEPBYSTEP;
     case YACS::STOPBEFORENODES: return YACS_ORB::STOPBEFORENODES;
     default: return YACS_ORB::CONTINUE;
     }
 }

References YACS_ORB::CONTINUE, YACS::CONTINUE, DEBTRACE, YACS_ORB::STEPBYSTEP, YACS::STEPBYSTEP, YACS_ORB::STOPBEFORENODES, and YACS::STOPBEFORENODES.

◆ getErrorDetails()

std::string GuiExecutor::getErrorDetails ( YACS::ENGINE::Node * node )

Definition at line 421 of file GuiExecutor.cxx.

 {
   DEBTRACE("GuiExecutor::getErrorDetails");
   if (_serv)
   {
     int engineId=_serv->getEngineId(node->getNumId());
     return _procRef->getErrorDetails(engineId);
   }
   return "---";
 }

References DEBTRACE, and YACS::ENGINE::Node::getNumId().

◆ getErrorReport()

std::string GuiExecutor::getErrorReport ( YACS::ENGINE::Node * node )

Definition at line 432 of file GuiExecutor.cxx.

 {
   DEBTRACE("GuiExecutor::getErrorReport");
   if (_serv)
   {
     int engineId=_serv->getEngineId(node->getNumId());
     return _procRef->getErrorReport(engineId);
   }
   return "---";
 }

References DEBTRACE, and YACS::ENGINE::Node::getNumId().

Referenced by YACS::HMI::EditionProc::update().

◆ getExecutorState()

int GuiExecutor::getExecutorState ( )

Definition at line 318 of file GuiExecutor.cxx.

 {
   DEBTRACE("GuiExecutor::getExecutorState");
   if (_isRunning || !CORBA::is_nil(_procRef))
     return _procRef->getExecutorState();
   else if (CORBA::is_nil(_procRef))
     return YACS::NOTYETINITIALIZED;
   else
     return YACS::FINISHED;
 }

References DEBTRACE, YACS::FINISHED, and YACS::NOTYETINITIALIZED.

◆ getProc()

YACS::ENGINE::Proc* YACS::HMI::GuiExecutor::getProc ( )

inline

Definition at line 86 of file GuiExecutor.hxx.

86 { return _proc; };

References _proc.

◆ getShutdownLevel()

int YACS::HMI::GuiExecutor::getShutdownLevel ( )

inline

Definition at line 93 of file GuiExecutor.hxx.

93 {return _shutdownLevel;}

References _shutdownLevel.

Referenced by YACS::HMI::EditionProc::EditionProc().

◆ isRunning()

bool YACS::HMI::GuiExecutor::isRunning ( ) const

inline

Definition at line 82 of file GuiExecutor.hxx.

82 { return _isRunning; };

References _isRunning.

◆ isStopOnError()

bool YACS::HMI::GuiExecutor::isStopOnError ( ) const

inline

Definition at line 83 of file GuiExecutor.hxx.

83 { return _isStopOnError; }

References _isStopOnError.

◆ killDataflow()

void GuiExecutor::killDataflow ( )

Definition at line 186 of file GuiExecutor.cxx.

 {
   DEBTRACE("GuiExecutor::killDataflow");
   if (_isRunning)
     _procRef->stopExecution();
 }

References DEBTRACE.

◆ registerStatusObservers()

void GuiExecutor::registerStatusObservers ( )

Definition at line 386 of file GuiExecutor.cxx.

 {
   DEBTRACE("GuiExecutor::registerStatusObservers");
   if (CORBA::is_nil(_procRef))
     {
       DEBTRACE("Runtime error (yacsgui): Lost connection on YACS executor");
       return;
     }
   if (CORBA::is_nil(_observerRef))
     {
       _serv = new GuiObserver_i(_proc);
       _serv->SetImpl(this);
       _observerRef = _serv->_this();
     }
   DEBTRACE("---");
   _serv->SetRemoteProc(_procRef);
   _serv->setConversion();
   DEBTRACE("---");
   std::list<Node*> aNodeSet = _proc->getAllRecursiveConstituents();
   for ( std::list<Node*>::iterator it = aNodeSet.begin(); it != aNodeSet.end(); it++ )
     {
       _procRef->addObserver(_observerRef, _serv->getEngineId((*it)->getNumId()) , "status");
       _procRef->addObserver(_observerRef, _serv->getEngineId((*it)->getNumId()) , "progress");
     }
   _procRef->addObserver(_observerRef, _serv->getEngineId(_proc->getNumId()) , "executor"); 
 }

References driver_internal::_proc, and DEBTRACE.

◆ removeBreakpoint()

void GuiExecutor::removeBreakpoint ( std::string breakpoint )

Definition at line 365 of file GuiExecutor.cxx.

 {
   DEBTRACE("removeBreakpoint " << breakpoint);
   _breakpointList.remove(breakpoint);
   setBPList();
 }

References DEBTRACE.

Referenced by YACS::HMI::SchemaNodeItem::toggleState().

◆ resetDataflow()

void GuiExecutor::resetDataflow ( )

Definition at line 217 of file GuiExecutor.cxx.

 {
   DEBTRACE("GuiExecutor::resetDataflow");
   //update _isRunning
   checkEndOfDataflow();
   if (_isRunning)
     _procRef->stopExecution();
   checkEndOfDataflow();
  
   if (!_isRunning)
     {
       _isRunning = true;
       _procRef->setExecMode(YACS_ORB::STEPBYSTEP);
       //full reset: set all nodes in error to READY state and start execution
       _procRef->RestartFromState("");
     }
 }

References DEBTRACE, and YACS_ORB::STEPBYSTEP.

◆ resumeDataflow()

void GuiExecutor::resumeDataflow ( )

Definition at line 200 of file GuiExecutor.cxx.

 {
   DEBTRACE("GuiExecutor::resumeDataflow");
   if (_isRunning)
     {
       _procRef->setExecMode(getCurrentExecMode());
       _procRef->resumeCurrentBreakPoint();
     }
 }

References DEBTRACE.

◆ saveState()

void GuiExecutor::saveState ( const std::string & xmlFile )

Definition at line 285 of file GuiExecutor.cxx.

 {
   DEBTRACE("GuiExecutor::saveState " << xmlFile);
   bool StartFinish = (getExecutorState() == YACS::NOTYETINITIALIZED ||
                       getExecutorState() == YACS::FINISHED);
   if ( _isRunning ||
        !(CORBA::is_nil(_procRef)) && StartFinish ) {
     if ( !_procRef->saveState(xmlFile.c_str()) ) {
       string what = "Impossible to open file for writing: " + xmlFile;
       throw Exception(what);
     }
   }
 }

References DEBTRACE, YACS::FINISHED, and YACS::NOTYETINITIALIZED.

◆ setBPList()

void GuiExecutor::setBPList ( )

protected

Definition at line 574 of file GuiExecutor.cxx.

 {
   DEBTRACE("GuiExecutor::setBPList");
   if (_isRunning)
   {
     YACS_ORB::stringArray listOfBreakPoints;
     listOfBreakPoints.length(_breakpointList.size());
     int i=0;
     for (list<string>::iterator it = _breakpointList.begin(); it != _breakpointList.end(); ++it)
       listOfBreakPoints[i++] = (*it).c_str();
     _procRef->setListOfBreakPoints(listOfBreakPoints);
   }
 }

References DEBTRACE, and yacsorb.CORBAEngineTest::i.

◆ setBreakpointList()

void GuiExecutor::setBreakpointList ( std::list< std::string > breakpointList )

Definition at line 330 of file GuiExecutor.cxx.

 {
   DEBTRACE("GuiExecutor::setBreakpointList");
   if (!_context)
     {
       DEBTRACE("context closed");
       return;
     }
   _breakpointList.clear();
   _breakpointList = breakpointList;
   setBPList();
   if ((_execMode == YACS::CONTINUE) && ! _breakpointList.empty())
     {
       _context->getGMain()->_breakpointsModeAct->setChecked(true);
       setBreakpointMode();
     }
 }

References YACS::CONTINUE, and DEBTRACE.

◆ setBreakpointMode()

void GuiExecutor::setBreakpointMode ( )

Definition at line 252 of file GuiExecutor.cxx.

 {
   DEBTRACE("GuiExecutor::setBreakpointMode");
   _execMode = YACS::STOPBEFORENODES;
   if (_isRunning)
     _procRef->setExecMode(YACS_ORB::STOPBEFORENODES);
 }

References DEBTRACE, YACS_ORB::STOPBEFORENODES, and YACS::STOPBEFORENODES.

◆ setContinueMode()

void GuiExecutor::setContinueMode ( )

Definition at line 244 of file GuiExecutor.cxx.

 {
   DEBTRACE("GuiExecutor::setContinueMode");
   _execMode = YACS::CONTINUE;
   if (_isRunning)
     _procRef->setExecMode(YACS_ORB::CONTINUE);
 }

References YACS_ORB::CONTINUE, YACS::CONTINUE, and DEBTRACE.

◆ setEngineRef()

void GuiExecutor::setEngineRef ( YACS_ORB::YACS_Gen_ptr ref )

Definition at line 415 of file GuiExecutor.cxx.

 {
   DEBTRACE("GuiExecutor::setEngineRef");
   _engineRef = ref;
 }

References DEBTRACE, and gui.CONNECTOR::ref().

◆ setInPortValue()

void GuiExecutor::setInPortValue	(	YACS::ENGINE::DataPort *	port,
		std::string	value
	)

Definition at line 482 of file GuiExecutor.cxx.

 {
   DEBTRACE("GuiExecutor::setInPortValue");
  
   YACS::ENGINE::Node* node = port->getNode();
   YACS::ENGINE::ComposedNode* rootNode = node->getRootNode();
  
   std::string nodeName;
   if(rootNode == node)
     nodeName = node->getName();
   else
     nodeName = rootNode->getChildName(node);
  
   std::string msg = _procRef->setInPortValue(nodeName.c_str(), port->getName().c_str(), value.c_str());
 }

References DEBTRACE, YACS::ENGINE::ComposedNode::getChildName(), YACS::ENGINE::DataPort::getName(), YACS::ENGINE::Node::getName(), YACS::ENGINE::Port::getNode(), and YACS::ENGINE::Node::getRootNode().

Referenced by YACS::HMI::EditionElementaryNode::onCommitData(), and YACS::HMI::TreeView::onCommitData().

◆ setLoadStateFile()

void GuiExecutor::setLoadStateFile ( std::string xmlFile )

Definition at line 299 of file GuiExecutor.cxx.

 {
   DEBTRACE("GuiExecutor::setLoadStateFile " << xmlFile);
   _loadStateFile = xmlFile;
 }

References DEBTRACE.

Referenced by YACS::HMI::GenericGui::onRunLoadedSchema().

◆ setNextStepList()

void GuiExecutor::setNextStepList ( std::list< std::string > nextStepList )

Definition at line 372 of file GuiExecutor.cxx.

 {
   DEBTRACE("GuiExecutor::setNextStepList");
   if (_isRunning)
     {
       YACS_ORB::stringArray listOfNextStep;
       listOfNextStep.length(nextStepList.size());
       int i=0;
       for (list<string>::iterator it = nextStepList.begin(); it != nextStepList.end(); ++it)
         listOfNextStep[i++] = (*it).c_str();
       _procRef->setStepsToExecute(listOfNextStep);
     }
 }

References DEBTRACE, and yacsorb.CORBAEngineTest::i.

◆ setShutdownLevel()

void YACS::HMI::GuiExecutor::setShutdownLevel ( int level )

inline

Definition at line 92 of file GuiExecutor.hxx.

92 {_shutdownLevel=level;}

References _shutdownLevel.

Referenced by YACS::HMI::EditionProc::onLevelChange().

◆ setStepByStepMode()

void GuiExecutor::setStepByStepMode ( )

Definition at line 236 of file GuiExecutor.cxx.

 {
   DEBTRACE("GuiExecutor::setStepByStepMode");
   _execMode = YACS::STEPBYSTEP;
   if (_isRunning)
     _procRef->setExecMode(YACS_ORB::STEPBYSTEP);
 }

References DEBTRACE, YACS_ORB::STEPBYSTEP, and YACS::STEPBYSTEP.

◆ setStopOnError()

void GuiExecutor::setStopOnError ( bool aMode )

Definition at line 260 of file GuiExecutor.cxx.

 {
   DEBTRACE("GuiExecutor::setStopOnError " << aMode);
   if (_isRunning)
     {
 #ifdef WIN32
       _procRef->setStopOnError(aMode, (getenv("TEMP") + string("\\dumpStateOnError_") + getenv("USER") + string(".xml")).c_str());
 #else
       _procRef->setStopOnError(aMode, (string("/tmp/dumpStateOnError_") + getenv("USER") + string(".xml")).c_str());
 #endif
       _isStopOnError = true;
     }
 }

References DEBTRACE.

Referenced by YACS::HMI::GenericGui::onRunLoadedSchema().

◆ shutdownProc()

void GuiExecutor::shutdownProc ( )

Definition at line 474 of file GuiExecutor.cxx.

 {
   DEBTRACE("GuiExecutor::shutdownProc " << _shutdownLevel << "," << _isRunning);
   checkEndOfDataflow();
   if (!_isRunning)
     _procRef->shutdownProc(_shutdownLevel);
 }

References DEBTRACE.

◆ startResumeDataflow()

void GuiExecutor::startResumeDataflow ( bool initialize = false )

Definition at line 85 of file GuiExecutor.cxx.

 {
   DEBTRACE("GuiExecutor::runDataflow " << initialize);
   if (!_context)
     {
       DEBTRACE("context closed");
       return;
     }
   if (CORBA::is_nil(_engineRef))
     {
       DEBTRACE("Create YACS ORB engine!");
       YACS::ENGINE::RuntimeSALOME* runTime = YACS::ENGINE::getSALOMERuntime();
       CORBA::ORB_ptr orb = runTime->getOrb();
       SALOME_NamingService_Wrapper namingService(orb);
       //int iii(0); std::cin >> iii;
       {
         SALOME_LifeCycleCORBA lcc(&namingService);
         ostringstream containerName;
         containerName << "localhost/YACSContainer";
         Engines::EngineComponent_var comp = lcc.FindOrLoad_Component(containerName.str().c_str(), "YACS" );
         _engineRef =YACS_ORB::YACS_Gen::_narrow(comp);
         YASSERT(!CORBA::is_nil(_engineRef));
       }
     }
  
   checkEndOfDataflow(); // --- to allow change of the _isRunning state
  
   if (_isRunning)
     {
       if (_isSuspended)
         {
           _procRef->setExecMode(getCurrentExecMode());
           _procRef->resumeCurrentBreakPoint();
           _isSuspended = false;
         }
       return;
     }
  
   _isRunning = true;
  
   if (CORBA::is_nil(_procRef))
     {
       DEBTRACE("init _procRef");
       _procRef = _engineRef->LoadProc(_context->getFileName().toUtf8());
       registerStatusObservers();
       DEBTRACE("_procRef init");
     }
  
   YASSERT(!CORBA::is_nil(_procRef));
  
   if (initialize)
     _procRef->setExecMode(YACS_ORB::STEPBYSTEP);
   else
     _procRef->setExecMode(getCurrentExecMode());
   setBPList();
  
   if (_loadStateFile.empty())
     {
       DEBTRACE("Run from scratch!");
       _procRef->Run();
     }
   else
     {
       DEBTRACE("Run from STATE!");
       try
         {
           _procRef->RunFromState(_loadStateFile.c_str());
         }
       catch (...)
         {
           DEBTRACE("Runtime error: execution from the loaded state failed")
           return;
         }
     }
 }

References yacsorb.CORBAEngineTest::comp, DEBTRACE, YACS::ENGINE::RuntimeSALOME::getOrb(), YACS::ENGINE::getSALOMERuntime(), orb, YACS_ORB::STEPBYSTEP, and YASSERT.

Referenced by YACS::HMI::GenericGui::onRunLoadedSchema().

◆ stopDataflow()

void GuiExecutor::stopDataflow ( )

Definition at line 210 of file GuiExecutor.cxx.

 {
   DEBTRACE("GuiExecutor::stopDataflow");
   if (_isRunning)
     _procRef->stopExecution();
 }

References DEBTRACE.

◆ suspendDataflow()

void GuiExecutor::suspendDataflow ( )

Definition at line 193 of file GuiExecutor.cxx.

 {
   DEBTRACE("GuiExecutor::suspendDataflow");
   if (_isRunning)
     _procRef->setExecMode(YACS_ORB::STEPBYSTEP);
 }

References DEBTRACE, and YACS_ORB::STEPBYSTEP.

◆ unsetStopOnError()

void GuiExecutor::unsetStopOnError ( )

Definition at line 274 of file GuiExecutor.cxx.

 {
   DEBTRACE("GuiExecutor::unsetStopOnError");
   if (_isRunning)
     {
       _procRef->unsetStopOnError();
       _isStopOnError = false;
     }
 }

References DEBTRACE.

◆ updateSchema()

YACS::ExecutorState GuiExecutor::updateSchema ( std::string jobState )

Definition at line 588 of file GuiExecutor.cxx.

 {
   YACS::ExecutorState execState = YACS::NOTYETINITIALIZED;
  
   int numid;
   int state;
   std::list<Node*> aNodeSet = _proc->getAllRecursiveConstituents();
   for ( std::list<Node*>::iterator it = aNodeSet.begin(); it != aNodeSet.end(); it++ ){
  
     numid = (*it)->getNumId();
  
     state = _proc->getNodeState(numid);
     SubjectNode *snode = _context->_mapOfExecSubjectNode[numid];
  
     YACS::ENGINE::Node *node = snode->getNode();
     list<InputPort*> inports = node->getLocalInputPorts();
     list<InputPort*>::iterator iti = inports.begin();
     for ( ; iti != inports.end(); ++iti)
       {
         string val = _proc->getInPortValue(numid, (*iti)->getName().c_str());
         YASSERT(_context->_mapOfSubjectDataPort.count(*iti));
         SubjectDataPort* port = _context->_mapOfSubjectDataPort[*iti];
         port->setExecValue(val);
         port->update(YACS::HMI::UPDATEPROGRESS, 0, port);
       }
     list<OutputPort*> outports = node->getLocalOutputPorts();
     list<OutputPort*>::iterator ito = outports.begin();
     for ( ; ito != outports.end(); ++ito)
       {
         string val = _proc->getOutPortValue(numid, (*ito)->getName().c_str());
         YASSERT(_context->_mapOfSubjectDataPort.count(*ito));
         SubjectDataPort* port = _context->_mapOfSubjectDataPort[*ito];
         port->setExecValue(val);
         port->update(YACS::HMI::UPDATEPROGRESS, 0, port);
       }
     snode->update(YACS::HMI::UPDATEPROGRESS, state, snode);
   }
   state = _proc->getRootNode()->getEffectiveState();
   switch(state){
   case YACS::LOADED:
   case YACS::ACTIVATED:
     if(jobState!="RUNNING")
       execState = YACS::FINISHED;
     else
       execState = YACS::RUNNING;
     break;
   case YACS::FAILED:
   case YACS::DONE:
     execState = YACS::FINISHED;
     break;
   case YACS::SUSPENDED:
     execState = YACS::PAUSED;
     break;
   }
   SubjectProc *sproc = _context->getSubjectProc();
   sproc->update(YACS::HMI::UPDATEPROGRESS, execState, sproc);
  
   return execState;
 }

References driver_internal::_proc, YACS::ACTIVATED, YACS::DONE, YACS::FAILED, YACS::FINISHED, YACS::ENGINE::Node::getLocalInputPorts(), YACS::ENGINE::Node::getLocalOutputPorts(), YACS::HMI::SubjectNode::getNode(), YACS::LOADED, YACS::NOTYETINITIALIZED, YACS::PAUSED, YACS::RUNNING, YACS::HMI::SubjectDataPort::setExecValue(), yacsorb.CORBAEngineTest::state, YACS::SUSPENDED, YACS::HMI::Subject::update(), YACS::HMI::SubjectNode::update(), YACS::HMI::UPDATEPROGRESS, and YASSERT.

Referenced by YACS::HMI::BatchJobsListDialog::get_dump_file().

Member Data Documentation

◆ _breakpointList

std::list<std::string> YACS::HMI::GuiExecutor::_breakpointList

protected

Definition at line 117 of file GuiExecutor.hxx.

◆ _context

QtGuiContext* YACS::HMI::GuiExecutor::_context

protected

Definition at line 103 of file GuiExecutor.hxx.

◆ _engineRef

YACS_ORB::YACS_Gen_var YACS::HMI::GuiExecutor::_engineRef

protected

Definition at line 105 of file GuiExecutor.hxx.

◆ _execMode

YACS::ExecutionMode YACS::HMI::GuiExecutor::_execMode

protected

Definition at line 109 of file GuiExecutor.hxx.

◆ _isRunning

bool YACS::HMI::GuiExecutor::_isRunning

protected

Definition at line 112 of file GuiExecutor.hxx.

Referenced by isRunning().

◆ _isStopOnError

bool YACS::HMI::GuiExecutor::_isStopOnError

protected

Definition at line 114 of file GuiExecutor.hxx.

Referenced by isStopOnError().

◆ _isSuspended

bool YACS::HMI::GuiExecutor::_isSuspended

protected

Definition at line 113 of file GuiExecutor.hxx.

◆ _loadStateFile

std::string YACS::HMI::GuiExecutor::_loadStateFile

protected

Definition at line 118 of file GuiExecutor.hxx.

◆ _observerRef

YACS_ORB::Observer_var YACS::HMI::GuiExecutor::_observerRef

protected

Definition at line 107 of file GuiExecutor.hxx.

◆ _proc

YACS::ENGINE::Proc* YACS::HMI::GuiExecutor::_proc

protected

Definition at line 102 of file GuiExecutor.hxx.

Referenced by getProc().

◆ _procRef

YACS_ORB::ProcExec_var YACS::HMI::GuiExecutor::_procRef

protected

Definition at line 106 of file GuiExecutor.hxx.

◆ _serv

GuiObserver_i* YACS::HMI::GuiExecutor::_serv

protected

Definition at line 110 of file GuiExecutor.hxx.

◆ _shutdownLevel

int YACS::HMI::GuiExecutor::_shutdownLevel

protected

Definition at line 115 of file GuiExecutor.hxx.

Referenced by getShutdownLevel(), and setShutdownLevel().

The documentation for this class was generated from the following files:

src/genericgui/GuiExecutor.hxx
src/genericgui/GuiExecutor.cxx

Public Member Functions

Protected Member Functions

Protected Attributes

Detailed Description

Constructor & Destructor Documentation

◆ GuiExecutor()

◆ ~GuiExecutor()

Member Function Documentation

◆ addBreakpoint()

◆ checkEndOfDataflow()

◆ closeContext()

◆ event()

◆ getContainerLog() [1/2]

◆ getContainerLog() [2/2]

◆ getCurrentExecMode()

◆ getErrorDetails()

◆ getErrorReport()

◆ getExecutorState()

◆ getProc()

◆ getShutdownLevel()

◆ isRunning()

◆ isStopOnError()

◆ killDataflow()

◆ registerStatusObservers()

◆ removeBreakpoint()

◆ resetDataflow()

◆ resumeDataflow()

◆ saveState()

◆ setBPList()

◆ setBreakpointList()

◆ setBreakpointMode()

◆ setContinueMode()

◆ setEngineRef()

◆ setInPortValue()

◆ setLoadStateFile()

◆ setNextStepList()

◆ setShutdownLevel()

◆ setStepByStepMode()

◆ setStopOnError()

◆ shutdownProc()

◆ startResumeDataflow()

◆ stopDataflow()

◆ suspendDataflow()

◆ unsetStopOnError()

◆ updateSchema()

Member Data Documentation

◆ _breakpointList

◆ _context

◆ _engineRef

◆ _execMode

◆ _isRunning

◆ _isStopOnError

◆ _isSuspended

◆ _loadStateFile

◆ _observerRef

◆ _proc

◆ _procRef

◆ _serv

◆ _shutdownLevel