DUNE::Tasks::Manager Class Reference

Public Member Functions
	Manager (Context &ctx)
	~Manager (void)
void	start (void)
void	start (const std::string &name)
void	stop (const std::string &name)
void	join (const std::string &name)
void	writeParamsXML (std::ostream &os) const
std::map< std::string, Task * >::iterator	begin (void)
std::map< std::string, Task * >::iterator	end (void)
Task *	getTaskByName (const std::string &name)
void	measureCpuUsage (void)
void	adjustPriorities (void)

Static Public Member Functions
static std::string	getTaskName (const std::string &str)

Constructor & Destructor Documentation

Manager()

DUNE::Tasks::Manager::Manager

(

Context &

ctx

)

Constructor.

Parameters

ctx	task context.

References DUNE::Tasks::Context::config, DUNE::Tasks::Task::err(), DUNE::Tasks::Factory::exists(), DUNE::Parsers::Config::get(), getTaskName(), DUNE::Tasks::Profiles::isSelected(), DUNE::Tasks::Task::loadConfig(), DUNE::Tasks::Factory::produce(), DUNE::Tasks::Context::profiles, DUNE::Tasks::Task::reserveEntities(), and DUNE::Parsers::Config::sections().

~Manager()

DUNE::Tasks::Manager::~Manager

(

void

)

Destructor.

References join(), and stop().

Member Function Documentation

adjustPriorities()

void DUNE::Tasks::Manager::adjustPriorities

(

void

)

References DUNE::Tasks::Task::getPriority(), DUNE::Concurrency::Scheduler::minimumPriority(), DUNE::Tasks::Task::setPriority(), and DUNE::Tasks::Task::war().

Referenced by getTaskByName(), and DUNE::Daemon::writeParamsXML().

begin()

std::map<std::string, Task*>::iterator DUNE::Tasks::Manager::begin ( void  )

inline

end()

std::map<std::string, Task*>::iterator DUNE::Tasks::Manager::end ( void  )

inline

getTaskByName()

Task* DUNE::Tasks::Manager::getTaskByName ( const std::string &  name )

inline

References adjustPriorities(), and measureCpuUsage().

getTaskName()

std::string DUNE::Tasks::Manager::getTaskName ( const std::string &  str )

static

Retrieve the task name from a configuration section.

Parameters

str	configuration section string.

Returns

task name.

References DUNE::Utils::String::split().

Referenced by Manager().

join()

void DUNE::Tasks::Manager::join

(

const std::string &

name

)

Referenced by ~Manager().

measureCpuUsage()

void DUNE::Tasks::Manager::measureCpuUsage

(

void

)

References DUNE::Tasks::Task::dispatch(), DUNE::Tasks::Task::getEntityId(), DUNE::Concurrency::Thread::getProcessorUsage(), DUNE::IMC::Message::setSourceEntity(), and DUNE::IMC::CpuUsage::value.

Referenced by getTaskByName(), and DUNE::Daemon::writeParamsXML().

start() [1/2]

void DUNE::Tasks::Manager::start

(

void

)

Start all tasks.

Referenced by DUNE::Daemon::onResourceInitialization().

start() [2/2]

void DUNE::Tasks::Manager::start

(

const std::string &

name

)

Start a task with a given name.

Parameters

name	task name.

References DUNE::Tasks::Task::err(), DUNE::Tasks::Task::inf(), and DUNE::Concurrency::Runnable::start().

stop()

void DUNE::Tasks::Manager::stop

(

const std::string &

name

)

Stop a task with a given name.

Parameters

name	task name.

Returns

true if task was stopped, false otherwise.

Referenced by ~Manager().

writeParamsXML()

void DUNE::Tasks::Manager::writeParamsXML

(

std::ostream &

os

)

const

Referenced by DUNE::Daemon::writeParamsXML().

Collaboration diagram for DUNE::Tasks::Manager: