src/runtime/SalomeContainerHelper.cxx

   1 // Copyright (C) 2006-2014  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
  20 #include "SalomeContainerHelper.hxx"
  21
  22 #include "ServiceNode.hxx"
  23 #include "YacsTrace.hxx"
  24
  25 #include <sstream>
  26 #include <iostream>
  27
  28 using namespace YACS::ENGINE;
  29 using namespace std;
  30
  31 const char SalomeContainerMonoHelper::TYPE_NAME[]="mono";
  32
  33 const char SalomeContainerMonoHelper::DFT_LAUNCH_MODE[]="start";
  34
  35 const char SalomeContainerMultiHelper::TYPE_NAME[]="multi";
  36
  37 const char SalomeContainerMultiHelper::DFT_LAUNCH_MODE[]="getorstart";
  38
  39 SalomeContainerHelper::~SalomeContainerHelper()
  40 {
  41 }
  42
  43 SalomeContainerMonoHelper::SalomeContainerMonoHelper():_trueCont(Engines::Container::_nil())
  44 {
  45
  46 }
  47
  48 std::string SalomeContainerMonoHelper::getType() const
  49 {
  50   return TYPE_NAME;
  51 }
  52
  53 SalomeContainerMonoHelper *SalomeContainerMonoHelper::deepCpyOnlyStaticInfo() const
  54 {
  55   return new SalomeContainerMonoHelper;
  56 }
  57
  58 Engines::Container_var SalomeContainerMonoHelper::getContainer(const Task *askingNode) const
  59 {
  60   return _trueCont;
  61 }
  62
  63 bool SalomeContainerMonoHelper::isAlreadyStarted(const Task *askingNode) const
  64 {
  65   if(CORBA::is_nil(_trueCont))
  66     return false;
  67   else
  68     return true;
  69 }
  70
  71 void SalomeContainerMonoHelper::setContainer(const Task *askingNode, Engines::Container_var cont)
  72 {
  73   _trueCont=cont;
  74 #ifdef REFCNT
  75     DEBTRACE(_trueCont->_PR_getobj()->pd_refCount );
  76 #endif
  77 }
  78
  79 void SalomeContainerMonoHelper::shutdown()
  80 {
  81   try
  82   {
  83       DEBTRACE("shutdown SALOME container: " );
  84       CORBA::String_var containerName=_trueCont->name();
  85       DEBTRACE(containerName);
  86       _trueCont->Shutdown();
  87       std::cerr << "shutdown SALOME container: " << containerName << std::endl;
  88   }
  89   catch(...)
  90   {
  91       DEBTRACE("Unknown exception ignored." );
  92   }
  93   _trueCont=Engines::Container::_nil();
  94 }
  95
  96 SalomeContainerMonoHelper::~SalomeContainerMonoHelper()
  97 {
  98 }
  99
 100 std::string SalomeContainerMultiHelper::getType() const
 101 {
 102   return TYPE_NAME;
 103 }
 104
 105 SalomeContainerMultiHelper *SalomeContainerMultiHelper::deepCpyOnlyStaticInfo() const
 106 {
 107   return new SalomeContainerMultiHelper;
 108 }
 109
 110 Engines::Container_var SalomeContainerMultiHelper::getContainer(const Task *askingNode) const
 111 {
 112   const ComponentInstance *inst(askingNode?askingNode->getComponent():0);
 113   std::map<const ComponentInstance *,Engines::Container_var>::const_iterator it(_trueContainers.find(inst));
 114   if(it!=_trueContainers.end())
 115     return (*it).second;
 116   else
 117     return Engines::Container::_nil();
 118 }
 119
 120 bool SalomeContainerMultiHelper::isAlreadyStarted(const Task *askingNode) const
 121 {
 122   const ComponentInstance *inst(askingNode?askingNode->getComponent():0);
 123   if(_trueContainers.count(inst)==0)
 124     return false;
 125   else
 126     return true;
 127 }
 128
 129 void SalomeContainerMultiHelper::setContainer(const Task *askingNode, Engines::Container_var cont)
 130 {
 131   const ComponentInstance *inst(askingNode?askingNode->getComponent():0);
 132   _trueContainers[inst]=cont;
 133 #ifdef REFCNT
 134     std::map<const ComponentInstance *, Engines::Container_var >::const_iterator it;
 135     for(it = _trueContainers.begin(); it != _trueContainers.end(); ++it)
 136       {
 137         DEBTRACE(it->second->_PR_getobj()->pd_refCount );
 138       }
 139 #endif
 140 }
 141
 142 void SalomeContainerMultiHelper::shutdown()
 143 {
 144   for(std::map<const ComponentInstance *, Engines::Container_var >::const_iterator it = _trueContainers.begin(); it != _trueContainers.end(); ++it)
 145     {
 146       try
 147       {
 148           DEBTRACE("shutdown SALOME container: " );
 149           CORBA::String_var containerName=it->second->name();
 150           DEBTRACE(containerName);
 151           it->second->Shutdown();
 152           std::cerr << "shutdown SALOME container: " << containerName << std::endl;
 153       }
 154       catch(CORBA::Exception&)
 155       {
 156           DEBTRACE("Unexpected CORBA failure detected." );
 157       }
 158       catch(...)
 159       {
 160           DEBTRACE("Unknown exception ignored." );
 161       }
 162     }
 163   _trueContainers.clear();
 164 }
 165
 166 SalomeContainerMultiHelper::~SalomeContainerMultiHelper()
 167 {
 168 }