YACS.py

Go to the documentation of this file.

# Copyright (C) 2006-2025  CEA, EDF
#
# This library is free software; you can redistribute it and/or
# modify it under the terms of the GNU Lesser General Public
# License as published by the Free Software Foundation; either
# version 2.1 of the License, or (at your option) any later version.
#
# This library is distributed in the hope that it will be useful,
# but WITHOUT ANY WARRANTY; without even the implied warranty of
# MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the GNU
# Lesser General Public License for more details.
#
# You should have received a copy of the GNU Lesser General Public
# License along with this library; if not, write to the Free Software
# Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA  02111-1307 USA
#
# See http://www.salome-platform.org/ or email : webmaster.salome@opencascade.com
#
 
import sys
import YACS_ORB__POA
import YACS_ORB
import SALOME_ComponentPy
import SALOME_DriverPy
 
import threading
import tempfile
import os
 
import SALOMERuntime
import loader
import salomeloader
import pilot
import traceback
 
class proc_i(YACS_ORB__POA.ProcExec):
    def __init__(self, xmlFile):
        self.ll = loader.YACSLoader()
        self.ee = pilot.ExecutorSwig()
        self.ee.setExecMode(1) # YACS::STEPBYSTEP
        self.run1run1 = None
        self.pp = self.ll.load(xmlFile)
        self.xmlFilexmlFile=xmlFile
        pass
 
    def getNodeState(self,numid):
        return self.pp.getNodeState(numid)
 
    def getNodeProgress(self,numid):
        return self.pp.getNodeProgress(numid)
 
    def getXMLState(self, numid):
        return self.pp.getXMLState(numid)
 
    def getInPortValue(self, nodeNumid, portName):
      try:
        return self.pp.getInPortValue(nodeNumid, portName)
      except:
        traceback.print_exc()
        return ""
 
    def setInPortValue(self, nodeName, portName, value):
      try:
        return self.pp.setInPortValue(nodeName, portName, value)
      except:
        traceback.print_exc()
        return ""
 
    def getOutPortValue(self, nodeNumid, portName):
      try:
        return self.pp.getOutPortValue(nodeNumid, portName)
      except:
        traceback.print_exc()
        return ""
 
    def getErrorDetails(self, nodeNumid):
        return self.pp.getNodeErrorDetails(nodeNumid)
 
    def getErrorReport(self, nodeNumid):
        return self.pp.getNodeErrorReport(nodeNumid)
 
    def getContainerLog(self, nodeNumid):
        return self.pp.getNodeContainerLog(nodeNumid)
 
    def shutdownProc(self, level):
        return self.pp.shutdown(level)
 
    def getExecutorState(self):
        return self.ee.getExecutorState()
 
    def getIds(self):
        numids = self.pp.getNumIds()
        ids = self.pp.getIds()
        return (numids,ids)
 
    def getNumIds(self):
        return self.pp.getNumIds()
 
    def getNames(self):
        return self.pp.getIds()
 
    def runProc(self,debug, isPyThread, fromscratch):
      print("**************************Begin schema execution %s**************************" % self.xmlFilexmlFile)
      self.ee.RunPy(self.pp,debug, isPyThread, fromscratch)
      print("**************************End schema execution %s****************************" % self.xmlFilexmlFile)
 
    def Run(self):
        if self.run1run1 is not None:
          execState = self.ee.getExecutorState()
          if execState >= pilot.FINISHED:
            self.run1run1.join()
            self.run1run1 = None
 
        if self.run1run1 is None:
            self.run1run1 = threading.Thread(None, self.runProcrunProc, "CORBAExec", (0,True,True))
            self.run1run1.start()
 
    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.run1run1 is not None:
          execState = self.ee.getExecutorState()
          if execState >= pilot.FINISHED:
            self.run1run1.join()
            self.run1run1 = None
 
        if xmlFile:
          try:
            self.pp.init()
            self.pp.exUpdateState();
            sp = loader.stateParser()
            sl = loader.stateLoader(sp,self.pp)
            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.run1run1 is None:
            self.run1run1 = threading.Thread(None, self.runProcrunProc, "CORBAExec", (0,True,False))
            self.run1run1.start()
 
    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.run1run1 is not None:
          execState = self.ee.getExecutorState()
          if execState >= pilot.FINISHED:
            self.run1run1.join()
            self.run1run1 = None
          else:
            return
 
        try:
          if os.path.exists(xmlFile):
            self.pp.init()
            sp = loader.stateParser()
            sl = loader.stateLoader(sp,self.pp)
            sl.parse(xmlFile)
 
          self.pp.resetState(1)
          self.pp.exUpdateState();
        except:
            pass
 
        if self.run1run1 is None:
            self.run1run1 = threading.Thread(None, self.runProcrunProc, "CORBAExec", (0,True,False))
            self.run1run1.start()
 
    def addObserver(self, obs, numid, event):
        disp = SALOMERuntime.SALOMEDispatcher_getSALOMEDispatcher()
        disp.addObserver(obs, numid, event)
        pass
 
    def setExecMode(self, mode):
        if mode == YACS_ORB.CONTINUE:
            self.ee.setExecMode(0)
            pass
        if mode == YACS_ORB.STEPBYSTEP:
            self.ee.setExecMode(1)
            pass
        if mode == YACS_ORB.STOPBEFORENODES:
            self.ee.setExecMode(2)
            pass
        pass
 
    def setListOfBreakPoints(self, listOfBreakPoints):
        self.ee.setListOfBreakPoints(listOfBreakPoints)
        pass
 
    def getTasksToLoad(self):
        return self.ee.getTasksToLoad()
 
    def setStepsToExecute(self, listToExecute):
        return self.ee.setStepsToExecute(listToExecute)
 
    def resumeCurrentBreakPoint(self):
        return self.ee.resumeCurrentBreakPoint()
 
    def isNotFinished(self):
        return self.ee.isNotFinished()
 
    def stopExecution(self):
        self.ee.stopExecution()
        pass
 
    def saveState(self, xmlFile):
        return self.ee.saveState(xmlFile)
 
    def setStopOnError(self, dumpRequested, xmlFile):
        self.ee.setStopOnError(dumpRequested, xmlFile)
        pass
 
    def unsetStopOnError(self):
        self.ee.unsetStopOnError()
        pass
 
    pass
 
 
class YACS(YACS_ORB__POA.YACS_Gen,
              SALOME_ComponentPy.SALOME_ComponentPy_i,
              SALOME_DriverPy.SALOME_DriverPy_i):
    """
    To be a SALOME component, this Python class must have the component name
    (YACS) and inherit the YACS_Gen class build from idl compilation
    with omniidl and also the class SALOME_ComponentPy_i which defines general
    SALOME component behaviour.
    """
    def __init__ ( self, orb, poa, contID, containerName, instanceName,
                   interfaceName ):
        print("YACS.__init__: ", containerName, ';', instanceName)
        SALOME_ComponentPy.SALOME_ComponentPy_i.__init__(self, orb, poa, contID,
                                                         containerName, instanceName,
                                                         interfaceName, False)
        SALOME_DriverPy.SALOME_DriverPy_i.__init__(self, interfaceName)
 
        SALOMERuntime.RuntimeSALOME.setRuntime(1)
        SALOMERuntime.SALOMEDispatcher_setSALOMEDispatcher()
        r=pilot.getRuntime()
 
        try:
          #try to load SALOME module catalogs
          modul_catalog = self._naming_service.Resolve("/Kernel/ModulCatalog")
          ior= orb.object_to_string(modul_catalog)
          cata=r.loadCatalog("session",ior)
          r.addCatalog(cata)
        except :
          pass
 
    """
    Get version information.
    """
    def getVersion( self ):
        try:
            rt = SALOMERuntime.getSALOMERuntime()
            version = rt.getVersion()
        except:
            version = ""
            pass
        return version
 
    def LoadProc(self,xmlFile):
        """
        load an XML graph in a YACS::ENGINE::proc, create a CORBA servant
        associated to the proc, and return a ref on the servant.
        """
        try:
            procExec_i = proc_i(xmlFile)
            logger=procExec_i.p.getLogger("parser")
            if not logger.isEmpty():
              print("The imported file has errors :")
              print(logger.getStr())
              sys.stdout.flush()
              return None
        except IOError as ex:
            print("IO Error: ", ex, file=sys.stderr)
            return None
        except ValueError as ex:
            print("Caught ValueError Exception:",ex, file=sys.stderr)
            return None
        except pilot.Exception as ex:
            print(ex.what(), file=sys.stderr)
            return None
        except:
            traceback.print_exc()
            return None
        procExec_o = procExec_i._this()
        return procExec_o
        
    def convertSupervFile(self,xmlFile):
        """
        load a SUPERV xml graph, convert it and return the new filename.
        """
        try:
            r = pilot.getRuntime()
            lo = salomeloader.SalomeLoader()
            e = pilot.ExecutorSwig()
            p = lo.load(xmlFile)
            s = pilot.SchemaSave(p)
            hnd, convertedFile = tempfile.mkstemp(".xml","yacs_","/tmp")
            s.save(convertedFile)
            return convertedFile
        except (IndexError):
            return ""
 
    pass