src/evalyfx/YACSEvalYFX.cxx

   1 // Copyright (C) 2012-2021  CEA/DEN, EDF R&D
   2 //
   3 // This library is free software; you can redistribute it and/or
   4 // modify it under the terms of the GNU Lesser General Public
   5 // License as published by the Free Software Foundation; either
   6 // version 2.1 of the License, or (at your option) any later version.
   7 //
   8 // This library is distributed in the hope that it will be useful,
   9 // but WITHOUT ANY WARRANTY; without even the implied warranty of
  10 // MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the GNU
  11 // Lesser General Public License for more details.
  12 //
  13 // You should have received a copy of the GNU Lesser General Public
  14 // License along with this library; if not, write to the Free Software
  15 // Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA  02111-1307 USA
  16 //
  17 // See http://www.salome-platform.org/ or email : webmaster.salome@opencascade.com
  18 //
  19 // Author : Anthony Geay (EDF R&D)
  20
  21 #include "YACSEvalYFX.hxx"
  22 #include "YACSEvalYFXPattern.hxx"
  23 #include "YACSEvalAutoPtr.hxx"
  24 #include "YACSEvalResource.hxx"
  25 #include "YACSEvalSession.hxx"
  26 #include "YACSEvalPort.hxx"
  27 #include "RuntimeSALOME.hxx"
  28 #include "Executor.hxx"
  29 #include "Proc.hxx"
  30 #include "Exception.hxx"
  31 #include "parsers.hxx"
  32
  33 #include <algorithm>
  34 #include <sstream>
  35 #include <limits>
  36 #include <set>
  37
  38 #include <Python.h>
  39
  40 YACSEvalYFX *YACSEvalYFX::BuildFromFile(const std::string& xmlOfScheme)
  41 {
  42   YACS::ENGINE::RuntimeSALOME::setRuntime();
  43   YACS::YACSLoader l;
  44   YACS::ENGINE::Proc *scheme(l.load(xmlOfScheme.c_str()));
  45   return new YACSEvalYFX(scheme,true);
  46 }
  47
  48 YACSEvalYFX *YACSEvalYFX::BuildFromScheme(YACS::ENGINE::Proc *scheme)
  49 {
  50   return new YACSEvalYFX(scheme,false);
  51 }
  52
  53 std::vector< YACSEvalInputPort * > YACSEvalYFX::getFreeInputPorts() const
  54 {
  55   return _pattern->getFreeInputPorts();
  56 }
  57
  58 std::vector< YACSEvalOutputPort * > YACSEvalYFX::getFreeOutputPorts() const
  59 {
  60   return _pattern->getFreeOutputPorts();
  61 }
  62
  63 void YACSEvalYFX::lockPortsForEvaluation(const std::vector< YACSEvalInputPort * >& inputsOfInterest, const std::vector< YACSEvalOutputPort * >& outputsOfInterest)
  64 {
  65   checkPortsForEvaluation(inputsOfInterest,outputsOfInterest);
  66   _pattern->setOutPortsOfInterestForEvaluation(outputsOfInterest);
  67 }
  68
  69 void YACSEvalYFX::unlockAll()
  70 {
  71   std::vector< YACSEvalInputPort * > allInputs(getFreeInputPorts());
  72   for(std::vector< YACSEvalInputPort * >::const_iterator it=allInputs.begin();it!=allInputs.end();it++)
  73     (*it)->unlock();
  74   _pattern->resetOutputsOfInterest();
  75   _pattern->resetGeneratedGraph();
  76 }
  77
  78 bool YACSEvalYFX::isLocked() const
  79 {
  80   return _pattern->isLocked();
  81 }
  82
  83 /*!
  84  * Caller is not responsible from returned pointer
  85  */
  86 YACSEvalListOfResources *YACSEvalYFX::giveResources()
  87 {
  88   return _pattern->giveResources();
  89 }
  90
  91 bool YACSEvalYFX::run(YACSEvalSession *session, int& nbOfBranches)
  92 {
  93   _pattern->generateGraph();
  94   if(!session)
  95     {
  96       throw YACS::Exception("YACSEvalYFX::run : input session in null !");
  97     }
  98   session->launch();
  99   YACSEvalListOfResources *rss(giveResources());
 100   rss->checkOKForRun();
 101   _pattern->assignRandomVarsInputs();
 102   rss->apply();
 103   nbOfBranches=_pattern->assignNbOfBranches();
 104   return _pattern->go(_params,session);
 105 }
 106
 107 void YACSEvalYFX::registerObserver(YACSEvalObserver *observer)
 108 {
 109   if(!_pattern)
 110     throw YACS::Exception("YACSEvalYFX::registerObserver : no pattern !");
 111   _pattern->registerObserver(observer);
 112 }
 113
 114 YACSEvalObserver *YACSEvalYFX::getObserver()
 115 {
 116   if(!_pattern)
 117     throw YACS::Exception("YACSEvalYFX::getObserver : no pattern !");
 118   return _pattern->getObserver();
 119 }
 120
 121 std::string YACSEvalYFX::getErrorDetailsInCaseOfFailure() const
 122 {
 123   return _pattern->getErrorDetailsInCaseOfFailure();
 124 }
 125
 126 std::string YACSEvalYFX::getStatusOfRunStr() const
 127 {
 128   return _pattern->getStatusOfRunStr();
 129 }
 130
 131 std::vector<YACSEvalSeqAny *> YACSEvalYFX::getResults() const
 132 {
 133   return _pattern->getResults();
 134 }
 135
 136 std::vector<YACSEvalSeqAny *> YACSEvalYFX::getResultsInCaseOfFailure(std::vector<unsigned int>& passedIds) const
 137 {
 138   return _pattern->getResultsInCaseOfFailure(passedIds);
 139 }
 140
 141 YACS::ENGINE::Proc *YACSEvalYFX::getUndergroundGeneratedGraph() const
 142 {
 143   return _pattern->getUndergroundGeneratedGraph();
 144 }
 145
 146 void YACSEvalYFX::setParallelizeStatus(bool newVal)
 147 {
 148   _pattern->setParallelizeStatus(newVal);
 149 }
 150
 151 bool YACSEvalYFX::getParallelizeStatus() const
 152 {
 153   return _pattern->getParallelizeStatus();
 154 }
 155
 156 YACSEvalYFX::YACSEvalYFX(YACS::ENGINE::Proc *scheme, bool ownScheme):_pattern(0)
 157 {
 158   _pattern=YACSEvalYFXPattern::FindPatternFrom(this,scheme,ownScheme);
 159 }
 160
 161 void YACSEvalYFX::checkPortsForEvaluation(const std::vector< YACSEvalInputPort * >& inputs, const std::vector< YACSEvalOutputPort * >& outputs) const
 162 {
 163   std::set<YACSEvalInputPort * > inputs2(inputs.begin(),inputs.end());
 164   std::vector< YACSEvalInputPort * > allInputs(getFreeInputPorts());
 165   std::vector< YACSEvalOutputPort * > allOutputs(getFreeOutputPorts());
 166   for(std::vector< YACSEvalInputPort * >::const_iterator it=allInputs.begin();it!=allInputs.end();it++)
 167     {
 168       if(inputs2.find(*it)==inputs2.end())
 169         {
 170           if(!(*it)->isOKForLock())
 171             {
 172               std::ostringstream oss; oss << "YACSEvalYFX::checkPortsForEvaluation : input port with name \"" << (*it)->getName() << "\" is not set properly !";
 173               throw YACS::Exception(oss.str());
 174             }
 175         }
 176     }
 177   for(std::vector< YACSEvalOutputPort * >::const_iterator it=outputs.begin();it!=outputs.end();it++)
 178     if(std::find(allOutputs.begin(),allOutputs.end(),*it)==allOutputs.end())
 179       throw YACS::Exception("YACSEvalYFX::lockPortsForEvaluation : one of output is not part of this !");
 180   std::set< YACSEvalOutputPort * > soutputs(outputs.begin(),outputs.end());
 181   if(soutputs.size()!=outputs.size())
 182     throw YACS::Exception("YACSEvalYFX::lockPortsForEvaluation : each elt in outputs must appear once !");
 183   for(std::vector< YACSEvalInputPort * >::const_iterator it=allInputs.begin();it!=allInputs.end();it++)
 184     {
 185       (*it)->declareRandomnessStatus(inputs2.find(*it)!=inputs2.end());
 186       (*it)->lock();
 187     }
 188 }
 189
 190 YACSEvalYFX::~YACSEvalYFX()
 191 {
 192   delete _pattern;
 193 }