1 // Copyright (C) 2012-2015 CEA/DEN, EDF R&D
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.
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.
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
17 // See http://www.salome-platform.org/ or email : webmaster.salome@opencascade.com
19 // Author : Anthony Geay (EDF R&D)
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"
30 #include "Exception.hxx"
31 #include "parsers.hxx"
40 class MyAutoThreadSaver
43 MyAutoThreadSaver():_save(PyEval_SaveThread()) { }
44 ~MyAutoThreadSaver() { PyEval_RestoreThread(_save); }
49 YACSEvalYFX *YACSEvalYFX::BuildFromFile(const std::string& xmlOfScheme)
51 YACS::ENGINE::RuntimeSALOME::setRuntime();
53 YACS::ENGINE::Proc *scheme(l.load(xmlOfScheme.c_str()));
54 return new YACSEvalYFX(scheme,true);
57 YACSEvalYFX *YACSEvalYFX::BuildFromScheme(YACS::ENGINE::Proc *scheme)
59 return new YACSEvalYFX(scheme,false);
62 std::vector< YACSEvalInputPort * > YACSEvalYFX::getFreeInputPorts() const
64 return _pattern->getFreeInputPorts();
67 std::vector< YACSEvalOutputPort * > YACSEvalYFX::getFreeOutputPorts() const
69 return _pattern->getFreeOutputPorts();
72 void YACSEvalYFX::lockPortsForEvaluation(const std::vector< YACSEvalInputPort * >& inputsOfInterest, const std::vector< YACSEvalOutputPort * >& outputsOfInterest)
74 checkPortsForEvaluation(inputsOfInterest,outputsOfInterest);
75 _pattern->setOutPortsOfInterestForEvaluation(outputsOfInterest);
76 _pattern->generateGraph();
79 void YACSEvalYFX::unlockAll()
81 std::vector< YACSEvalInputPort * > allInputs(getFreeInputPorts());
82 for(std::vector< YACSEvalInputPort * >::const_iterator it=allInputs.begin();it!=allInputs.end();it++)
84 _pattern->resetOutputsOfInterest();
85 _pattern->resetGeneratedGraph();
88 bool YACSEvalYFX::isLocked() const
90 return _pattern->isLocked();
93 YACSEvalListOfResources *YACSEvalYFX::giveResources()
95 return _pattern->giveResources();
98 bool YACSEvalYFX::run(YACSEvalSession *session, int& nbOfBranches)
100 _pattern->assignRandomVarsInputs();
101 YACSEvalListOfResources *rss(giveResources());
102 if(!rss->isInteractive())
103 throw YACS::Exception("YACSEvalYFX::run : not implemented yet for non interactive !");
104 YACSEvalSession *mySession(session);
105 YACS::AutoCppPtr<YACSEvalSession> loc;
108 throw YACS::Exception("YACSEvalYFX::run : input session in null !");
109 /*loc=new YACSEvalSession;
113 nbOfBranches=_pattern->assignNbOfBranches();
115 YACS::ENGINE::Executor exe;
116 exe.setKeepGoingProperty(!_params.getStopASAPAfterErrorStatus());
118 _pattern->emitStart();
120 MyAutoThreadSaver locker;
121 exe.RunW(getUndergroundGeneratedGraph());
123 return getUndergroundGeneratedGraph()->getState()==YACS::DONE;
126 void YACSEvalYFX::registerObserver(YACSEvalObserver *observer)
129 throw YACS::Exception("YACSEvalYFX::registerObserver : no pattern !");
130 _pattern->registerObserver(observer);
133 YACSEvalObserver *YACSEvalYFX::getObserver()
136 throw YACS::Exception("YACSEvalYFX::getObserver : no pattern !");
137 return _pattern->getObserver();
140 std::string YACSEvalYFX::getErrorDetailsInCaseOfFailure() const
142 return _pattern->getErrorDetailsInCaseOfFailure();
145 std::string YACSEvalYFX::getStatusOfRunStr() const
147 return _pattern->getStatusOfRunStr();
150 std::vector<YACSEvalSeqAny *> YACSEvalYFX::getResults() const
152 return _pattern->getResults();
155 std::vector<YACSEvalSeqAny *> YACSEvalYFX::getResultsInCaseOfFailure(std::vector<unsigned int>& passedIds) const
157 return _pattern->getResultsInCaseOfFailure(passedIds);
160 YACS::ENGINE::Proc *YACSEvalYFX::getUndergroundGeneratedGraph() const
162 return _pattern->getUndergroundGeneratedGraph();
165 void YACSEvalYFX::setParallelizeStatus(bool newVal)
167 _pattern->setParallelizeStatus(newVal);
170 bool YACSEvalYFX::getParallelizeStatus() const
172 return _pattern->getParallelizeStatus();
175 YACSEvalYFX::YACSEvalYFX(YACS::ENGINE::Proc *scheme, bool ownScheme):_pattern(0)
177 _pattern=YACSEvalYFXPattern::FindPatternFrom(this,scheme,ownScheme);
180 void YACSEvalYFX::checkPortsForEvaluation(const std::vector< YACSEvalInputPort * >& inputs, const std::vector< YACSEvalOutputPort * >& outputs) const
182 std::set<YACSEvalInputPort * > inputs2(inputs.begin(),inputs.end());
183 std::vector< YACSEvalInputPort * > allInputs(getFreeInputPorts());
184 std::vector< YACSEvalOutputPort * > allOutputs(getFreeOutputPorts());
185 for(std::vector< YACSEvalInputPort * >::const_iterator it=allInputs.begin();it!=allInputs.end();it++)
187 if(inputs2.find(*it)==inputs2.end())
189 if(!(*it)->isOKForLock())
191 std::ostringstream oss; oss << "YACSEvalYFX::checkPortsForEvaluation : input port with name \"" << (*it)->getName() << "\" is not set properly !";
192 throw YACS::Exception(oss.str());
196 for(std::vector< YACSEvalOutputPort * >::const_iterator it=outputs.begin();it!=outputs.end();it++)
197 if(std::find(allOutputs.begin(),allOutputs.end(),*it)==allOutputs.end())
198 throw YACS::Exception("YACSEvalYFX::lockPortsForEvaluation : one of output is not part of this !");
199 std::set< YACSEvalOutputPort * > soutputs(outputs.begin(),outputs.end());
200 if(soutputs.size()!=outputs.size())
201 throw YACS::Exception("YACSEvalYFX::lockPortsForEvaluation : each elt in outputs must appear once !");
202 for(std::vector< YACSEvalInputPort * >::const_iterator it=allInputs.begin();it!=allInputs.end();it++)
204 (*it)->declareRandomnessStatus(inputs2.find(*it)!=inputs2.end());
209 YACSEvalYFX::~YACSEvalYFX()