#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 ()

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