yacsorb.YACS.proc_i Class Reference

Inheritance diagram for yacsorb.YACS.proc_i:

Collaboration diagram for yacsorb.YACS.proc_i:

Public Member Functions
def	__init__ (self, xmlFile)
def	getNodeState (self, numid)
def	getNodeProgress (self, numid)
def	getXMLState (self, numid)
def	getInPortValue (self, nodeNumid, portName)
def	setInPortValue (self, nodeName, portName, value)
def	getOutPortValue (self, nodeNumid, portName)
def	getErrorDetails (self, nodeNumid)
def	getErrorReport (self, nodeNumid)
def	getContainerLog (self, nodeNumid)
def	shutdownProc (self, level)
def	getExecutorState (self)
def	getIds (self)
def	getNumIds (self)
def	getNames (self)
def	runProc (self, debug, isPyThread, fromscratch)
def	Run (self)
def	RunFromState (self, xmlFile)
def	RestartFromState (self, xmlFile)
def	addObserver (self, obs, numid, event)
def	setExecMode (self, mode)
def	setListOfBreakPoints (self, listOfBreakPoints)
def	getTasksToLoad (self)
def	setStepsToExecute (self, listToExecute)
def	resumeCurrentBreakPoint (self)
def	isNotFinished (self)
def	stopExecution (self)
def	saveState (self, xmlFile)
def	setStopOnError (self, dumpRequested, xmlFile)
def	unsetStopOnError (self)

Public Attributes
	l
	e
	run1
	p
	xmlFile

Detailed Description

Definition at line 36 of file YACS.py.

Constructor & Destructor Documentation

__init__()

def yacsorb.YACS.proc_i.__init__	(		self,
			xmlFile
	)

Definition at line 37 of file YACS.py.

    def __init__(self, xmlFile):
        self.l = loader.YACSLoader()
        self.e = pilot.ExecutorSwig()
        self.e.setExecMode(1) # YACS::STEPBYSTEP
        self.run1 = None
        self.p = self.l.load(xmlFile)
        self.xmlFile=xmlFile
        pass
 

Member Function Documentation

addObserver()

def yacsorb.YACS.proc_i.addObserver	(		self,
			obs,
			numid,
			event
	)

Definition at line 181 of file YACS.py.

    def addObserver(self, obs, numid, event):
        disp = SALOMERuntime.SALOMEDispatcher_getSALOMEDispatcher()
        disp.addObserver(obs, numid, event)
        pass
 

getContainerLog()

def yacsorb.YACS.proc_i.getContainerLog	(		self,
			nodeNumid
	)

Definition at line 82 of file YACS.py.

    def getContainerLog(self, nodeNumid):
        return self.p.getNodeContainerLog(nodeNumid)
 

References yacsorb.YACS.proc_i.p.

getErrorDetails()

def yacsorb.YACS.proc_i.getErrorDetails	(		self,
			nodeNumid
	)

Definition at line 76 of file YACS.py.

    def getErrorDetails(self, nodeNumid):
        return self.p.getNodeErrorDetails(nodeNumid)
 

References yacsorb.YACS.proc_i.p.

getErrorReport()

def yacsorb.YACS.proc_i.getErrorReport	(		self,
			nodeNumid
	)

Definition at line 79 of file YACS.py.

    def getErrorReport(self, nodeNumid):
        return self.p.getNodeErrorReport(nodeNumid)
 

References yacsorb.YACS.proc_i.p.

getExecutorState()

def yacsorb.YACS.proc_i.getExecutorState

(

self

)

Definition at line 88 of file YACS.py.

    def getExecutorState(self):
        return self.e.getExecutorState()
 

References yacsorb.YACS.proc_i.e, and yacsorb.YACS.proc_i.getExecutorState().

Referenced by yacsorb.YACS.proc_i.getExecutorState(), yacsorb.YACS.proc_i.RestartFromState(), yacsorb.YACS.proc_i.Run(), and yacsorb.YACS.proc_i.RunFromState().

getIds()

def yacsorb.YACS.proc_i.getIds

(

self

)

Definition at line 91 of file YACS.py.

    def getIds(self):
        numids = self.p.getNumIds()
        ids = self.p.getIds()
        return (numids,ids)
 

References yacsorb.YACS.proc_i.getIds(), yacsorb.YACS.proc_i.getNumIds(), and yacsorb.YACS.proc_i.p.

Referenced by yacsorb.YACS.proc_i.getIds(), and yacsorb.YACS.proc_i.getNames().

getInPortValue()

def yacsorb.YACS.proc_i.getInPortValue	(		self,
			nodeNumid,
			portName
	)

Definition at line 55 of file YACS.py.

    def getInPortValue(self, nodeNumid, portName):
      try:
        return self.p.getInPortValue(nodeNumid, portName)
      except:
        traceback.print_exc()
        return ""
 

References yacsorb.YACS.proc_i.getInPortValue(), and yacsorb.YACS.proc_i.p.

Referenced by yacsorb.YACS.proc_i.getInPortValue().

getNames()

def yacsorb.YACS.proc_i.getNames

(

self

)

Definition at line 99 of file YACS.py.

    def getNames(self):
        return self.p.getIds()
 

References yacsorb.YACS.proc_i.getIds(), and yacsorb.YACS.proc_i.p.

getNodeProgress()

def yacsorb.YACS.proc_i.getNodeProgress	(		self,
			numid
	)

Definition at line 49 of file YACS.py.

    def getNodeProgress(self,numid):
        return self.p.getNodeProgress(numid)
 

References yacsorb.YACS.proc_i.getNodeProgress(), and yacsorb.YACS.proc_i.p.

Referenced by yacsorb.YACS.proc_i.getNodeProgress().

getNodeState()

def yacsorb.YACS.proc_i.getNodeState	(		self,
			numid
	)

Definition at line 46 of file YACS.py.

    def getNodeState(self,numid):
        return self.p.getNodeState(numid)
 

References yacsorb.YACS.proc_i.getNodeState(), and yacsorb.YACS.proc_i.p.

Referenced by yacsorb.YACS.proc_i.getNodeState().

getNumIds()

def yacsorb.YACS.proc_i.getNumIds

(

self

)

Definition at line 96 of file YACS.py.

    def getNumIds(self):
        return self.p.getNumIds()
 

References yacsorb.YACS.proc_i.getNumIds(), and yacsorb.YACS.proc_i.p.

Referenced by yacsorb.YACS.proc_i.getIds(), and yacsorb.YACS.proc_i.getNumIds().

getOutPortValue()

def yacsorb.YACS.proc_i.getOutPortValue	(		self,
			nodeNumid,
			portName
	)

Definition at line 69 of file YACS.py.

    def getOutPortValue(self, nodeNumid, portName):
      try:
        return self.p.getOutPortValue(nodeNumid, portName)
      except:
        traceback.print_exc()
        return ""
 

References yacsorb.YACS.proc_i.getOutPortValue(), and yacsorb.YACS.proc_i.p.

Referenced by yacsorb.YACS.proc_i.getOutPortValue().

getTasksToLoad()

def yacsorb.YACS.proc_i.getTasksToLoad

(

self

)

Definition at line 202 of file YACS.py.

    def getTasksToLoad(self):
        return self.e.getTasksToLoad()
 

References yacsorb.YACS.proc_i.e, and yacsorb.YACS.proc_i.getTasksToLoad().

Referenced by yacsorb.YACS.proc_i.getTasksToLoad().

getXMLState()

def yacsorb.YACS.proc_i.getXMLState	(		self,
			numid
	)

Definition at line 52 of file YACS.py.

    def getXMLState(self, numid):
        return self.p.getXMLState(numid)
 

References yacsorb.YACS.proc_i.getXMLState(), and yacsorb.YACS.proc_i.p.

Referenced by yacsorb.YACS.proc_i.getXMLState().

isNotFinished()

def yacsorb.YACS.proc_i.isNotFinished

(

self

)

Definition at line 211 of file YACS.py.

    def isNotFinished(self):
        return self.e.isNotFinished()
 

References yacsorb.YACS.proc_i.e, and yacsorb.YACS.proc_i.isNotFinished().

Referenced by yacsorb.YACS.proc_i.isNotFinished().

RestartFromState()

def yacsorb.YACS.proc_i.RestartFromState	(		self,
			xmlFile
	)

Reset the procedure state to ready state for all nodes in error
   if xmlFile exists first try to load the state from this file.
   then start execution

Definition at line 152 of file YACS.py.

    def RestartFromState(self, xmlFile):
        """Reset the procedure state to ready state for all nodes in error
           if xmlFile exists first try to load the state from this file.
           then start execution
        """
        if self.run1 is not None:
          execState = self.e.getExecutorState()
          if execState >= pilot.FINISHED:
            self.run1.join()
            self.run1 = None
          else:
            return
 
        try:
          if os.path.exists(xmlFile):
            self.p.init()
            sp = loader.stateParser()
            sl = loader.stateLoader(sp,self.p)
            sl.parse(xmlFile)
 
          self.p.resetState(1)
          self.p.exUpdateState();
        except:
            pass
 
        if self.run1 is None:
            self.run1 = threading.Thread(None, self.runProc, "CORBAExec", (0,True,False))
            self.run1.start()
 

References yacsorb.YACS.proc_i.e, yacsorb.YACS.proc_i.getExecutorState(), yacsorb.YACS.proc_i.p, yacsorb.YACS.proc_i.run1, and yacsorb.YACS.proc_i.runProc().

resumeCurrentBreakPoint()

def yacsorb.YACS.proc_i.resumeCurrentBreakPoint

(

self

)

Definition at line 208 of file YACS.py.

    def resumeCurrentBreakPoint(self):
        return self.e.resumeCurrentBreakPoint()
 

References yacsorb.YACS.proc_i.e, and yacsorb.YACS.proc_i.resumeCurrentBreakPoint().

Referenced by yacsorb.YACS.proc_i.resumeCurrentBreakPoint().

Run()

def yacsorb.YACS.proc_i.Run

(

self

)

Definition at line 107 of file YACS.py.

    def Run(self):
        if self.run1 is not None:
          execState = self.e.getExecutorState()
          if execState >= pilot.FINISHED:
            self.run1.join()
            self.run1 = None
 
        if self.run1 is None:
            self.run1 = threading.Thread(None, self.runProc, "CORBAExec", (0,True,True))
            self.run1.start()
 

References yacsorb.YACS.proc_i.e, yacsorb.YACS.proc_i.getExecutorState(), yacsorb.YACS.proc_i.run1, and yacsorb.YACS.proc_i.runProc().

RunFromState()

def yacsorb.YACS.proc_i.RunFromState	(		self,
			xmlFile
	)

Start an execution from the state given by the file xmlFile
   If xmlFile == "", start execution from the current state

Definition at line 118 of file YACS.py.

    def RunFromState(self, xmlFile):
        """Start an execution from the state given by the file xmlFile
           If xmlFile == "", start execution from the current state
        """
        if self.run1 is not None:
          execState = self.e.getExecutorState()
          if execState >= pilot.FINISHED:
            self.run1.join()
            self.run1 = None
 
        if xmlFile:
          try:
            self.p.init()
            self.p.exUpdateState();
            sp = loader.stateParser()
            sl = loader.stateLoader(sp,self.p)
            sl.parse(xmlFile)
          except IOError as ex:
            print("IO Error: ", ex)
            return
          except ValueError as ex:
            print("Caught ValueError Exception:",ex)
            return
          except pilot.Exception as ex:
            print(ex.what())
            return
          except:
            print("Unknown exception!")
            return
 
        if self.run1 is None:
            self.run1 = threading.Thread(None, self.runProc, "CORBAExec", (0,True,False))
            self.run1.start()
 

References yacsorb.YACS.proc_i.e, yacsorb.YACS.proc_i.getExecutorState(), yacsorb.YACS.proc_i.p, yacsorb.YACS.proc_i.run1, and yacsorb.YACS.proc_i.runProc().

runProc()

def yacsorb.YACS.proc_i.runProc	(		self,
			debug,
			isPyThread,
			fromscratch
	)

Definition at line 102 of file YACS.py.

    def runProc(self,debug, isPyThread, fromscratch):
      print("**************************Begin schema execution %s**************************" % self.xmlFile)
      self.e.RunPy(self.p,debug, isPyThread, fromscratch)
      print("**************************End schema execution %s****************************" % self.xmlFile)
 

References yacsorb.YACS.proc_i.e, yacsorb.YACS.proc_i.p, and yacsorb.YACS.proc_i.xmlFile.

Referenced by yacsorb.YACS.proc_i.RestartFromState(), yacsorb.YACS.proc_i.Run(), and yacsorb.YACS.proc_i.RunFromState().

saveState()

def yacsorb.YACS.proc_i.saveState	(		self,
			xmlFile
	)

Definition at line 218 of file YACS.py.

    def saveState(self, xmlFile):
        return self.e.saveState(xmlFile)
 

References yacsorb.YACS.proc_i.e, and yacsorb.YACS.proc_i.saveState().

Referenced by yacsorb.YACS.proc_i.saveState().

setExecMode()

def yacsorb.YACS.proc_i.setExecMode	(		self,
			mode
	)

Definition at line 186 of file YACS.py.

    def setExecMode(self, mode):
        if mode == YACS_ORB.CONTINUE:
            self.e.setExecMode(0)
            pass
        if mode == YACS_ORB.STEPBYSTEP:
            self.e.setExecMode(1)
            pass
        if mode == YACS_ORB.STOPBEFORENODES:
            self.e.setExecMode(2)
            pass
        pass
 

References yacsorb.YACS.proc_i.e, and yacsorb.YACS.proc_i.setExecMode().

Referenced by yacsorb.YACS.proc_i.setExecMode().

setInPortValue()

def yacsorb.YACS.proc_i.setInPortValue	(		self,
			nodeName,
			portName,
			value
	)

Definition at line 62 of file YACS.py.

    def setInPortValue(self, nodeName, portName, value):
      try:
        return self.p.setInPortValue(nodeName, portName, value)
      except:
        traceback.print_exc()
        return ""
 

References yacsorb.YACS.proc_i.p, and yacsorb.YACS.proc_i.setInPortValue().

Referenced by yacsorb.YACS.proc_i.setInPortValue().

setListOfBreakPoints()

def yacsorb.YACS.proc_i.setListOfBreakPoints	(		self,
			listOfBreakPoints
	)

Definition at line 198 of file YACS.py.

    def setListOfBreakPoints(self, listOfBreakPoints):
        self.e.setListOfBreakPoints(listOfBreakPoints)
        pass
 

References yacsorb.YACS.proc_i.e, and yacsorb.YACS.proc_i.setListOfBreakPoints().

Referenced by yacsorb.YACS.proc_i.setListOfBreakPoints().

setStepsToExecute()

def yacsorb.YACS.proc_i.setStepsToExecute	(		self,
			listToExecute
	)

Definition at line 205 of file YACS.py.

    def setStepsToExecute(self, listToExecute):
        return self.e.setStepsToExecute(listToExecute)
 

References yacsorb.YACS.proc_i.e, and yacsorb.YACS.proc_i.setStepsToExecute().

Referenced by yacsorb.YACS.proc_i.setStepsToExecute().

setStopOnError()

def yacsorb.YACS.proc_i.setStopOnError	(		self,
			dumpRequested,
			xmlFile
	)

Definition at line 221 of file YACS.py.

    def setStopOnError(self, dumpRequested, xmlFile):
        self.e.setStopOnError(dumpRequested, xmlFile)
        pass
 

References yacsorb.YACS.proc_i.e, and yacsorb.YACS.proc_i.setStopOnError().

Referenced by yacsorb.YACS.proc_i.setStopOnError().

shutdownProc()

def yacsorb.YACS.proc_i.shutdownProc	(		self,
			level
	)

Definition at line 85 of file YACS.py.

    def shutdownProc(self, level):
        return self.p.shutdown(level)
 

References yacsorb.YACS.proc_i.p.

stopExecution()

def yacsorb.YACS.proc_i.stopExecution

(

self

)

Definition at line 214 of file YACS.py.

    def stopExecution(self):
        self.e.stopExecution()
        pass
 

References yacsorb.YACS.proc_i.e, and yacsorb.YACS.proc_i.stopExecution().

Referenced by yacsorb.YACS.proc_i.stopExecution().

unsetStopOnError()

def yacsorb.YACS.proc_i.unsetStopOnError

(

self

)

Definition at line 225 of file YACS.py.

    def unsetStopOnError(self):
        self.e.unsetStopOnError()
        pass
 

References yacsorb.YACS.proc_i.e, and yacsorb.YACS.proc_i.unsetStopOnError().

Referenced by yacsorb.YACS.proc_i.unsetStopOnError().

Member Data Documentation

e

yacsorb.YACS.proc_i.e

Definition at line 39 of file YACS.py.

Referenced by yacsorb.YACS.proc_i.getExecutorState(), yacsorb.YACS.proc_i.getTasksToLoad(), yacsorb.YACS.proc_i.isNotFinished(), yacsorb.YACS.proc_i.RestartFromState(), yacsorb.YACS.proc_i.resumeCurrentBreakPoint(), yacsorb.YACS.proc_i.Run(), yacsorb.YACS.proc_i.RunFromState(), yacsorb.YACS.proc_i.runProc(), yacsorb.YACS.proc_i.saveState(), yacsorb.YACS.proc_i.setExecMode(), yacsorb.YACS.proc_i.setListOfBreakPoints(), yacsorb.YACS.proc_i.setStepsToExecute(), yacsorb.YACS.proc_i.setStopOnError(), yacsorb.YACS.proc_i.stopExecution(), and yacsorb.YACS.proc_i.unsetStopOnError().

l

yacsorb.YACS.proc_i.l

Definition at line 38 of file YACS.py.

p

yacsorb.YACS.proc_i.p

Definition at line 42 of file YACS.py.

Referenced by yacsorb.YACS.proc_i.getContainerLog(), yacsorb.YACS.proc_i.getErrorDetails(), yacsorb.YACS.proc_i.getErrorReport(), yacsorb.YACS.proc_i.getIds(), yacsorb.YACS.proc_i.getInPortValue(), yacsorb.YACS.proc_i.getNames(), yacsorb.YACS.proc_i.getNodeProgress(), yacsorb.YACS.proc_i.getNodeState(), yacsorb.YACS.proc_i.getNumIds(), yacsorb.YACS.proc_i.getOutPortValue(), yacsorb.YACS.proc_i.getXMLState(), yacsorb.YACS.proc_i.RestartFromState(), yacsorb.YACS.proc_i.RunFromState(), yacsorb.YACS.proc_i.runProc(), yacsorb.YACS.proc_i.setInPortValue(), and yacsorb.YACS.proc_i.shutdownProc().

run1

yacsorb.YACS.proc_i.run1

Definition at line 41 of file YACS.py.

Referenced by yacsorb.YACS.proc_i.RestartFromState(), yacsorb.YACS.proc_i.Run(), and yacsorb.YACS.proc_i.RunFromState().

xmlFile

yacsorb.YACS.proc_i.xmlFile

Definition at line 43 of file YACS.py.

Referenced by yacsorb.YACS.proc_i.runProc().

---

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

• src/yacsorb/YACS.py