DPsim::Scheduler Class Reference

#include <Scheduler.h>

Inheritance diagram for DPsim::Scheduler:

Collaboration diagram for DPsim::Scheduler:

Classes
class	Root

Public Types
typedef std::unordered_map< CPS::Task::Ptr, std::deque< CPS::Task::Ptr > >	Edges
typedef std::chrono::steady_clock::duration	TaskTime
	Time measurement for the task execution.

Public Member Functions
	Scheduler (CPS::Logger::Level logLevel=CPS::Logger::Level::off)
virtual	~Scheduler ()
virtual void	createSchedule (const CPS::Task::List &tasks, const Edges &inEdges, const Edges &outEdges)=0
	Creates the schedule for the given dependency graph.
virtual void	step (Real time, Int timeStepCount)=0
	Performs a single simulation step.
virtual void	stop ()
	Called on simulation stop to reliably clean up e.g. running helper threads.
void	resolveDeps (CPS::Task::List &tasks, Edges &inEdges, Edges &outEdges)
TaskTime	getAveragedMeasurement (CPS::Task::Ptr task)

Static Public Attributes
static CPS::AttributeBase::Ptr	external

Protected Member Functions
void	topologicalSort (const CPS::Task::List &tasks, const Edges &inEdges, const Edges &outEdges, CPS::Task::List &sortedTasks)
	Simple topological sort, filtering out tasks that do not need to be executed.
void	initMeasurements (const CPS::Task::List &tasks)
void	updateMeasurement (CPS::Task *task, TaskTime time)
void	writeMeasurements (CPS::String filename)
	Write measurement data to file.
void	readMeasurements (CPS::String filename, std::unordered_map< CPS::String, TaskTime::rep > &measurements)
	Read measurement data from file to use it for the scheduling.
TaskTime	getAveragedMeasurement (CPS::Task *task)

Static Protected Member Functions
static void	levelSchedule (const CPS::Task::List &tasks, const Edges &inEdges, const Edges &outEdges, std::vector< CPS::Task::List > &levels)

Protected Attributes
CPS::Task::Ptr	mRoot
CPS::Logger::Level	mLogLevel
	Log level.
CPS::Logger::Log	mSLog
	Logger.

Detailed Description

Definition at line 27 of file Scheduler.h.

Member Typedef Documentation

Edges

typedef std::unordered_map<CPS::Task::Ptr, std::deque<CPS::Task::Ptr> > DPsim::Scheduler::Edges

Edges describe the dependency from the first task to a list of other tasks or the other way around.

Definition at line 31 of file Scheduler.h.

TaskTime

typedef std::chrono::steady_clock::duration DPsim::Scheduler::TaskTime

Time measurement for the task execution.

Definition at line 33 of file Scheduler.h.

Constructor & Destructor Documentation

Scheduler()

DPsim::Scheduler::Scheduler ( CPS::Logger::Level logLevel = CPS::Logger::Level::off )

inline

Definition at line 36 of file Scheduler.h.

~Scheduler()

virtual DPsim::Scheduler::~Scheduler ( )

inlinevirtual

Definition at line 43 of file Scheduler.h.

Member Function Documentation

createSchedule()

virtual void DPsim::Scheduler::createSchedule ( const CPS::Task::List & tasks, const Edges & inEdges, const Edges & outEdges )

pure virtual

Creates the schedule for the given dependency graph.

Implemented in DPsim::OpenMPLevelScheduler, DPsim::SequentialScheduler, DPsim::ThreadLevelScheduler, and DPsim::ThreadListScheduler.

getAveragedMeasurement() [1/2]

Scheduler::TaskTime Scheduler::getAveragedMeasurement ( CPS::Task * task )

protected

Definition at line 65 of file Scheduler.cpp.

getAveragedMeasurement() [2/2]

TaskTime DPsim::Scheduler::getAveragedMeasurement ( CPS::Task::Ptr task )

inline

Definition at line 65 of file Scheduler.h.

initMeasurements()

void Scheduler::initMeasurements ( const CPS::Task::List & tasks )

protected

Definition at line 21 of file Scheduler.cpp.

levelSchedule()

void Scheduler::levelSchedule ( const CPS::Task::List & tasks, const Edges & inEdges, const Edges & outEdges, std::vector< CPS::Task::List > & levels )

staticprotected

Separate topologically sorted list of tasks into levels which can be executed in parallel

Definition at line 190 of file Scheduler.cpp.

readMeasurements()

void Scheduler::readMeasurements ( CPS::String filename, std::unordered_map< CPS::String, TaskTime::rep > & measurements )

protected

Read measurement data from file to use it for the scheduling.

Definition at line 45 of file Scheduler.cpp.

resolveDeps()

void Scheduler::resolveDeps	(	CPS::Task::List &	tasks,
		Edges &	inEdges,
		Edges &	outEdges )

Helper function that resolves the task-attribute dependencies to task-task dependencies and inserts a root task

CHECK: Having external be the nullptr can lead to segfaults rather quickly. Maybe make it a special kind of attribute

Definition at line 78 of file Scheduler.cpp.

step()

virtual void DPsim::Scheduler::step ( Real time, Int timeStepCount )

pure virtual

Performs a single simulation step.

Implemented in DPsim::OpenMPLevelScheduler, DPsim::SequentialScheduler, and DPsim::ThreadScheduler.

stop()

virtual void DPsim::Scheduler::stop ( )

inlinevirtual

Called on simulation stop to reliably clean up e.g. running helper threads.

Reimplemented in DPsim::OpenMPLevelScheduler, DPsim::SequentialScheduler, and DPsim::ThreadScheduler.

Definition at line 53 of file Scheduler.h.

topologicalSort()

void Scheduler::topologicalSort ( const CPS::Task::List & tasks, const Edges & inEdges, const Edges & outEdges, CPS::Task::List & sortedTasks )

protected

Simple topological sort, filtering out tasks that do not need to be executed.

Definition at line 120 of file Scheduler.cpp.

updateMeasurement()

void Scheduler::updateMeasurement ( CPS::Task * task, TaskTime time )

protected

Not thread-safe for multiple calls with same task, but should only be called once for each task in each step anyway

Definition at line 28 of file Scheduler.cpp.

writeMeasurements()

void Scheduler::writeMeasurements ( CPS::String filename )

protected

Write measurement data to file.

Definition at line 32 of file Scheduler.cpp.

Member Data Documentation

external

CPS::AttributeBase::Ptr Scheduler::external

static

Definition at line 63 of file Scheduler.h.

mLogLevel

CPS::Logger::Level DPsim::Scheduler::mLogLevel

protected

Log level.

Definition at line 104 of file Scheduler.h.

mRoot

CPS::Task::Ptr DPsim::Scheduler::mRoot

protected

Definition at line 102 of file Scheduler.h.

mSLog

CPS::Logger::Log DPsim::Scheduler::mSLog

protected

Logger.

Definition at line 106 of file Scheduler.h.

---

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

• /__w/dpsim/dpsim/dpsim/include/dpsim/Scheduler.h
• /__w/dpsim/dpsim/dpsim/src/Scheduler.cpp