#include <SalomeContainerTools.hxx>

Inheritance diagram for YACS::ENGINE::SalomeContainerTools:

Collaboration diagram for YACS::ENGINE::SalomeContainerTools:

[legend]

Public Member Functions
	SalomeContainerTools ()

	SalomeContainerTools (const SalomeContainerTools &other)

	~SalomeContainerTools ()

std::string	getProperty (const std::string &name) const override

void	setProperty (const std::string &name, const std::string &value) override

const std::map< std::string, std::string > &	getProperties () const override

std::map< std::string, std::string >	getResourceProperties (const std::string &name) const override

void	clearProperties () override

void	addToComponentList (const std::string &name) override

void	addToResourceList (const std::string &name) override

Engines::ContainerParameters	getParameters () const override

void	setContainerName (const std::string &name) override

std::string	getHostName () const override

std::string	getNotNullContainerName (const Container contPtr, const Task askingNode, bool &isEmpty) const override

std::string	getContainerName () const override

int	getNumberOfCoresPerWorker () const override

Public Member Functions inherited from YACS::ENGINE::SalomeContainerToolsBase
virtual	~SalomeContainerToolsBase ()

virtual std::string	getProperty (const std::string &name) const =0

virtual void	setProperty (const std::string &name, const std::string &value)=0

virtual const std::map< std::string, std::string > &	getProperties () const =0

virtual std::map< std::string, std::string >	getResourceProperties (const std::string &name) const =0

virtual void	clearProperties ()=0

virtual void	addToComponentList (const std::string &name)=0

virtual void	addToResourceList (const std::string &name)=0

virtual Engines::ContainerParameters	getParameters () const =0

virtual void	setContainerName (const std::string &name)=0

virtual std::string	getHostName () const =0

virtual std::string	getNotNullContainerName (const Container contPtr, const Task askingNode, bool &isEmpty) const =0

virtual std::string	getContainerName () const =0

virtual int	getNumberOfCoresPerWorker () const =0

Private Attributes
std::map< std::string, std::string >	_propertyMap

Engines::ContainerParameters	_params

Additional Inherited Members
Static Public Member Functions inherited from YACS::ENGINE::SalomeContainerToolsBase
static void	SetContainerNameOf (Engines::ContainerParameters &params, const std::string &name)

static void	Start (const std::vector< std::string > &compoNames, SalomeContainerHelper schelp, SalomeContainerToolsBase &sct, int &shutdownLevel, const Container cont, const Task *askingNode)

static CORBA::Object_ptr	LoadComponent (SalomeContainerHelper launchModeType, Container cont, Task *askingNode)

static CORBA::Object_ptr	CreateComponentInstance (Container cont, Engines::Container_ptr contPtr, const ComponentInstance inst)

static std::string	GetPlacementId (const SalomeContainerHelper launchModeType, const Container cont, const Task *askingNode)

static std::string	GetFullPlacementId (const SalomeContainerHelper launchModeType, const Container cont, const Task *askingNode)

Detailed Description

Definition at line 66 of file SalomeContainerTools.hxx.

Constructor & Destructor Documentation

◆ SalomeContainerTools() [1/2]

SalomeContainerTools::SalomeContainerTools ( )

Definition at line 47 of file SalomeContainerTools.cxx.

{
  /* Init ContainerParameters */
  SALOME_LifeCycleCORBA::preSet(_params);
}

References _params.

◆ SalomeContainerTools() [2/2]

SalomeContainerTools::SalomeContainerTools ( const SalomeContainerTools & other )

Definition at line 53 of file SalomeContainerTools.cxx.

                                                                           :_params(other._params),_propertyMap(other._propertyMap)
{
}

◆ ~SalomeContainerTools()

YACS::ENGINE::SalomeContainerTools::~SalomeContainerTools ( )

inline

Definition at line 71 of file SalomeContainerTools.hxx.

71{ }

Member Function Documentation

◆ addToComponentList()

void SalomeContainerTools::addToComponentList ( const std::string & name )

overridevirtual

Implements YACS::ENGINE::SalomeContainerToolsBase.

Definition at line 200 of file SalomeContainerTools.cxx.

{
  // Search if name is already in the list
  for (CORBA::ULong i = 0; i < _params.resource_params.componentList.length(); i++)
    {
      std::string component_name = _params.resource_params.componentList[i].in();
      if (component_name == name)
        return;
    }
  // Add name to list
  CORBA::ULong lgth = _params.resource_params.componentList.length();
  _params.resource_params.componentList.length(lgth + 1);
  _params.resource_params.componentList[lgth] = CORBA::string_dup(name.c_str());
}

References _params, and yacsorb.CORBAEngineTest::i.

Referenced by setProperty().

◆ addToResourceList()

void SalomeContainerTools::addToResourceList ( const std::string & name )

overridevirtual

Implements YACS::ENGINE::SalomeContainerToolsBase.

Definition at line 215 of file SalomeContainerTools.cxx.

{
  // Search if name is already in the list
  for (CORBA::ULong i = 0; i < _params.resource_params.resList.length(); i++)
    {
      std::string component_name = _params.resource_params.resList[i].in();
      if (component_name == name)
        return;
    }
  // Add name to list
  CORBA::ULong lgth = _params.resource_params.resList.length();
  _params.resource_params.resList.length(lgth + 1);
  _params.resource_params.resList[lgth] = CORBA::string_dup(name.c_str());
}

References _params, and yacsorb.CORBAEngineTest::i.

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

◆ clearProperties()

void SalomeContainerTools::clearProperties ( )

overridevirtual

Implements YACS::ENGINE::SalomeContainerToolsBase.

Definition at line 57 of file SalomeContainerTools.cxx.

{
  _propertyMap.clear();
  _params=Engines::ContainerParameters();
}

References _params, and _propertyMap.

Referenced by YACS::ENGINE::SalomeContainer::clearProperties(), and YACS::ENGINE::SalomeHPContainer::clearProperties().

◆ getContainerName()

std::string SalomeContainerTools::getContainerName ( ) const

overridevirtual

Implements YACS::ENGINE::SalomeContainerToolsBase.

Definition at line 230 of file SalomeContainerTools.cxx.

{
  return std::string(_params.container_name);
}

References _params.

◆ getHostName()

std::string SalomeContainerTools::getHostName ( ) const

overridevirtual

Implements YACS::ENGINE::SalomeContainerToolsBase.

Definition at line 267 of file SalomeContainerTools.cxx.

{
  return std::string(_params.resource_params.hostname);
}

References _params.

◆ getNotNullContainerName()

std::string SalomeContainerTools::getNotNullContainerName	(	const Container *	contPtr,
		const Task *	askingNode,
		bool &	isEmpty
	)		const

overridevirtual

Implements YACS::ENGINE::SalomeContainerToolsBase.

Definition at line 245 of file SalomeContainerTools.cxx.

{
  isEmpty=true;
  std::string name(_params.container_name);
  if(!name.empty())
    {
      isEmpty=false;
      return name;
    }
  else
    {
      //give a almost unique name to the container : Pid_Name_Addr
      std::ostringstream stream;
      stream << getpid();
      stream << "_";
      stream << contPtr->getName();
      stream << "_";
      stream << contPtr->getDiscreminantStrOfThis(askingNode);
      return stream.str();
    }
}

References _params, YACS::ENGINE::Container::getDiscreminantStrOfThis(), and YACS::ENGINE::Container::getName().

◆ getNumberOfCoresPerWorker()

int SalomeContainerTools::getNumberOfCoresPerWorker ( ) const

overridevirtual

Implements YACS::ENGINE::SalomeContainerToolsBase.

Definition at line 235 of file SalomeContainerTools.cxx.

{
  return _params.resource_params.nb_proc_per_node;
}

References _params.

Referenced by YACS::ENGINE::SalomeHPContainer::getNumberOfCoresPerWorker().

◆ getParameters()

Engines::ContainerParameters YACS::ENGINE::SalomeContainerTools::getParameters ( ) const

inlineoverridevirtual

Implements YACS::ENGINE::SalomeContainerToolsBase.

Definition at line 79 of file SalomeContainerTools.hxx.

79{ return _params; }

◆ getProperties()

const std::map< std::string, std::string > & YACS::ENGINE::SalomeContainerTools::getProperties ( ) const

inlineoverridevirtual

Implements YACS::ENGINE::SalomeContainerToolsBase.

Definition at line 74 of file SalomeContainerTools.hxx.

74{ return _propertyMap; }

Referenced by YACS::ENGINE::SalomeContainer::getProperties(), and YACS::ENGINE::SalomeHPContainer::getProperties().

◆ getProperty()

std::string SalomeContainerTools::getProperty ( const std::string & name ) const

overridevirtual

Implements YACS::ENGINE::SalomeContainerToolsBase.

Definition at line 63 of file SalomeContainerTools.cxx.

{
  std::map<std::string,std::string>::const_iterator it(_propertyMap.find(name));
  if(it!=_propertyMap.end())
    return (*it).second;
  else
    return std::string();
}

References _propertyMap.

Referenced by YACS::ENGINE::SalomeContainer::getProperty(), and YACS::ENGINE::SalomeHPContainer::getProperty().

◆ getResourceProperties()

std::map< std::string, std::string > SalomeContainerTools::getResourceProperties ( const std::string & name ) const

overridevirtual

Implements YACS::ENGINE::SalomeContainerToolsBase.

Definition at line 277 of file SalomeContainerTools.cxx.

{
  std::map<std::string,std::string> properties;
 
  YACS::ENGINE::RuntimeSALOME* runTime = YACS::ENGINE::getSALOMERuntime();
  CORBA::ORB_ptr orb = runTime->getOrb();
  if (!orb) return properties;
  SALOME_NamingService_Wrapper namingService(orb);
  SALOME_LifeCycleCORBA lcc(&namingService);
  CORBA::Object_var obj = namingService.Resolve(SALOME_ResourcesManager::_ResourcesManagerNameInNS);
  if (CORBA::is_nil(obj))
    return properties;
  Engines::ResourcesManager_var resManager = Engines::ResourcesManager::_narrow(obj);
  if (CORBA::is_nil(resManager))
    return properties;
 
  std::ostringstream value;
  Engines::ResourceDefinition_var resource_definition = resManager->GetResourceDefinition(name.c_str());
  properties["hostname"]=resource_definition->hostname.in();
  properties["OS"]=resource_definition->OS.in();
  value.str(""); value << resource_definition->mem_mb;
  properties["mem_mb"]=value.str();
  value.str(""); value << resource_definition->cpu_clock;
  properties["cpu_clock"]=value.str();
  value.str(""); value << resource_definition->nb_node;
  properties["nb_node"]=value.str();
  value.str(""); value << resource_definition->nb_proc_per_node;
  properties["nb_proc_per_node"]=value.str();
  /*
  properties["component_list"]="";
  for(CORBA::ULong i=0; i < resource_definition->componentList.length(); i++)
    {
      if(i > 0)
        properties["component_list"]=properties["component_list"]+",";
      properties["component_list"]=properties["component_list"]+resource_definition->componentList[i].in();
    }
    */
  return properties;
}

References YACS::ENGINE::RuntimeSALOME::getOrb(), YACS::ENGINE::getSALOMERuntime(), orb, and SALOME_NamingService_Wrapper::Resolve().

Referenced by YACS::ENGINE::SalomeContainer::getResourceProperties(), and YACS::ENGINE::SalomeHPContainer::getResourceProperties().

◆ setContainerName()

void SalomeContainerTools::setContainerName ( const std::string & name )

overridevirtual

Implements YACS::ENGINE::SalomeContainerToolsBase.

Definition at line 240 of file SalomeContainerTools.cxx.

{
  SetContainerNameOf(_params,name);
}

References _params, and YACS::ENGINE::SalomeContainerToolsBase::SetContainerNameOf().

◆ setProperty()

void SalomeContainerTools::setProperty	(	const std::string &	name,
		const std::string &	value
	)

overridevirtual

Implements YACS::ENGINE::SalomeContainerToolsBase.

Definition at line 72 of file SalomeContainerTools.cxx.

{
  //DEBUG_YACSTRACE("SalomeContainer::setProperty : " << name << " ; " << value);
  // Container Part
  if (name == "container_name")
    _params.container_name = CORBA::string_dup(value.c_str());
  else if (name == "workingdir")
    _params.workingdir = CORBA::string_dup(value.c_str());
  else if (name == "nb_parallel_procs")
  {
    std::istringstream iss(value);
    if (!(iss >> _params.nb_proc))
      throw Exception("salomecontainer::setproperty : params.nb_proc value not correct : " + value);
  }
  else if (name == "isMPI")
  {
    if (value == "true")
      _params.isMPI = true;
    else if (value == "false")
      _params.isMPI = false;
    else 
      throw Exception("SalomeContainer::setProperty : params.isMPI value not correct : " + value);
  }
  else if (name == "parallelLib")
    _params.parallelLib = CORBA::string_dup(value.c_str());
 
  // Resource part
  else if (name == "name")
    _params.resource_params.name = CORBA::string_dup(value.c_str());
  else if (name == "hostname")
    _params.resource_params.hostname = CORBA::string_dup(value.c_str());
  else if (name == "OS")
    _params.resource_params.OS = CORBA::string_dup(value.c_str());
  else if (name == "nb_resource_procs")
  {
    std::istringstream iss(value);
    if (!(iss >> _params.resource_params.nb_proc))
      throw Exception("salomecontainer::setproperty : params.resource_params.nb_proc value not correct : " + value);
  }
  else if (name == "mem_mb")
  {
    std::istringstream iss(value);
    if (!(iss >> _params.resource_params.mem_mb))
      throw Exception("salomecontainer::setproperty : params.resource_params.mem_mb value not correct : " + value);
  }
  else if (name == "cpu_clock")
  {
    std::istringstream iss(value);
    if (!(iss >> _params.resource_params.cpu_clock))
      throw Exception("salomecontainer::setproperty : params.resource_params.cpu_clock value not correct : " + value);
  }
  else if (name == "nb_node")
  {
    std::istringstream iss(value);
    if (!(iss >> _params.resource_params.nb_node))
      throw Exception("salomecontainer::setproperty : params.nb_node value not correct : " + value);
  }
  else if (name == "nb_proc_per_node")
  {
    std::istringstream iss(value);
    if (!(iss >> _params.resource_params.nb_proc_per_node))
      throw Exception("salomecontainer::setproperty : params.nb_proc_per_node value not correct : " + value);
  }
  else if (name == "policy")
    _params.resource_params.policy = CORBA::string_dup(value.c_str());
  else if (name == "component_list")
  {
    std::string clean_value(value);
 
    // Step 1: remove blanks
    while(clean_value.find(" ") != std::string::npos)
      clean_value = clean_value.erase(clean_value.find(" "), 1);
 
    // Step 2: get values
    while(!clean_value.empty())
    {
      std::string result("");
      std::string::size_type loc = clean_value.find(",", 0);
      if (loc != std::string::npos)
      {
        result = clean_value.substr(0, loc);
        clean_value = clean_value.erase(0, loc+1);
      }
      else
      {
        result = clean_value;
        clean_value.erase();
      }
      if (result != "," && result != "")
      {
        addToComponentList(result);
      }
    }
 
  }
  else if (name == "resource_list")
  {
    std::string clean_value(value);
 
    // Step 1: remove blanks
    while(clean_value.find(" ") != std::string::npos)
      clean_value = clean_value.erase(clean_value.find(" "), 1);
 
    // Step 2: get values
    while(!clean_value.empty())
    {
      std::string result("");
      std::string::size_type loc = clean_value.find(",", 0);
      if (loc != std::string::npos)
      {
        result = clean_value.substr(0, loc);
        clean_value = clean_value.erase(0, loc+1);
      }
      else
      {
        result = clean_value;
        clean_value.erase();
      }
      if (result != "," && result != "")
      {
        addToResourceList(result);
      }
    }
 
  }
  _propertyMap[name]=value;
}

References _params, _propertyMap, addToComponentList(), and addToResourceList().

Referenced by YACS::ENGINE::SalomeContainer::setProperty(), YACS::ENGINE::SalomeHPContainer::setProperty(), and YACS::ENGINE::SalomeContainer::start().

Member Data Documentation

◆ _params

Engines::ContainerParameters YACS::ENGINE::SalomeContainerTools::_params

private

Definition at line 87 of file SalomeContainerTools.hxx.

Referenced by addToComponentList(), addToResourceList(), clearProperties(), getContainerName(), getHostName(), getNotNullContainerName(), getNumberOfCoresPerWorker(), SalomeContainerTools(), setContainerName(), and setProperty().

◆ _propertyMap

std::map<std::string,std::string> YACS::ENGINE::SalomeContainerTools::_propertyMap

private

Definition at line 86 of file SalomeContainerTools.hxx.

Referenced by clearProperties(), getProperty(), and setProperty().

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

src/runtime/SalomeContainerTools.hxx
src/runtime/SalomeContainerTools.cxx

Public Member Functions

Private Attributes

Additional Inherited Members

Detailed Description

Constructor & Destructor Documentation

◆ SalomeContainerTools() [1/2]

◆ SalomeContainerTools() [2/2]

◆ ~SalomeContainerTools()

Member Function Documentation

◆ addToComponentList()

◆ addToResourceList()

◆ clearProperties()

◆ getContainerName()

◆ getHostName()

◆ getNotNullContainerName()

◆ getNumberOfCoresPerWorker()

◆ getParameters()

◆ getProperties()

◆ getProperty()

◆ getResourceProperties()

◆ setContainerName()

◆ setProperty()

Member Data Documentation

◆ _params

◆ _propertyMap