#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 _breakpointList, _context, _engineRef, _execMode, _isRunning, _isStopOnError, _isSuspended, _loadStateFile, _observerRef, _proc, _procRef, _serv, _shutdownLevel, YACS::CONTINUE, DEBTRACE, and YACS::HMI::QtGuiContext::getQtCurrent().

◆ ~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 _breakpointList, YACS::HMI::GenericGui::_breakpointsModeAct, _context, _execMode, YACS::CONTINUE, DEBTRACE, YACS::HMI::QtGuiContext::getGMain(), setBPList(), and setBreakpointMode().

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 _isRunning, _procRef, and DEBTRACE.

Referenced by resetDataflow(), shutdownProc(), and startResumeDataflow().

◆ closeContext()

void GuiExecutor::closeContext ( )

Definition at line 79 of file GuiExecutor.cxx.

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

References _context, and 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 _context, YACS::HMI::GuiObserver_i::_engineToGuiMap, _isSuspended, YACS::HMI::GuiContext::_mapOfExecSubjectNode, YACS::HMI::GuiContext::_mapOfSubjectDataPort, _procRef, _serv, DEBTRACE, event(), YACS::ENGINE::Node::getLocalInputPorts(), YACS::ENGINE::Node::getLocalOutputPorts(), YACS::HMI::SubjectNode::getName(), YACS::HMI::SubjectNode::getNode(), YACS::HMI::GuiContext::getSubjectProc(), 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.

Referenced by event().

◆ 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 _engineRef, and DEBTRACE.

Referenced by YACS::HMI::GenericGui::onGetContainerLog(), and YACS::HMI::GenericGui::onGetYacsContainerLog().

◆ 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 _procRef, _serv, DEBTRACE, YACS::HMI::GuiObserver_i::getEngineId(), 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 _execMode, YACS_ORB::CONTINUE, YACS::CONTINUE, DEBTRACE, YACS_ORB::STEPBYSTEP, YACS::STEPBYSTEP, YACS_ORB::STOPBEFORENODES, and YACS::STOPBEFORENODES.

Referenced by resumeDataflow(), and startResumeDataflow().

◆ 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 _procRef, _serv, DEBTRACE, YACS::HMI::GuiObserver_i::getEngineId(), and YACS::ENGINE::Node::getNumId().

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

◆ 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 _procRef, _serv, DEBTRACE, YACS::HMI::GuiObserver_i::getEngineId(), and YACS::ENGINE::Node::getNumId().

Referenced by YACS::HMI::GenericGui::onGetErrorReport(), and 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 _isRunning, _procRef, DEBTRACE, YACS::FINISHED, and YACS::NOTYETINITIALIZED.

Referenced by saveState().

◆ 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 _isRunning, _procRef, and DEBTRACE.

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

◆ 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 _observerRef, _proc, _procRef, _serv, DEBTRACE, YACS::ENGINE::ComposedNode::getAllRecursiveConstituents(), YACS::HMI::GuiObserver_i::getEngineId(), YACS::ENGINE::Node::getNumId(), YACS::HMI::GuiObserver_i::setConversion(), YACS::HMI::GuiObserver_i::SetImpl(), and YACS::HMI::GuiObserver_i::SetRemoteProc().

Referenced by startResumeDataflow().

◆ removeBreakpoint()

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

Definition at line 365 of file GuiExecutor.cxx.

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

References _breakpointList, DEBTRACE, and setBPList().

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 _isRunning, _procRef, checkEndOfDataflow(), DEBTRACE, and YACS_ORB::STEPBYSTEP.

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

◆ resumeDataflow()

void GuiExecutor::resumeDataflow ( )

Definition at line 200 of file GuiExecutor.cxx.

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

References _isRunning, _procRef, DEBTRACE, and getCurrentExecMode().

◆ 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 _isRunning, _procRef, DEBTRACE, YACS::FINISHED, getExecutorState(), and YACS::NOTYETINITIALIZED.

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

◆ 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 _breakpointList, _isRunning, _procRef, DEBTRACE, and yacsorb.CORBAEngineTest::i.

Referenced by addBreakpoint(), removeBreakpoint(), setBreakpointList(), and startResumeDataflow().

◆ 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 _breakpointList, YACS::HMI::GenericGui::_breakpointsModeAct, _context, _execMode, YACS::CONTINUE, DEBTRACE, YACS::HMI::QtGuiContext::getGMain(), setBPList(), and setBreakpointMode().

◆ 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 _execMode, _isRunning, _procRef, DEBTRACE, YACS_ORB::STOPBEFORENODES, and YACS::STOPBEFORENODES.

Referenced by addBreakpoint(), YACS::HMI::GenericGui::onBreakpointsMode(), and setBreakpointList().

◆ 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 _execMode, _isRunning, _procRef, YACS_ORB::CONTINUE, YACS::CONTINUE, and DEBTRACE.

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

◆ setEngineRef()

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

Definition at line 415 of file GuiExecutor.cxx.

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

References _engineRef, 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 _procRef, 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 _loadStateFile, and 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 _isRunning, _procRef, 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 _execMode, _isRunning, _procRef, DEBTRACE, YACS_ORB::STEPBYSTEP, and YACS::STEPBYSTEP.

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

◆ 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 _isRunning, _isStopOnError, _procRef, and DEBTRACE.

Referenced by YACS::HMI::GenericGui::onRunLoadedSchema(), and YACS::HMI::GenericGui::onToggleStopOnError().

◆ shutdownProc()

void GuiExecutor::shutdownProc ( )

Definition at line 474 of file GuiExecutor.cxx.

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

References _isRunning, _procRef, _shutdownLevel, checkEndOfDataflow(), and DEBTRACE.

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

◆ 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 _context, _engineRef, _isRunning, _isSuspended, _loadStateFile, _procRef, checkEndOfDataflow(), yacsorb.CORBAEngineTest::comp, DEBTRACE, getCurrentExecMode(), YACS::HMI::QtGuiContext::getFileName(), YACS::ENGINE::RuntimeSALOME::getOrb(), YACS::ENGINE::getSALOMERuntime(), orb, registerStatusObservers(), setBPList(), YACS_ORB::STEPBYSTEP, and YASSERT.

Referenced by YACS::HMI::GenericGui::onRunLoadedSchema(), and YACS::HMI::GenericGui::onStartResume().

◆ stopDataflow()

void GuiExecutor::stopDataflow ( )

Definition at line 210 of file GuiExecutor.cxx.

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

References _isRunning, _procRef, and DEBTRACE.

◆ suspendDataflow()

void GuiExecutor::suspendDataflow ( )

Definition at line 193 of file GuiExecutor.cxx.

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

References _isRunning, _procRef, DEBTRACE, and YACS_ORB::STEPBYSTEP.

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

◆ unsetStopOnError()

void GuiExecutor::unsetStopOnError ( )

Definition at line 274 of file GuiExecutor.cxx.

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

References _isRunning, _isStopOnError, _procRef, and DEBTRACE.

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

◆ 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 _context, YACS::HMI::GuiContext::_mapOfExecSubjectNode, YACS::HMI::GuiContext::_mapOfSubjectDataPort, _proc, YACS::ACTIVATED, YACS::DONE, YACS::FAILED, YACS::FINISHED, YACS::ENGINE::ComposedNode::getAllRecursiveConstituents(), YACS::ENGINE::Node::getEffectiveState(), YACS::ENGINE::Proc::getInPortValue(), YACS::ENGINE::Node::getLocalInputPorts(), YACS::ENGINE::Node::getLocalOutputPorts(), YACS::HMI::SubjectNode::getNode(), YACS::ENGINE::Proc::getNodeState(), YACS::ENGINE::Proc::getOutPortValue(), YACS::ENGINE::ComposedNode::getRootNode(), YACS::HMI::GuiContext::getSubjectProc(), 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.

Referenced by addBreakpoint(), GuiExecutor(), removeBreakpoint(), setBPList(), and setBreakpointList().

◆ _context

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

protected

Definition at line 103 of file GuiExecutor.hxx.

Referenced by addBreakpoint(), closeContext(), event(), GuiExecutor(), setBreakpointList(), startResumeDataflow(), and updateSchema().

◆ _engineRef

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

protected

Definition at line 105 of file GuiExecutor.hxx.

Referenced by getContainerLog(), GuiExecutor(), setEngineRef(), and startResumeDataflow().

◆ _execMode

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

protected

Definition at line 109 of file GuiExecutor.hxx.

Referenced by addBreakpoint(), getCurrentExecMode(), GuiExecutor(), setBreakpointList(), setBreakpointMode(), setContinueMode(), and setStepByStepMode().

◆ _isRunning

bool YACS::HMI::GuiExecutor::_isRunning

protected

Definition at line 112 of file GuiExecutor.hxx.

Referenced by checkEndOfDataflow(), getExecutorState(), GuiExecutor(), isRunning(), killDataflow(), resetDataflow(), resumeDataflow(), saveState(), setBPList(), setBreakpointMode(), setContinueMode(), setNextStepList(), setStepByStepMode(), setStopOnError(), shutdownProc(), startResumeDataflow(), stopDataflow(), suspendDataflow(), and unsetStopOnError().

◆ _isStopOnError

bool YACS::HMI::GuiExecutor::_isStopOnError

protected

Definition at line 114 of file GuiExecutor.hxx.

Referenced by GuiExecutor(), isStopOnError(), setStopOnError(), and unsetStopOnError().

◆ _isSuspended

bool YACS::HMI::GuiExecutor::_isSuspended

protected

Definition at line 113 of file GuiExecutor.hxx.

Referenced by event(), GuiExecutor(), and startResumeDataflow().

◆ _loadStateFile

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

protected

Definition at line 118 of file GuiExecutor.hxx.

Referenced by GuiExecutor(), setLoadStateFile(), and startResumeDataflow().

◆ _observerRef

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

protected

Definition at line 107 of file GuiExecutor.hxx.

Referenced by GuiExecutor(), and registerStatusObservers().

◆ _proc

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

protected

Definition at line 102 of file GuiExecutor.hxx.

Referenced by getProc(), GuiExecutor(), registerStatusObservers(), and updateSchema().

◆ _procRef

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

protected

◆ _serv

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

protected

Definition at line 110 of file GuiExecutor.hxx.

Referenced by event(), getContainerLog(), getErrorDetails(), getErrorReport(), GuiExecutor(), and registerStatusObservers().

◆ _shutdownLevel

int YACS::HMI::GuiExecutor::_shutdownLevel

protected

Definition at line 115 of file GuiExecutor.hxx.

Referenced by getShutdownLevel(), GuiExecutor(), setShutdownLevel(), and shutdownProc().

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