YACS::ENGINE::WlmTask Class Reference

#include <WlmTask.hxx>

Inheritance diagram for YACS::ENGINE::WlmTask:

Collaboration diagram for YACS::ENGINE::WlmTask:

Public Member Functions
	WlmTask (Executor &executor, YACS::ENGINE::Task *yacsTask)
const WorkloadManager::ContainerType &	type () const override
void	run (const WorkloadManager::RunInfo &runInfo) override
bool	isAccepted (const WorkloadManager::Resource &r) override

Static Public Member Functions
static void	loadResources (WorkloadManager::WorkloadManager &wm)

Private Attributes
WorkloadManager::ContainerType	_type
Executor &	_executor
YACS::ENGINE::Task *	_yacsTask

Detailed Description

Definition at line 29 of file WlmTask.hxx.

Constructor & Destructor Documentation

WlmTask()

YACS::ENGINE::WlmTask::WlmTask	(	Executor &	executor,
		YACS::ENGINE::Task *	yacsTask
	)

Definition at line 28 of file WlmTask.cxx.

: _type()
, _executor(executor)
, _yacsTask(yacsTask)
{
  Container * yacsContainer = yacsTask->getContainer();
  if(yacsContainer != nullptr && yacsTask->canAcceptImposedResource())
  {
    _type.ignoreResources = false;
    _type.name = yacsContainer->getName();
    std::string nb_procs_str = yacsContainer->getProperty("nb_parallel_procs");
    float needed_cores = 0.0;
    if(!nb_procs_str.empty())
      needed_cores = std::stof(nb_procs_str);
    _type.neededCores = needed_cores;
  }
  else
  {
    _type.ignoreResources = true;
    _type.name = "test";
    _type.neededCores = 0;
  }
  _type.id = 0;
}

References _type, YACS::ENGINE::Task::canAcceptImposedResource(), YACS::ENGINE::Task::getContainer(), YACS::ENGINE::Container::getName(), and YACS::ENGINE::Container::getProperty().

Member Function Documentation

isAccepted()

bool YACS::ENGINE::WlmTask::isAccepted ( const WorkloadManager::Resource &  r )

override

Definition at line 74 of file WlmTask.cxx.

{
  Container * yacsContainer = _yacsTask->getContainer();
  std::string hostname = yacsContainer->getProperty("hostname");
  bool accept = true;
  if(!hostname.empty())
    accept = (hostname == r.name);
  return accept;
}

References _yacsTask, YACS::ENGINE::Task::getContainer(), YACS::ENGINE::Container::getProperty(), and testCppPluginInvokation::r.

loadResources()

void YACS::ENGINE::WlmTask::loadResources ( WorkloadManager::WorkloadManager &  wm )

static

Definition at line 84 of file WlmTask.cxx.

{
  Runtime *r(getRuntime());
  if(!r)
    throw YACS::Exception("loadResources : no runtime  !");
  std::vector< std::pair<std::string,int> > data(r->getCatalogOfComputeNodes());
  int id = 0;
  for(const std::pair<std::string,int>& res : data)
  {
    WorkloadManager::Resource newResource;
    newResource.name = res.first;
    newResource.id = id;
    id++;
    newResource.nbCores = res.second;
    wm.addResource(newResource);
  }
  wm.freezeResources();
}

References YACS::ENGINE::getRuntime(), and testCppPluginInvokation::r.

Referenced by YACS::ENGINE::Executor::runWlm().

run()

void YACS::ENGINE::WlmTask::run ( const WorkloadManager::RunInfo &  runInfo )

override

Definition at line 58 of file WlmTask.cxx.

{
  if(runInfo.isOk)
  {
    _executor.loadTask(_yacsTask, runInfo);
    _executor.makeDatastreamConnections(_yacsTask);
    YACS::Event ev = _executor.runTask(_yacsTask);
    _executor.endTask(_yacsTask, ev);
  }
  else
  {
    _executor.failTask(_yacsTask, runInfo.error_message);
  }
  delete this; // provisoire
}

References _executor, _yacsTask, YACS::ENGINE::Executor::endTask(), YACS::ENGINE::Executor::failTask(), YACS::ENGINE::Executor::loadTask(), YACS::ENGINE::Executor::makeDatastreamConnections(), and YACS::ENGINE::Executor::runTask().

type()

const WorkloadManager::ContainerType & YACS::ENGINE::WlmTask::type ( ) const

override

Definition at line 53 of file WlmTask.cxx.

{
  return _type;
}

References _type.

Member Data Documentation

_executor

Executor& YACS::ENGINE::WlmTask::_executor

private

Definition at line 40 of file WlmTask.hxx.

Referenced by run().

_type

WorkloadManager::ContainerType YACS::ENGINE::WlmTask::_type

private

Definition at line 39 of file WlmTask.hxx.

Referenced by type(), and WlmTask().

_yacsTask

YACS::ENGINE::Task* YACS::ENGINE::WlmTask::_yacsTask

private

Definition at line 41 of file WlmTask.hxx.

Referenced by isAccepted(), and run().

---

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

• src/engine/WlmTask.hxx
• src/engine/WlmTask.cxx