20 #ifndef __STARPU_SCHEDULER_H__
21 #define __STARPU_SCHEDULER_H__
104 double (*simulate_push_task)(
struct starpu_task *);
136 struct starpu_task *(*pop_task)(
unsigned sched_ctx_id);
145 struct starpu_task *(*pop_every_task)(
unsigned sched_ctx_id);
215 unsigned long starpu_task_get_job_id(
struct starpu_task *task);
402 typedef void (*starpu_notify_ready_soon_func)(
void *data,
struct starpu_task *task,
double delay);
418 void starpu_sched_task_break(
struct starpu_task *task);
unsigned workerid
Definition: starpu_task.h:999
uint32_t * workerids
Definition: starpu_task.h:1029
Definition: starpu_task.h:567
starpu_data_access_mode
Definition: starpu_data.h:55
struct _starpu_data_state * starpu_data_handle_t
Definition: starpu_data.h:44
void(* push_task_notify)(struct starpu_task *, int workerid, int perf_workerid, unsigned sched_ctx_id)
Definition: starpu_scheduler.h:114
void(* submit_hook)(struct starpu_task *task)
Definition: starpu_scheduler.h:151
const char * policy_description
Definition: starpu_scheduler.h:193
void(* add_workers)(unsigned sched_ctx_id, int *workerids, unsigned nworkers)
Definition: starpu_scheduler.h:177
void(* deinit_sched)(unsigned sched_ctx_id)
Definition: starpu_scheduler.h:92
int(* push_task)(struct starpu_task *)
Definition: starpu_scheduler.h:102
void(* pre_exec_hook)(struct starpu_task *, unsigned sched_ctx_id)
Definition: starpu_scheduler.h:157
const char * policy_name
Definition: starpu_scheduler.h:188
void(* remove_workers)(unsigned sched_ctx_id, int *workerids, unsigned nworkers)
Definition: starpu_scheduler.h:183
void(* init_sched)(unsigned sched_ctx_id)
Definition: starpu_scheduler.h:88
void(* do_schedule)(unsigned sched_ctx_id)
Definition: starpu_scheduler.h:171
void(* post_exec_hook)(struct starpu_task *, unsigned sched_ctx_id)
Definition: starpu_scheduler.h:163
double starpu_data_expected_transfer_time(starpu_data_handle_t handle, unsigned memory_node, enum starpu_data_access_mode mode)
int starpu_idle_prefetch_task_input_on_node(struct starpu_task *task, unsigned node)
uint32_t starpu_task_footprint(struct starpu_perfmodel *model, struct starpu_task *task, struct starpu_perfmodel_arch *arch, unsigned nimpl)
int starpu_push_task_end(struct starpu_task *task)
int starpu_worker_can_execute_task(unsigned workerid, struct starpu_task *task, unsigned nimpl)
double starpu_task_expected_length(struct starpu_task *task, struct starpu_perfmodel_arch *arch, unsigned nimpl)
void starpu_sched_ctx_worker_shares_tasks_lists(int workerid, int sched_ctx_id)
double starpu_task_expected_data_transfer_time_for(struct starpu_task *task, unsigned worker)
int starpu_wake_worker_relax(int workerid)
int starpu_prefetch_task_input_on_node(struct starpu_task *task, unsigned node)
int starpu_idle_prefetch_task_input_for(struct starpu_task *task, unsigned worker)
double starpu_task_expected_energy(struct starpu_task *task, struct starpu_perfmodel_arch *arch, unsigned nimpl)
int starpu_worker_can_execute_task_impl(unsigned workerid, struct starpu_task *task, unsigned *impl_mask)
int starpu_prefetch_task_input_on_node_prio(struct starpu_task *task, unsigned node, int prio)
double starpu_task_expected_data_transfer_time(unsigned memory_node, struct starpu_task *task)
struct starpu_sched_policy ** starpu_sched_get_predefined_policies()
double starpu_task_expected_conversion_time(struct starpu_task *task, struct starpu_perfmodel_arch *arch, unsigned nimpl)
int starpu_sched_get_max_priority(void)
int starpu_idle_prefetch_task_input_on_node_prio(struct starpu_task *task, unsigned node, int prio)
int starpu_sched_get_min_priority(void)
int starpu_worker_can_execute_task_first_impl(unsigned workerid, struct starpu_task *task, unsigned *nimpl)
int starpu_idle_prefetch_task_input_for_prio(struct starpu_task *task, unsigned worker, int prio)
int starpu_wake_worker_locked(int workerid)
int starpu_prefetch_task_input_for(struct starpu_task *task, unsigned worker)
double starpu_worker_get_relative_speedup(struct starpu_perfmodel_arch *perf_arch)
int starpu_wake_worker_relax_light(int workerid)
void starpu_task_notify_ready_soon_register(starpu_notify_ready_soon_func f, void *data)
int starpu_wake_worker_no_relax(int workerid)
int starpu_get_prefetch_flag(void)
uint32_t starpu_task_data_footprint(struct starpu_task *task)
int starpu_sched_set_max_priority(int max_prio)
int starpu_sched_set_min_priority(int min_prio)
void starpu_worker_get_sched_condition(int workerid, starpu_pthread_mutex_t **sched_mutex, starpu_pthread_cond_t **sched_cond)
int starpu_prefetch_task_input_for_prio(struct starpu_task *task, unsigned worker, int prio)
int starpu_push_local_task(int workerid, struct starpu_task *task, int back)
Definition: starpu_scheduler.h:83
starpu_worker_collection_type
Definition: starpu_worker.h:92