18 #ifndef SC_HYPERVISOR_H 19 #define SC_HYPERVISOR_H 33 starpu_pthread_mutex_t act_hypervisor_mutex;
45 void (*
size_ctxs)(
unsigned *sched_ctxs,
int nsched_ctxs ,
int *workers,
int nworkers);
48 void (*
resize_ctxs)(
unsigned *sched_ctxs,
int nsched_ctxs ,
int *workers,
int nworkers);
106 void sc_hypervisor_move_workers(
unsigned sender_sched_ctx,
unsigned receiver_sched_ctx,
int *workers_to_move,
unsigned nworkers_to_move,
unsigned now);
133 void sc_hypervisor_update_resize_interval(
unsigned *sched_ctxs,
int nsched_ctxs,
int max_nworkers);
136 void sc_hypervisor_get_ctxs_on_level(
unsigned **sched_ctxs,
int *nsched_ctxs,
unsigned hierarchy_level,
unsigned father_sched_ctx_id);
139 unsigned sc_hypervisor_get_nhierarchy_levels(
void);
142 void sc_hypervisor_get_leaves(
unsigned *sched_ctxs,
int nsched_ctxs,
unsigned *leaves,
int *nleaves);
145 double sc_hypervisor_get_nready_flops_of_all_sons_of_sched_ctx(
unsigned sched_ctx);
147 void sc_hypervisor_print_overhead();
void(* handle_poped_task)(unsigned sched_ctx, int worker, struct starpu_task *task, uint32_t footprint)
Definition: sc_hypervisor.h:57
Definition: starpu_task.h:89
void sc_hypervisor_unregister_ctx(unsigned sched_ctx)
void sc_hypervisor_stop_resize(unsigned sched_ctx)
void(* resize_ctxs)(unsigned *sched_ctxs, int nsched_ctxs, int *workers, int nworkers)
Definition: sc_hypervisor.h:48
void sc_hypervisor_set_type_of_task(struct starpu_codelet *cl, unsigned sched_ctx, uint32_t footprint, size_t data_size)
void(* end_ctx)(unsigned sched_ctx)
Definition: sc_hypervisor.h:69
void(* handle_post_exec_hook)(unsigned sched_ctx, int task_tag)
Definition: sc_hypervisor.h:63
void sc_hypervisor_shutdown(void)
unsigned sc_hypervisor_can_resize(unsigned sched_ctx)
void sc_hypervisor_size_ctxs(unsigned *sched_ctxs, int nsched_ctxs, int *workers, int nworkers)
void sc_hypervisor_update_diff_total_flops(unsigned sched_ctx, double diff_total_flops)
unsigned sched_ctx
Definition: starpu_task.h:192
const char * sc_hypervisor_get_policy()
void(* size_ctxs)(unsigned *sched_ctxs, int nsched_ctxs, int *workers, int nworkers)
Definition: sc_hypervisor.h:45
void sc_hypervisor_free_size_req(void)
void(* handle_idle_end)(unsigned sched_ctx, int worker)
Definition: sc_hypervisor.h:60
Definition: starpu_task.h:129
Definition: sc_hypervisor.h:36
void * sc_hypervisor_init(struct sc_hypervisor_policy *policy)
void sc_hypervisor_move_workers(unsigned sender_sched_ctx, unsigned receiver_sched_ctx, int *workers_to_move, unsigned nworkers_to_move, unsigned now)
void sc_hypervisor_remove_workers_from_sched_ctx(int *workers_to_remove, unsigned nworkers_to_remove, unsigned sched_ctx, unsigned now)
void(* handle_idle_cycle)(unsigned sched_ctx, int worker)
Definition: sc_hypervisor.h:51
void(* handle_submitted_job)(struct starpu_codelet *cl, unsigned sched_ctx, uint32_t footprint, size_t data_size)
Definition: sc_hypervisor.h:66
unsigned custom
Definition: sc_hypervisor.h:42
unsigned sc_hypervisor_get_size_req(unsigned **sched_ctxs, int *nsched_ctxs, int **workers, int *nworkers)
void sc_hypervisor_resize_ctxs(unsigned *sched_ctxs, int nsched_ctxs, int *workers, int nworkers)
const char * name
Definition: sc_hypervisor.h:39
void sc_hypervisor_post_resize_request(unsigned sched_ctx, int task_tag)
void sc_hypervisor_save_size_req(unsigned *sched_ctxs, int nsched_ctxs, int *workers, int nworkers)
void sc_hypervisor_add_workers_to_sched_ctx(int *workers_to_add, unsigned nworkers_to_add, unsigned sched_ctx)
void sc_hypervisor_register_ctx(unsigned sched_ctx, double total_flops)
void(* handle_pushed_task)(unsigned sched_ctx, int worker)
Definition: sc_hypervisor.h:54
void sc_hypervisor_update_diff_elapsed_flops(unsigned sched_ctx, double diff_task_flops)
void sc_hypervisor_start_resize(unsigned sched_ctx)