Realm::LocalTaskProcessor Class Reference

#include <proc_impl.h>

Inheritance diagram for Realm::LocalTaskProcessor:

Collaboration diagram for Realm::LocalTaskProcessor:

Classes
struct	TaskTableEntry

Public Member Functions
	LocalTaskProcessor (RuntimeImpl *runtime_impl, Processor _me, Processor::Kind _kind, int num_cores=1)
virtual	~LocalTaskProcessor (void)
virtual void	enqueue_task (Task *task)
virtual void	enqueue_tasks (Task::TaskList &tasks, size_t num_tasks)
virtual void	spawn_task (Processor::TaskFuncID func_id, const void *args, size_t arglen, const ProfilingRequestSet &reqs, Event start_event, GenEventImpl *finish_event, EventImpl::gen_t finish_gen, int priority)
virtual bool	register_task (Processor::TaskFuncID func_id, CodeDescriptor &codedesc, const ByteArrayRef &user_data)
virtual void	start_threads (void)
virtual void	shutdown (void)
virtual void	add_to_group (ProcessorGroupImpl *group)
virtual void	remove_from_group (ProcessorGroupImpl *group)
virtual void	add_internal_task (InternalTask *task)
Public Member Functions inherited from Realm::ProcessorImpl
	ProcessorImpl (RuntimeImpl *runtime_impl, Processor _me, Processor::Kind _kind, int _num_cores=1)
virtual	~ProcessorImpl (void)
GenEventImpl *	create_genevent ()
void	free_genevent (GenEventImpl *)

Protected Member Functions
void	set_scheduler (ThreadedTaskScheduler *_sched)
virtual void	execute_task (Processor::TaskFuncID func_id, const ByteArrayRef &task_args)
Protected Member Functions inherited from Realm::ProcessorImpl
void	enqueue_or_defer_task (Task *task, Event start_event, DeferredSpawnCache *cache)

Protected Attributes
ThreadedTaskScheduler *	sched
TaskQueue	task_queue
ProfilingGauges::AbsoluteRangeGauge< int >	ready_task_count
DeferredSpawnCache	deferred_spawn_cache
RWLock	task_table_mutex
std::map< Processor::TaskFuncID, TaskTableEntry >	task_table
Protected Attributes inherited from Realm::ProcessorImpl
LocalEventTableAllocator::FreeList	free_local_events

Additional Inherited Members
Static Public Member Functions inherited from Realm::ProcessorImpl
static Processor::Kind	get_processor_kind (RuntimeImpl *runtime_impl, Processor processor)
Public Attributes inherited from Realm::ProcessorImpl
Processor	me
Processor::Kind	kind
int	num_cores

Constructor & Destructor Documentation

LocalTaskProcessor()

Realm::LocalTaskProcessor::LocalTaskProcessor	(	RuntimeImpl *	runtime_impl,
		Processor	_me,
		Processor::Kind	_kind,
		int	num_cores = 1
	)

~LocalTaskProcessor()

virtual Realm::LocalTaskProcessor::~LocalTaskProcessor ( void  )

virtual

Member Function Documentation

add_internal_task()

virtual void Realm::LocalTaskProcessor::add_internal_task ( InternalTask *  task )

virtual

Reimplemented from Realm::ProcessorImpl.

add_to_group()

virtual void Realm::LocalTaskProcessor::add_to_group ( ProcessorGroupImpl *  group )

virtual

Implements Realm::ProcessorImpl.

enqueue_task()

virtual void Realm::LocalTaskProcessor::enqueue_task ( Task *  task )

virtual

Implements Realm::ProcessorImpl.

enqueue_tasks()

virtual void Realm::LocalTaskProcessor::enqueue_tasks ( Task::TaskList &  tasks, size_t  num_tasks  )

virtual

Implements Realm::ProcessorImpl.

execute_task()

virtual void Realm::LocalTaskProcessor::execute_task ( Processor::TaskFuncID  func_id, const ByteArrayRef &  task_args  )

protectedvirtual

Reimplemented from Realm::ProcessorImpl.

Reimplemented in Realm::Cuda::GPUProcessor, and Realm::Hip::GPUProcessor.

register_task()

virtual bool Realm::LocalTaskProcessor::register_task ( Processor::TaskFuncID  func_id, CodeDescriptor &  codedesc, const ByteArrayRef &  user_data  )

virtual

Reimplemented from Realm::ProcessorImpl.

Reimplemented in Realm::Cuda::GPUProcessor, and Realm::Hip::GPUProcessor.

remove_from_group()

virtual void Realm::LocalTaskProcessor::remove_from_group ( ProcessorGroupImpl *  group )

virtual

Implements Realm::ProcessorImpl.

set_scheduler()

void Realm::LocalTaskProcessor::set_scheduler ( ThreadedTaskScheduler *  _sched )

protected

shutdown()

virtual void Realm::LocalTaskProcessor::shutdown ( void  )

virtual

Reimplemented from Realm::ProcessorImpl.

Reimplemented in Realm::Cuda::GPUProcessor, Realm::Hip::GPUProcessor, and Realm::LocalOpenMPProcessor.

spawn_task()

virtual void Realm::LocalTaskProcessor::spawn_task ( Processor::TaskFuncID  func_id, const void *  args, size_t  arglen, const ProfilingRequestSet &  reqs, Event  start_event, GenEventImpl *  finish_event, EventImpl::gen_t  finish_gen, int  priority  )

virtual

Implements Realm::ProcessorImpl.

start_threads()

virtual void Realm::LocalTaskProcessor::start_threads ( void  )

virtual

Reimplemented from Realm::ProcessorImpl.

Member Data Documentation

deferred_spawn_cache

DeferredSpawnCache Realm::LocalTaskProcessor::deferred_spawn_cache

protected

ready_task_count

ProfilingGauges::AbsoluteRangeGauge<int> Realm::LocalTaskProcessor::ready_task_count

protected

sched

ThreadedTaskScheduler* Realm::LocalTaskProcessor::sched

protected

task_queue

TaskQueue Realm::LocalTaskProcessor::task_queue

protected

task_table

std::map<Processor::TaskFuncID, TaskTableEntry> Realm::LocalTaskProcessor::task_table

protected

task_table_mutex

RWLock Realm::LocalTaskProcessor::task_table_mutex

protected

---

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

• /home/runner/work/realm/realm/realm-src/src/realm/proc_impl.h