Loading...
Searching...
No Matches
starpu_scheduler.h
Go to the documentation of this file.
/* StarPU --- Runtime system for heterogeneous multicore architectures.
*
* Copyright (C) 2009-2025 University of Bordeaux, CNRS (LaBRI UMR 5800), Inria
* Copyright (C) 2016-2016 Uppsala University
* Copyright (C) 2013-2013 Thibaut Lambert
* Copyright (C) 2011-2011 Télécom Sud Paris
*
* StarPU is free software; you can redistribute it and/or modify
* it under the terms of the GNU Lesser General Public License as published by
* the Free Software Foundation; either version 2.1 of the License, or (at
* your option) any later version.
*
* StarPU is distributed in the hope that it will be useful, but
* WITHOUT ANY WARRANTY; without even the implied warranty of
* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.
*
* See the GNU Lesser General Public License in COPYING.LGPL for more details.
*/
#include <starpu.h>
#ifndef __STARPU_SCHEDULER_H__
#define __STARPU_SCHEDULER_H__
#ifdef __cplusplus
extern "C" {
#endif
struct starpu_task;
struct starpu_sched_policy
{
void (*init_sched)(unsigned sched_ctx_id);
void (*deinit_sched)(unsigned sched_ctx_id);
int (*push_task)(struct starpu_task *);
double (*simulate_push_task)(struct starpu_task *);
void (*push_task_notify)(struct starpu_task *, int workerid, int perf_workerid, unsigned sched_ctx_id);
struct starpu_task *(*pop_task)(unsigned sched_ctx_id);
void (*submit_hook)(struct starpu_task *task);
void (*pre_exec_hook)(struct starpu_task *, unsigned sched_ctx_id);
void (*post_exec_hook)(struct starpu_task *, unsigned sched_ctx_id);
void (*do_schedule)(unsigned sched_ctx_id);
void (*add_workers)(unsigned sched_ctx_id, int *workerids, unsigned nworkers);
void (*remove_workers)(unsigned sched_ctx_id, int *workerids, unsigned nworkers);
int prefetches;
const char *policy_name;
const char *policy_description;
enum starpu_worker_collection_type worker_type;
};
struct starpu_sched_policy **starpu_sched_get_predefined_policies(void);
struct starpu_sched_policy *starpu_get_sched_lib_policy(const char *name);
struct starpu_sched_policy **starpu_get_sched_lib_policies(void);
struct starpu_sched_policy *starpu_sched_get_sched_policy_in_ctx(unsigned sched_ctx_id);
struct starpu_sched_policy *starpu_sched_get_sched_policy(void);
void starpu_worker_get_sched_condition(int workerid, starpu_pthread_mutex_t **sched_mutex, starpu_pthread_cond_t **sched_cond);
unsigned long starpu_task_get_job_id(struct starpu_task *task);
int starpu_sched_get_min_priority(void);
int starpu_sched_get_max_priority(void);
int starpu_sched_set_min_priority(int min_prio);
int starpu_sched_set_max_priority(int max_prio);
int starpu_worker_can_execute_task(unsigned workerid, struct starpu_task *task, unsigned nimpl);
int starpu_worker_can_execute_task_impl(unsigned workerid, struct starpu_task *task, unsigned *impl_mask);
int starpu_worker_can_execute_task_first_impl(unsigned workerid, struct starpu_task *task, unsigned *nimpl);
int starpu_push_local_task(int workerid, struct starpu_task *task, int back);
int starpu_push_task_end(struct starpu_task *task);
int starpu_get_prefetch_flag(void);
int starpu_prefetch_task_input_on_node_prio(struct starpu_task *task, unsigned node, int prio);
int starpu_prefetch_task_input_on_node(struct starpu_task *task, unsigned node);
int starpu_idle_prefetch_task_input_on_node_prio(struct starpu_task *task, unsigned node, int prio);
int starpu_idle_prefetch_task_input_on_node(struct starpu_task *task, unsigned node);
int starpu_prefetch_task_input_for_prio(struct starpu_task *task, unsigned worker, int prio);
int starpu_prefetch_task_input_for(struct starpu_task *task, unsigned worker);
int starpu_idle_prefetch_task_input_for_prio(struct starpu_task *task, unsigned worker, int prio);
int starpu_idle_prefetch_task_input_for(struct starpu_task *task, unsigned worker);
uint32_t starpu_task_footprint(struct starpu_perfmodel *model, struct starpu_task *task, struct starpu_perfmodel_arch *arch, unsigned nimpl);
uint32_t starpu_task_data_footprint(struct starpu_task *task);
double starpu_task_expected_length(struct starpu_task *task, struct starpu_perfmodel_arch *arch, unsigned nimpl);
double starpu_task_worker_expected_length(struct starpu_task *task, unsigned workerid, unsigned sched_ctx_id, unsigned nimpl);
double starpu_task_expected_length_average(struct starpu_task *task, unsigned sched_ctx_id);
double starpu_worker_get_relative_speedup(struct starpu_perfmodel_arch *perf_arch);
double starpu_task_expected_data_transfer_time(unsigned memory_node, struct starpu_task *task);
double starpu_task_expected_data_transfer_time_for(struct starpu_task *task, unsigned worker);
double starpu_data_expected_transfer_time(starpu_data_handle_t handle, unsigned memory_node, enum starpu_data_access_mode mode);
double starpu_task_expected_energy(struct starpu_task *task, struct starpu_perfmodel_arch *arch, unsigned nimpl);
double starpu_task_worker_expected_energy(struct starpu_task *task, unsigned workerid, unsigned sched_ctx_id, unsigned nimpl);
double starpu_task_expected_energy_average(struct starpu_task *task, unsigned sched_ctx_id);
double starpu_task_expected_conversion_time(struct starpu_task *task, struct starpu_perfmodel_arch *arch, unsigned nimpl);
typedef void (*starpu_notify_ready_soon_func)(void *data, struct starpu_task *task, double delay);
void starpu_task_notify_ready_soon_register(starpu_notify_ready_soon_func f, void *data);
void starpu_sched_ctx_worker_shares_tasks_lists(int workerid, int sched_ctx_id);
void starpu_sched_task_break(struct starpu_task *task);
int starpu_wake_worker_relax(int workerid);
int starpu_wake_worker_no_relax(int workerid);
int starpu_wake_worker_locked(int workerid);
int starpu_wake_worker_relax_light(int workerid);
#ifdef __cplusplus
}
#endif
#endif /* __STARPU_SCHEDULER_H__ */
starpu_task::workerid
unsigned workerid
Definition starpu_task.h:1228
starpu_task
Definition starpu_task.h:689
starpu_data_access_mode
starpu_data_access_mode
Definition starpu_data.h:56
starpu_data_handle_t
struct _starpu_data_state * starpu_data_handle_t
Definition starpu_data.h:45
starpu_perfmodel
Definition starpu_perfmodel.h:193
starpu_perfmodel_arch
Definition starpu_perfmodel.h:52
starpu_sched_policy::prefetches
int prefetches
Definition starpu_scheduler.h:182
starpu_sched_policy::push_task_notify
void(* push_task_notify)(struct starpu_task *, int workerid, int perf_workerid, unsigned sched_ctx_id)
Definition starpu_scheduler.h:117
starpu_sched_policy::submit_hook
void(* submit_hook)(struct starpu_task *task)
Definition starpu_scheduler.h:145
starpu_sched_policy::policy_description
const char * policy_description
Definition starpu_scheduler.h:192
starpu_sched_policy::add_workers
void(* add_workers)(unsigned sched_ctx_id, int *workerids, unsigned nworkers)
Definition starpu_scheduler.h:171
starpu_sched_policy::deinit_sched
void(* deinit_sched)(unsigned sched_ctx_id)
Definition starpu_scheduler.h:91
starpu_sched_policy::push_task
int(* push_task)(struct starpu_task *)
Definition starpu_scheduler.h:101
starpu_sched_policy::pre_exec_hook
void(* pre_exec_hook)(struct starpu_task *, unsigned sched_ctx_id)
Definition starpu_scheduler.h:151
starpu_sched_policy::policy_name
const char * policy_name
Definition starpu_scheduler.h:187
starpu_sched_policy::remove_workers
void(* remove_workers)(unsigned sched_ctx_id, int *workerids, unsigned nworkers)
Definition starpu_scheduler.h:177
starpu_sched_policy::init_sched
void(* init_sched)(unsigned sched_ctx_id)
Definition starpu_scheduler.h:87
starpu_sched_policy::do_schedule
void(* do_schedule)(unsigned sched_ctx_id)
Definition starpu_scheduler.h:165
starpu_sched_policy::post_exec_hook
void(* post_exec_hook)(struct starpu_task *, unsigned sched_ctx_id)
Definition starpu_scheduler.h:157
starpu_data_expected_transfer_time
double starpu_data_expected_transfer_time(starpu_data_handle_t handle, unsigned memory_node, enum starpu_data_access_mode mode)
starpu_idle_prefetch_task_input_on_node
int starpu_idle_prefetch_task_input_on_node(struct starpu_task *task, unsigned node)
starpu_task_footprint
uint32_t starpu_task_footprint(struct starpu_perfmodel *model, struct starpu_task *task, struct starpu_perfmodel_arch *arch, unsigned nimpl)
starpu_push_task_end
int starpu_push_task_end(struct starpu_task *task)
starpu_sched_get_sched_policy_in_ctx
struct starpu_sched_policy * starpu_sched_get_sched_policy_in_ctx(unsigned sched_ctx_id)
starpu_worker_can_execute_task
int starpu_worker_can_execute_task(unsigned workerid, struct starpu_task *task, unsigned nimpl)
starpu_task_expected_length
double starpu_task_expected_length(struct starpu_task *task, struct starpu_perfmodel_arch *arch, unsigned nimpl)
starpu_sched_ctx_worker_shares_tasks_lists
void starpu_sched_ctx_worker_shares_tasks_lists(int workerid, int sched_ctx_id)
starpu_task_expected_data_transfer_time_for
double starpu_task_expected_data_transfer_time_for(struct starpu_task *task, unsigned worker)
starpu_wake_worker_relax
int starpu_wake_worker_relax(int workerid)
starpu_task_expected_length_average
double starpu_task_expected_length_average(struct starpu_task *task, unsigned sched_ctx_id)
starpu_get_sched_lib_policies
struct starpu_sched_policy ** starpu_get_sched_lib_policies(void)
starpu_sched_task_break
void starpu_sched_task_break(struct starpu_task *task)
starpu_prefetch_task_input_on_node
int starpu_prefetch_task_input_on_node(struct starpu_task *task, unsigned node)
starpu_idle_prefetch_task_input_for
int starpu_idle_prefetch_task_input_for(struct starpu_task *task, unsigned worker)
starpu_task_expected_energy
double starpu_task_expected_energy(struct starpu_task *task, struct starpu_perfmodel_arch *arch, unsigned nimpl)
starpu_worker_can_execute_task_impl
int starpu_worker_can_execute_task_impl(unsigned workerid, struct starpu_task *task, unsigned *impl_mask)
starpu_prefetch_task_input_on_node_prio
int starpu_prefetch_task_input_on_node_prio(struct starpu_task *task, unsigned node, int prio)
starpu_task_expected_data_transfer_time
double starpu_task_expected_data_transfer_time(unsigned memory_node, struct starpu_task *task)
starpu_task_expected_conversion_time
double starpu_task_expected_conversion_time(struct starpu_task *task, struct starpu_perfmodel_arch *arch, unsigned nimpl)
starpu_sched_get_max_priority
int starpu_sched_get_max_priority(void)
starpu_idle_prefetch_task_input_on_node_prio
int starpu_idle_prefetch_task_input_on_node_prio(struct starpu_task *task, unsigned node, int prio)
starpu_sched_get_min_priority
int starpu_sched_get_min_priority(void)
starpu_worker_can_execute_task_first_impl
int starpu_worker_can_execute_task_first_impl(unsigned workerid, struct starpu_task *task, unsigned *nimpl)
starpu_idle_prefetch_task_input_for_prio
int starpu_idle_prefetch_task_input_for_prio(struct starpu_task *task, unsigned worker, int prio)
starpu_wake_worker_locked
int starpu_wake_worker_locked(int workerid)
starpu_prefetch_task_input_for
int starpu_prefetch_task_input_for(struct starpu_task *task, unsigned worker)
starpu_worker_get_relative_speedup
double starpu_worker_get_relative_speedup(struct starpu_perfmodel_arch *perf_arch)
starpu_wake_worker_relax_light
int starpu_wake_worker_relax_light(int workerid)
starpu_task_notify_ready_soon_register
void starpu_task_notify_ready_soon_register(starpu_notify_ready_soon_func f, void *data)
starpu_wake_worker_no_relax
int starpu_wake_worker_no_relax(int workerid)
starpu_get_prefetch_flag
int starpu_get_prefetch_flag(void)
starpu_task_worker_expected_length
double starpu_task_worker_expected_length(struct starpu_task *task, unsigned workerid, unsigned sched_ctx_id, unsigned nimpl)
starpu_sched_get_sched_policy
struct starpu_sched_policy * starpu_sched_get_sched_policy(void)
starpu_task_get_job_id
unsigned long starpu_task_get_job_id(struct starpu_task *task)
starpu_task_data_footprint
uint32_t starpu_task_data_footprint(struct starpu_task *task)
starpu_task_worker_expected_energy
double starpu_task_worker_expected_energy(struct starpu_task *task, unsigned workerid, unsigned sched_ctx_id, unsigned nimpl)
starpu_get_sched_lib_policy
struct starpu_sched_policy * starpu_get_sched_lib_policy(const char *name)
starpu_sched_set_max_priority
int starpu_sched_set_max_priority(int max_prio)
starpu_sched_set_min_priority
int starpu_sched_set_min_priority(int min_prio)
starpu_task_expected_energy_average
double starpu_task_expected_energy_average(struct starpu_task *task, unsigned sched_ctx_id)
starpu_worker_get_sched_condition
void starpu_worker_get_sched_condition(int workerid, starpu_pthread_mutex_t **sched_mutex, starpu_pthread_cond_t **sched_cond)
starpu_prefetch_task_input_for_prio
int starpu_prefetch_task_input_for_prio(struct starpu_task *task, unsigned worker, int prio)
starpu_push_local_task
int starpu_push_local_task(int workerid, struct starpu_task *task, int back)
starpu_sched_get_predefined_policies
struct starpu_sched_policy ** starpu_sched_get_predefined_policies(void)
starpu_sched_policy
Definition starpu_scheduler.h:82
starpu_worker_collection_type
starpu_worker_collection_type
Definition starpu_worker.h:100
starpu.h