#include <GuiExecutor.hxx>

Inheritance diagram for YACS::HMI::GuiExecutor:

Collaboration diagram for YACS::HMI::GuiExecutor:

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 ( YACS::ENGINE::Proc * proc )

Definition at line 44 of file GuiExecutor.cxx.

References YACS::CONTINUE, and DEBTRACE.

 {
   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();
 }

GuiExecutor::~GuiExecutor ( )

virtual

Definition at line 68 of file GuiExecutor.cxx.

References DEBTRACE.

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

Member Function Documentation

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

Definition at line 339 of file GuiExecutor.cxx.

References YACS::CONTINUE, and DEBTRACE.

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

 {
   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();
     }
 }

bool GuiExecutor::checkEndOfDataflow ( bool display = true )

Definition at line 152 of file GuiExecutor.cxx.

References DEBTRACE.

 {
   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;
 }

void GuiExecutor::closeContext ( )

Definition at line 73 of file GuiExecutor.cxx.

References DEBTRACE.

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

bool GuiExecutor::event ( QEvent * e )

virtual

Definition at line 489 of file GuiExecutor.cxx.

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

 {
   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;
 }

std::string GuiExecutor::getContainerLog ( )

Definition at line 434 of file GuiExecutor.cxx.

References DEBTRACE.

 {
   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;
 }

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

Definition at line 450 of file GuiExecutor.cxx.

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

 {
   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;
 }

YACS_ORB::executionMode GuiExecutor::getCurrentExecMode ( )

Definition at line 297 of file GuiExecutor.cxx.

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

 {
   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;
     }
 }

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

Definition at line 412 of file GuiExecutor.cxx.

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

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

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

Definition at line 423 of file GuiExecutor.cxx.

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

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

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

int GuiExecutor::getExecutorState ( )

Definition at line 309 of file GuiExecutor.cxx.

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

 {
   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;
 }

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

inline

Definition at line 86 of file GuiExecutor.hxx.

References _proc.

86 { return _proc; };

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

inline

Definition at line 93 of file GuiExecutor.hxx.

References _shutdownLevel.

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

93 {return _shutdownLevel;}

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

inline

Definition at line 82 of file GuiExecutor.hxx.

References _isRunning.

82 { return _isRunning; };

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

inline

Definition at line 83 of file GuiExecutor.hxx.

References _isStopOnError.

83 { return _isStopOnError; }

void GuiExecutor::killDataflow ( )

Definition at line 177 of file GuiExecutor.cxx.

References DEBTRACE.

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

void GuiExecutor::registerStatusObservers ( )

Definition at line 377 of file GuiExecutor.cxx.

References DEBTRACE.

 {
   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"); 
 }

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

Definition at line 356 of file GuiExecutor.cxx.

References DEBTRACE.

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

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

void GuiExecutor::resetDataflow ( )

Definition at line 208 of file GuiExecutor.cxx.

References DEBTRACE, and YACS_ORB::STEPBYSTEP.

 {
   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("");
     }
 }

void GuiExecutor::resumeDataflow ( )

Definition at line 191 of file GuiExecutor.cxx.

References DEBTRACE.

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

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

Definition at line 276 of file GuiExecutor.cxx.

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

 {
   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);
     }
   }
 }

void GuiExecutor::setBPList ( )

protected

Definition at line 565 of file GuiExecutor.cxx.

References DEBTRACE, and CORBAEngineTest::i.

 {
   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);
   }
 }

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

Definition at line 321 of file GuiExecutor.cxx.

References YACS::CONTINUE, and DEBTRACE.

 {
   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();
     }
 }

void GuiExecutor::setBreakpointMode ( )

Definition at line 243 of file GuiExecutor.cxx.

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

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

void GuiExecutor::setContinueMode ( )

Definition at line 235 of file GuiExecutor.cxx.

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

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

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

Definition at line 406 of file GuiExecutor.cxx.

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

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

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

Definition at line 473 of file GuiExecutor.cxx.

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().

 {
   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());
 }

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

Definition at line 290 of file GuiExecutor.cxx.

References DEBTRACE.

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

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

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

Definition at line 363 of file GuiExecutor.cxx.

References DEBTRACE, and CORBAEngineTest::i.

 {
   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);
     }
 }

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

inline

Definition at line 92 of file GuiExecutor.hxx.

References _shutdownLevel.

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

92 {_shutdownLevel=level;}

void GuiExecutor::setStepByStepMode ( )

Definition at line 227 of file GuiExecutor.cxx.

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

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

void GuiExecutor::setStopOnError ( bool aMode )

Definition at line 251 of file GuiExecutor.cxx.

References DEBTRACE.

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

 {
   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;
     }
 }

void GuiExecutor::shutdownProc ( )

Definition at line 465 of file GuiExecutor.cxx.

References DEBTRACE.

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

void GuiExecutor::startResumeDataflow ( bool initialize = false )

Definition at line 79 of file GuiExecutor.cxx.

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

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

 {
   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 namingService(orb);
       SALOME_LifeCycleCORBA lcc(&namingService);
       ostringstream containerName;
       containerName << "localhost/YACSContainer" << QtGuiContext::getQtCurrent()->getStudyId();
       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;
         }
     }
 }

void GuiExecutor::stopDataflow ( )

Definition at line 201 of file GuiExecutor.cxx.

References DEBTRACE.

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

void GuiExecutor::suspendDataflow ( )

Definition at line 184 of file GuiExecutor.cxx.

References DEBTRACE, and YACS_ORB::STEPBYSTEP.

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

void GuiExecutor::unsetStopOnError ( )

Definition at line 265 of file GuiExecutor.cxx.

References DEBTRACE.

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

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

Definition at line 579 of file GuiExecutor.cxx.

References 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(), CORBAEngineTest::state, YACS::SUSPENDED, YACS::HMI::SubjectNode::update(), YACS::HMI::UPDATEPROGRESS, and YASSERT.

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

 {
   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;
 }

Member Data Documentation

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

protected

Definition at line 117 of file GuiExecutor.hxx.

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

protected

Definition at line 103 of file GuiExecutor.hxx.

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

protected

Definition at line 105 of file GuiExecutor.hxx.

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

protected

Definition at line 109 of file GuiExecutor.hxx.

bool YACS::HMI::GuiExecutor::_isRunning

protected

Definition at line 112 of file GuiExecutor.hxx.

Referenced by isRunning().

bool YACS::HMI::GuiExecutor::_isStopOnError

protected

Definition at line 114 of file GuiExecutor.hxx.

Referenced by isStopOnError().

bool YACS::HMI::GuiExecutor::_isSuspended

protected

Definition at line 113 of file GuiExecutor.hxx.

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

protected

Definition at line 118 of file GuiExecutor.hxx.

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

protected

Definition at line 107 of file GuiExecutor.hxx.

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

protected

Definition at line 102 of file GuiExecutor.hxx.

Referenced by getProc().

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

protected

Definition at line 106 of file GuiExecutor.hxx.

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

protected

Definition at line 110 of file GuiExecutor.hxx.

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

Member Function Documentation

Member Data Documentation