#include <SalomeContainerHelper.hxx>

Inheritance diagram for YACS::ENGINE::SalomeContainerMultiHelper:

Collaboration diagram for YACS::ENGINE::SalomeContainerMultiHelper:

[legend]

Public Member Functions
std::string	getType () const

std::string	getDftLaunchMode () const

SalomeContainerMultiHelper *	deepCpyOnlyStaticInfo () const

Engines::Container_var	getContainer (const Task *askingNode) const

bool	isAlreadyStarted (const Task *askingNode) const

void	setContainer (const Task *askingNode, Engines::Container_var cont)

void	shutdown ()

virtual std::string	getType () const =0

virtual std::string	getDftLaunchMode () const =0

virtual SalomeContainerHelper *	deepCpyOnlyStaticInfo () const =0

virtual Engines::Container_var	getContainer (const Task *askingNode) const =0

virtual bool	isAlreadyStarted (const Task *askingNode) const =0

virtual void	setContainer (const Task *askingNode, Engines::Container_var cont)=0

virtual void	shutdown ()=0

Public Member Functions inherited from YACS::ENGINE::RefCounter
unsigned int	getRefCnt () const

void	incrRef () const

bool	decrRef () const

Static Public Attributes
static const char	TYPE_NAME [] ="multi"

static const char	DFT_LAUNCH_MODE [] ="getorstart"

Static Public Attributes inherited from YACS::ENGINE::RefCounter
static unsigned int	_totalCnt =0

Private Member Functions
	~SalomeContainerMultiHelper ()

Private Attributes
std::map< const ComponentInstance *, Engines::Container_var >	_containersForComponents

std::map< const Task *, Engines::Container_var >	_containersForTasks

std::mutex	_data_mutex

Additional Inherited Members
Protected Member Functions inherited from YACS::ENGINE::SalomeContainerHelper
virtual	~SalomeContainerHelper ()

Protected Member Functions inherited from YACS::ENGINE::RefCounter
	RefCounter ()

	RefCounter (const RefCounter &other)

virtual	~RefCounter ()

Protected Attributes inherited from YACS::ENGINE::RefCounter
unsigned int	_cnt

Detailed Description

Definition at line 77 of file SalomeContainerHelper.hxx.

Constructor & Destructor Documentation

◆ ~SalomeContainerMultiHelper()

SalomeContainerMultiHelper::~SalomeContainerMultiHelper ( )

private

Definition at line 239 of file SalomeContainerHelper.cxx.

240{

241}

Member Function Documentation

◆ deepCpyOnlyStaticInfo()

SalomeContainerMultiHelper * SalomeContainerMultiHelper::deepCpyOnlyStaticInfo ( ) const

virtual

Implements YACS::ENGINE::SalomeContainerHelper.

Definition at line 130 of file SalomeContainerHelper.cxx.

{
  return new SalomeContainerMultiHelper;
}

◆ getContainer()

Engines::Container_var SalomeContainerMultiHelper::getContainer ( const Task * askingNode ) const

virtual

Implements YACS::ENGINE::SalomeContainerHelper.

Definition at line 135 of file SalomeContainerHelper.cxx.

{
  std::unique_lock<std::mutex> lock(_data_mutex);
  const ComponentInstance *inst(askingNode?askingNode->getComponent():0);
  if(inst == nullptr && askingNode != nullptr && askingNode->hasImposedResource())
  {
    std::map<const Task *,Engines::Container_var>::const_iterator it(_containersForTasks.find(askingNode));
    if(it!=_containersForTasks.end())
      return (*it).second;
    else
      return Engines::Container::_nil();
  }
  else
  {
    std::map<const ComponentInstance *,Engines::Container_var>::const_iterator it(_containersForComponents.find(inst));
    if(it!=_containersForComponents.end())
      return (*it).second;
    else
      return Engines::Container::_nil();
  }
}

References _containersForComponents, _containersForTasks, _data_mutex, YACS::ENGINE::Task::getComponent(), and YACS::ENGINE::Task::hasImposedResource().

◆ getDftLaunchMode()

std::string SalomeContainerMultiHelper::getDftLaunchMode ( ) const

virtual

Implements YACS::ENGINE::SalomeContainerHelper.

Definition at line 125 of file SalomeContainerHelper.cxx.

{
  return std::string(DFT_LAUNCH_MODE);
}

References DFT_LAUNCH_MODE.

◆ getType()

std::string SalomeContainerMultiHelper::getType ( ) const

virtual

Implements YACS::ENGINE::SalomeContainerHelper.

Definition at line 120 of file SalomeContainerHelper.cxx.

{
  return TYPE_NAME;
}

References TYPE_NAME.

◆ isAlreadyStarted()

bool SalomeContainerMultiHelper::isAlreadyStarted ( const Task * askingNode ) const

virtual

Implements YACS::ENGINE::SalomeContainerHelper.

Definition at line 157 of file SalomeContainerHelper.cxx.

{
  std::unique_lock<std::mutex> lock(_data_mutex);
  const ComponentInstance *inst(askingNode?askingNode->getComponent():0);
  if(inst == nullptr && askingNode != nullptr && askingNode->hasImposedResource())
  {
    return _containersForTasks.count(askingNode) > 0;
  }
  else
  {
    if(_containersForComponents.count(inst)==0)
      return false;
    else
      return true;
  }
}

References _containersForComponents, _containersForTasks, _data_mutex, YACS::ENGINE::Task::getComponent(), and YACS::ENGINE::Task::hasImposedResource().

◆ setContainer()

void SalomeContainerMultiHelper::setContainer	(	const Task *	askingNode,
		Engines::Container_var	cont
	)

virtual

Implements YACS::ENGINE::SalomeContainerHelper.

Definition at line 174 of file SalomeContainerHelper.cxx.

{
  std::unique_lock<std::mutex> lock(_data_mutex);
  const ComponentInstance *inst(askingNode?askingNode->getComponent():0);
  if(inst == nullptr && askingNode != nullptr && askingNode->hasImposedResource())
  {
    _containersForTasks[askingNode] = cont;
  }
  else
  {
    _containersForComponents[inst]=cont;
#ifdef REFCNT
    std::map<const ComponentInstance *, Engines::Container_var >::const_iterator it;
    for(it = _containersForComponents.begin(); it != _containersForComponents.end(); ++it)
      {
        DEBTRACE(it->second->_PR_getobj()->pd_refCount );
      }
#endif
  }
}

References _containersForComponents, _containersForTasks, _data_mutex, DEBTRACE, YACS::ENGINE::Task::getComponent(), and YACS::ENGINE::Task::hasImposedResource().

◆ shutdown()

void SalomeContainerMultiHelper::shutdown ( )

virtual

Implements YACS::ENGINE::SalomeContainerHelper.

Definition at line 195 of file SalomeContainerHelper.cxx.

{
  std::unique_lock<std::mutex> lock(_data_mutex);
  for(std::map<const Task *, Engines::Container_var >::const_iterator it = _containersForTasks.begin();
      it != _containersForTasks.end(); ++it)
  {
    try
    {
        CORBA::String_var containerName=it->second->name();
        INFO_MESSAGE("shutdown SALOME container: " << containerName);
        it->second->Shutdown();
    }
    catch(CORBA::Exception&)
    {
        ERROR_MESSAGE("Unexpected CORBA failure detected." );
    }
    catch(...)
    {
        ERROR_MESSAGE("Unknown exception ignored." );
    }
  }
  _containersForTasks.clear();
 
  for(std::map<const ComponentInstance *, Engines::Container_var >::const_iterator it = _containersForComponents.begin(); it != _containersForComponents.end(); ++it)
    {
      try
      {
          CORBA::String_var containerName=it->second->name();
          INFO_MESSAGE("shutdown SALOME container: " << containerName);
          it->second->Shutdown();
          std::cerr << "shutdown SALOME container: " << containerName << std::endl;
      }
      catch(CORBA::Exception&)
      {
          ERROR_MESSAGE("Unexpected CORBA failure detected." );
      }
      catch(...)
      {
          ERROR_MESSAGE("Unknown exception ignored." );
      }
    }
  _containersForComponents.clear();
}

References _containersForComponents, _containersForTasks, and _data_mutex.

Member Data Documentation

◆ _containersForComponents

std::map<const ComponentInstance *,Engines::Container_var> YACS::ENGINE::SalomeContainerMultiHelper::_containersForComponents

private

Definition at line 93 of file SalomeContainerHelper.hxx.

Referenced by getContainer(), isAlreadyStarted(), setContainer(), and shutdown().

◆ _containersForTasks

std::map<const Task *,Engines::Container_var> YACS::ENGINE::SalomeContainerMultiHelper::_containersForTasks

private

Definition at line 94 of file SalomeContainerHelper.hxx.

Referenced by getContainer(), isAlreadyStarted(), setContainer(), and shutdown().

◆ _data_mutex

std::mutex YACS::ENGINE::SalomeContainerMultiHelper::_data_mutex

mutableprivate

Definition at line 95 of file SalomeContainerHelper.hxx.

Referenced by getContainer(), isAlreadyStarted(), setContainer(), and shutdown().

◆ DFT_LAUNCH_MODE

const char SalomeContainerMultiHelper::DFT_LAUNCH_MODE ="getorstart"

static

Definition at line 91 of file SalomeContainerHelper.hxx.

Referenced by getDftLaunchMode().

◆ TYPE_NAME

const char SalomeContainerMultiHelper::TYPE_NAME ="multi"

static

Definition at line 90 of file SalomeContainerHelper.hxx.

Referenced by YACS::ENGINE::SalomeContainer::canAcceptImposedResource(), getType(), and YACS::ENGINE::SalomeContainer::setProperty().

The documentation for this class was generated from the following files:

src/runtime/SalomeContainerHelper.hxx
src/runtime/SalomeContainerHelper.cxx

Public Member Functions

Static Public Attributes

Private Member Functions

Private Attributes

Additional Inherited Members

Detailed Description

Constructor & Destructor Documentation

◆ ~SalomeContainerMultiHelper()

Member Function Documentation

◆ deepCpyOnlyStaticInfo()

◆ getContainer()

◆ getDftLaunchMode()

◆ getType()

◆ isAlreadyStarted()

◆ setContainer()

◆ shutdown()

Member Data Documentation

◆ _containersForComponents

◆ _containersForTasks

◆ _data_mutex

◆ DFT_LAUNCH_MODE

◆ TYPE_NAME