1 // Copyright (C) 2006-2024 CEA, EDF
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
20 #include "SalomeContainerHelper.hxx"
22 #include "ServiceNode.hxx"
24 #include "utilities.h"
29 using namespace YACS::ENGINE;
32 const char SalomeContainerMonoHelper::TYPE_NAME[]="mono";
34 const char SalomeContainerMonoHelper::DFT_LAUNCH_MODE[]="start";
36 const char SalomeContainerMultiHelper::TYPE_NAME[]="multi";
38 const char SalomeContainerMultiHelper::DFT_LAUNCH_MODE[]="getorstart";
40 SalomeContainerHelper::~SalomeContainerHelper()
44 SalomeContainerMonoHelper::SalomeContainerMonoHelper():_trueCont(Engines::Container::_nil())
49 std::string SalomeContainerMonoHelper::getType() const
54 std::string SalomeContainerMonoHelper::getDftLaunchMode() const
56 return std::string(DFT_LAUNCH_MODE);
59 SalomeContainerMonoHelper *SalomeContainerMonoHelper::deepCpyOnlyStaticInfo() const
61 return new SalomeContainerMonoHelper;
64 Engines::Container_var SalomeContainerMonoHelper::getContainer(const Task *askingNode) const
69 bool SalomeContainerMonoHelper::isAlreadyStarted(const Task *askingNode) const
71 if(CORBA::is_nil(_trueCont))
77 void SalomeContainerMonoHelper::setContainer(const Task *askingNode, Engines::Container_var cont)
81 DEBTRACE(_trueCont->_PR_getobj()->pd_refCount );
85 bool SalomeContainerMonoHelper::isKernelContNull() const
87 return CORBA::is_nil(_trueCont);
90 void SalomeContainerMonoHelper::shutdown()
92 if(CORBA::is_nil(_trueCont))
96 CORBA::String_var containerName=_trueCont->name();
97 INFO_MESSAGE("shutdown SALOME container: " << containerName);
98 _trueCont->Shutdown();
102 ERROR_MESSAGE("Unknown exception ignored." );
104 _trueCont=Engines::Container::_nil();
107 std::string SalomeContainerMonoHelper::getKernelContainerName() const
109 if(CORBA::is_nil(_trueCont))
110 return std::string("NULL");
111 CORBA::String_var containerName(_trueCont->name());
112 std::string ret(containerName);
116 SalomeContainerMonoHelper::~SalomeContainerMonoHelper()
120 std::string SalomeContainerMultiHelper::getType() const
125 std::string SalomeContainerMultiHelper::getDftLaunchMode() const
127 return std::string(DFT_LAUNCH_MODE);
130 SalomeContainerMultiHelper *SalomeContainerMultiHelper::deepCpyOnlyStaticInfo() const
132 return new SalomeContainerMultiHelper;
135 Engines::Container_var SalomeContainerMultiHelper::getContainer(const Task *askingNode) const
137 std::unique_lock<std::mutex> lock(_data_mutex);
138 const ComponentInstance *inst(askingNode?askingNode->getComponent():0);
139 if(inst == nullptr && askingNode != nullptr && askingNode->hasImposedResource())
141 std::map<const Task *,Engines::Container_var>::const_iterator it(_containersForTasks.find(askingNode));
142 if(it!=_containersForTasks.end())
145 return Engines::Container::_nil();
149 std::map<const ComponentInstance *,Engines::Container_var>::const_iterator it(_containersForComponents.find(inst));
150 if(it!=_containersForComponents.end())
153 return Engines::Container::_nil();
157 bool SalomeContainerMultiHelper::isAlreadyStarted(const Task *askingNode) const
159 std::unique_lock<std::mutex> lock(_data_mutex);
160 const ComponentInstance *inst(askingNode?askingNode->getComponent():0);
161 if(inst == nullptr && askingNode != nullptr && askingNode->hasImposedResource())
163 return _containersForTasks.count(askingNode) > 0;
167 if(_containersForComponents.count(inst)==0)
174 void SalomeContainerMultiHelper::setContainer(const Task *askingNode, Engines::Container_var cont)
176 std::unique_lock<std::mutex> lock(_data_mutex);
177 const ComponentInstance *inst(askingNode?askingNode->getComponent():0);
178 if(inst == nullptr && askingNode != nullptr && askingNode->hasImposedResource())
180 _containersForTasks[askingNode] = cont;
184 _containersForComponents[inst]=cont;
186 std::map<const ComponentInstance *, Engines::Container_var >::const_iterator it;
187 for(it = _containersForComponents.begin(); it != _containersForComponents.end(); ++it)
189 DEBTRACE(it->second->_PR_getobj()->pd_refCount );
195 void SalomeContainerMultiHelper::shutdown()
197 std::unique_lock<std::mutex> lock(_data_mutex);
198 for(std::map<const Task *, Engines::Container_var >::const_iterator it = _containersForTasks.begin();
199 it != _containersForTasks.end(); ++it)
203 CORBA::String_var containerName=it->second->name();
204 INFO_MESSAGE("shutdown SALOME container: " << containerName);
205 it->second->Shutdown();
207 catch(CORBA::Exception&)
209 ERROR_MESSAGE("Unexpected CORBA failure detected." );
213 ERROR_MESSAGE("Unknown exception ignored." );
216 _containersForTasks.clear();
218 for(std::map<const ComponentInstance *, Engines::Container_var >::const_iterator it = _containersForComponents.begin(); it != _containersForComponents.end(); ++it)
222 CORBA::String_var containerName=it->second->name();
223 INFO_MESSAGE("shutdown SALOME container: " << containerName);
224 it->second->Shutdown();
225 std::cerr << "shutdown SALOME container: " << containerName << std::endl;
227 catch(CORBA::Exception&)
229 ERROR_MESSAGE("Unexpected CORBA failure detected." );
233 ERROR_MESSAGE("Unknown exception ignored." );
236 _containersForComponents.clear();
239 SalomeContainerMultiHelper::~SalomeContainerMultiHelper()