X-Git-Url: http://git.salome-platform.org/gitweb/?a=blobdiff_plain;f=src%2FGENERICSOLVER%2FDEVIATION.py;h=8affa5738e6bd564a46bf6945a48c697f198eee1;hb=refs%2Ftags%2FV9_13_0a2;hp=369cabb06ab204623207bb4fdbdd956f0a3c7c5c;hpb=c3e08942f0996fcd79339b2be486acc0a1dd43c3;p=samples%2Fgenericsolver.git diff --git a/src/GENERICSOLVER/DEVIATION.py b/src/GENERICSOLVER/DEVIATION.py index 369cabb..8affa57 100644 --- a/src/GENERICSOLVER/DEVIATION.py +++ b/src/GENERICSOLVER/DEVIATION.py @@ -1,41 +1,47 @@ -# Copyright (C) 2009-2010 EDF R&D +# Copyright (C) 2009-2024 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. +# 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. +# 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 +# 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 -# -# $Id$ +# See http://www.salome-platform.org/ or email : webmaster.salome@opencascade.com # +import inspect import logging +import os +import platform import threading -import inspect import traceback -import salome +from salome.gui.helper import sgPyQt +from salome.kernel import termcolor +from salome.kernel.logger import Logger +from salome.kernel.parametric.compo_utils import \ + create_input_dict, create_normal_parametric_output, create_error_parametric_output import GENERICSOLVER_ORB__POA +import SALOME import SALOME_ComponentPy import SALOME_DriverPy -import SALOME -import SALOME_Parametric +import SALOME_Embedded_NamingService_ClientPy +import _thread +import salome -from salome.kernel.logger import Logger -from salome.kernel import termcolor -logger = Logger("DEVIATION", color = termcolor.RED_FG) + +logger = Logger("DEVIATION", color=termcolor.RED_FG) logger.setLevel(logging.INFO) + VARIABLE_ID = 1030 ### @@ -74,14 +80,14 @@ def getValueOfVariable( builder, varobj ): def getSubSObjectByName( studyId, sobjFather, childName ): logger.debug("GENERICSOLVER.getSubSObjectByName Looking for sobjet named " + childName) study = salome.myStudyManager.GetStudyByID( studyId ) - iter = study.NewChildIterator( sobjFather ) + iterator = study.NewChildIterator(sobjFather) #builder = study.NewBuilder() - while iter.More(): - sobj = iter.Value() + while iterator.More(): + sobj = iterator.Value() logger.debug("GENERICSOLVER.getSubSObjectByName Got sobjet named " + sobj.GetName()) if sobj.GetName() == childName: return sobj - iter.Next() + iterator.Next() pass return None @@ -104,11 +110,19 @@ class DEVIATION(GENERICSOLVER_ORB__POA.DEVIATION_Gen, interfaceName ): logger.info("__init__: " + containerName + ' ; ' + instanceName) SALOME_ComponentPy.SALOME_ComponentPy_i.__init__(self, orb, poa, - contID, containerName, instanceName, interfaceName, 0) + contID, containerName, instanceName, interfaceName, False) SALOME_DriverPy.SALOME_DriverPy_i.__init__(self, interfaceName) # On stocke dans l'attribut _naming_service, une reference sur # le Naming Service CORBA - self._naming_service = SALOME_ComponentPy.SALOME_NamingServicePy_i( self._orb ) + #self._naming_service = SALOME_ComponentPy.SALOME_NamingServicePy_i( self._orb ) + # + emb_ns = self._contId.get_embedded_NS_if_ssl() + import CORBA + if CORBA.is_nil(emb_ns): + self._naming_service = SALOME_ComponentPy.SALOME_NamingServicePy_i( self._orb ) + else: + self._naming_service = SALOME_Embedded_NamingService_ClientPy.SALOME_Embedded_NamingService_ClientPy(emb_ns) + # self.deterministicValues = {} ###################################################################### @@ -126,6 +140,11 @@ class DEVIATION(GENERICSOLVER_ORB__POA.DEVIATION_Gen, exc = SALOME.ExceptionStruct(SALOME.INTERNAL_ERROR, message, inspect.stack()[1][1], inspect.stack()[1][2]) raise SALOME.SALOME_Exception(exc) + + def _getIdMessage(self): + return "%s in container %s running on %s, process %d, thread %d" % \ + (self._instanceName, self._containerName, + platform.node(), os.getpid(), _thread.get_ident()) def Init(self, studyId, detCaseEntry): """ @@ -133,7 +152,7 @@ class DEVIATION(GENERICSOLVER_ORB__POA.DEVIATION_Gen, use with OpenTURNS in SALOME 5.1.5 and later (for YACS integration) """ try: - logger.info("Init: " + self._containerName + ' ; ' + self._instanceName) + logger.info("Init: " + self._getIdMessage()) DEVIATION.lock.acquire() salome.salome_init() DEVIATION.lock.release() @@ -149,29 +168,35 @@ class DEVIATION(GENERICSOLVER_ORB__POA.DEVIATION_Gen, use with OpenTURNS in SALOME 5.1.5 and later (for YACS integration) """ try: - logger.info("Exec: " + self._containerName + ' ; ' + self._instanceName) + logger.info("Exec: " + self._getIdMessage()) logger.debug("inputVarList: %s" % paramInput.inputVarList) logger.debug("outputVarList: %s" % paramInput.outputVarList) logger.debug("inputValues: %s" % paramInput.inputValues) - if len(paramInput.inputValues) != len(paramInput.inputVarList): - raise Exception("Size mismatch between inputVarList and point to evaluate") - - evalPoint = self.deterministicValues - for i in range(len(paramInput.inputVarList)): - evalPoint[paramInput.inputVarList[i]] = paramInput.inputValues[i][0][0] - logger.debug("evalPoint = %s" % evalPoint) - - resDict = {} - resDict["dev"] = self.BeamModel(**evalPoint) - - outputValues = [] - for outputVar in paramInput.outputVarList: - outputValues.append([[resDict[outputVar]]]) - logger.debug("paramOutput: %s" % outputValues) - return SALOME_Parametric.ParametricOutput(outputValues, - specificOutputInfos = [], - returnCode = 0, - errorMessage = "") + + # Get id and execution mode + id = "" + exec_mode = "" + for parameter in paramInput.specificParameters: + if parameter.name == "id": + id = parameter.value + if parameter.name == "executionMode": + exec_mode = parameter.value + logger.debug("ID: %s" % id) + logger.debug("Execution mode: %s" % exec_mode) + + inputDict = create_input_dict(self.deterministicValues, paramInput) + logger.debug("inputDict = %s" % inputDict) + + # Test for an invalid parameter and return an error in this case + if inputDict["L"] <= 0: + return create_error_parametric_output("Invalid value: L must be positive") + + outputDict = {} + outputDict["dev"] = self.BeamModel(**inputDict) + + paramOutput = create_normal_parametric_output(outputDict, paramInput) + logger.debug("outputValues: %s" % paramOutput.outputValues) + return paramOutput except: self._raiseSalomeError() @@ -181,10 +206,24 @@ class DEVIATION(GENERICSOLVER_ORB__POA.DEVIATION_Gen, It cleans everything set so far. """ try: - logger.info("Finalize: " + self._containerName + ' ; ' + self._instanceName) + logger.info("Finalize: " + self._getIdMessage()) except: self._raiseSalomeError() - + + def GetFilesToTransfer(self, studyId, detCaseEntry): + """ + This method can be used to specify files to transfer to the + computation resource. It is not useful for DEVIATION since it only + uses values from Salome study. + """ + try: + logger.info("GetFilesToTransfer: " + self._getIdMessage()) + inputFiles = [] + outputFiles = [] + return (inputFiles, outputFiles) + except: + self._raiseSalomeError() + ###################################################################### # This is the computation part of the GENERICSOLVER module, ie # the following method realizes what the solver is intended to do.