StarPU Handbook - StarPU Installation
Loading...
Searching...
No Matches
sc_hypervisor.h
Go to the documentation of this file.
1/* StarPU --- Runtime system for heterogeneous multicore architectures.
2 *
3 * Copyright (C) 2011-2023 Université de Bordeaux, CNRS (LaBRI UMR 5800), Inria
4 *
5 * StarPU is free software; you can redistribute it and/or modify
6 * it under the terms of the GNU Lesser General Public License as published by
7 * the Free Software Foundation; either version 2.1 of the License, or (at
8 * your option) any later version.
9 *
10 * StarPU is distributed in the hope that it will be useful, but
11 * WITHOUT ANY WARRANTY; without even the implied warranty of
12 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.
13 *
14 * See the GNU Lesser General Public License in COPYING.LGPL for more details.
15 */
16
17#ifndef SC_HYPERVISOR_H
18#define SC_HYPERVISOR_H
19
20#include <starpu.h>
24#include <math.h>
25
26#ifdef __cplusplus
27extern "C" {
28#endif
29
35{
41 const char *name;
42
46 unsigned custom;
47
52 void (*size_ctxs)(unsigned *sched_ctxs, int nsched_ctxs, int *workers, int nworkers);
53
57 void (*resize_ctxs)(unsigned *sched_ctxs, int nsched_ctxs, int *workers, int nworkers);
58
63 void (*handle_idle_cycle)(unsigned sched_ctx, int worker);
64
69 void (*handle_pushed_task)(unsigned sched_ctx, int worker);
70
75 void (*handle_poped_task)(unsigned sched_ctx, int worker, struct starpu_task *task, uint32_t footprint);
76
81 void (*handle_idle_end)(unsigned sched_ctx, int worker);
82
87 void (*handle_post_exec_hook)(unsigned sched_ctx, int task_tag);
88
93 void (*handle_submitted_job)(struct starpu_codelet *cl, unsigned sched_ctx, uint32_t footprint, size_t data_size);
94
99 void (*end_ctx)(unsigned sched_ctx);
100
105 void (*start_ctx)(unsigned sched_ctx);
106
110 void (*init_worker)(int workerid, unsigned sched_ctx);
111};
112
144extern starpu_pthread_mutex_t act_hypervisor_mutex;
145
150
159
164void sc_hypervisor_register_ctx(unsigned sched_ctx, double total_flops);
165
170void sc_hypervisor_unregister_ctx(unsigned sched_ctx);
171
176void sc_hypervisor_post_resize_request(unsigned sched_ctx, int task_tag);
177
183void sc_hypervisor_resize_ctxs(unsigned *sched_ctxs, int nsched_ctxs, int *workers, int nworkers);
184
188void sc_hypervisor_stop_resize(unsigned sched_ctx);
189
193void sc_hypervisor_start_resize(unsigned sched_ctx);
194
198const char *sc_hypervisor_get_policy(void);
199
203void sc_hypervisor_add_workers_to_sched_ctx(int *workers_to_add, unsigned nworkers_to_add, unsigned sched_ctx);
204
208void sc_hypervisor_remove_workers_from_sched_ctx(int *workers_to_remove, unsigned nworkers_to_remove, unsigned sched_ctx, unsigned now);
209
213void sc_hypervisor_move_workers(unsigned sender_sched_ctx, unsigned receiver_sched_ctx, int *workers_to_move, unsigned nworkers_to_move, unsigned now);
214
219void sc_hypervisor_size_ctxs(unsigned *sched_ctxs, int nsched_ctxs, int *workers, int nworkers);
220
224unsigned sc_hypervisor_get_size_req(unsigned **sched_ctxs, int *nsched_ctxs, int **workers, int *nworkers);
225
229void sc_hypervisor_save_size_req(unsigned *sched_ctxs, int nsched_ctxs, int *workers, int nworkers);
230
235
239unsigned sc_hypervisor_can_resize(unsigned sched_ctx);
240
245void sc_hypervisor_set_type_of_task(struct starpu_codelet *cl, unsigned sched_ctx, uint32_t footprint, size_t data_size);
246
251void sc_hypervisor_update_diff_total_flops(unsigned sched_ctx, double diff_total_flops);
252
257void sc_hypervisor_update_diff_elapsed_flops(unsigned sched_ctx, double diff_task_flops);
258
262void sc_hypervisor_update_resize_interval(unsigned *sched_ctxs, int nsched_ctxs, int max_nworkers);
263
268void sc_hypervisor_get_ctxs_on_level(unsigned **sched_ctxs, int *nsched_ctxs, unsigned hierarchy_level, unsigned father_sched_ctx_id);
269
274
278void sc_hypervisor_get_leaves(unsigned *sched_ctxs, int nsched_ctxs, unsigned *leaves, int *nleaves);
279
284
285void sc_hypervisor_print_overhead(void);
286
287void sc_hypervisor_init_worker(int workerid, unsigned sched_ctx);
288
291#ifdef __cplusplus
292}
293#endif
294
295#endif
Definition starpu_task.h:338
Definition starpu_task.h:683
void sc_hypervisor_get_leaves(unsigned *sched_ctxs, int nsched_ctxs, unsigned *leaves, int *nleaves)
void sc_hypervisor_shutdown(void)
void sc_hypervisor_unregister_ctx(unsigned sched_ctx)
unsigned sc_hypervisor_get_nhierarchy_levels(void)
unsigned sc_hypervisor_get_size_req(unsigned **sched_ctxs, int *nsched_ctxs, int **workers, int *nworkers)
void * sc_hypervisor_init(struct sc_hypervisor_policy *policy)
void sc_hypervisor_remove_workers_from_sched_ctx(int *workers_to_remove, unsigned nworkers_to_remove, unsigned sched_ctx, unsigned now)
void sc_hypervisor_register_ctx(unsigned sched_ctx, double total_flops)
void sc_hypervisor_update_diff_total_flops(unsigned sched_ctx, double diff_total_flops)
void sc_hypervisor_post_resize_request(unsigned sched_ctx, int task_tag)
void sc_hypervisor_free_size_req(void)
void sc_hypervisor_set_type_of_task(struct starpu_codelet *cl, unsigned sched_ctx, uint32_t footprint, size_t data_size)
void sc_hypervisor_resize_ctxs(unsigned *sched_ctxs, int nsched_ctxs, int *workers, int nworkers)
void sc_hypervisor_update_resize_interval(unsigned *sched_ctxs, int nsched_ctxs, int max_nworkers)
double sc_hypervisor_get_nready_flops_of_all_sons_of_sched_ctx(unsigned sched_ctx)
void sc_hypervisor_add_workers_to_sched_ctx(int *workers_to_add, unsigned nworkers_to_add, unsigned sched_ctx)
void sc_hypervisor_save_size_req(unsigned *sched_ctxs, int nsched_ctxs, int *workers, int nworkers)
void sc_hypervisor_stop_resize(unsigned sched_ctx)
void sc_hypervisor_get_ctxs_on_level(unsigned **sched_ctxs, int *nsched_ctxs, unsigned hierarchy_level, unsigned father_sched_ctx_id)
void sc_hypervisor_update_diff_elapsed_flops(unsigned sched_ctx, double diff_task_flops)
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_size_ctxs(unsigned *sched_ctxs, int nsched_ctxs, int *workers, int nworkers)
unsigned sc_hypervisor_can_resize(unsigned sched_ctx)
void sc_hypervisor_start_resize(unsigned sched_ctx)
const char * sc_hypervisor_get_policy(void)
starpu_pthread_mutex_t act_hypervisor_mutex
void(* handle_post_exec_hook)(unsigned sched_ctx, int task_tag)
Definition sc_hypervisor.h:87
void(* handle_idle_cycle)(unsigned sched_ctx, int worker)
Definition sc_hypervisor.h:63
void(* init_worker)(int workerid, unsigned sched_ctx)
Definition sc_hypervisor.h:110
void(* handle_pushed_task)(unsigned sched_ctx, int worker)
Definition sc_hypervisor.h:69
void(* resize_ctxs)(unsigned *sched_ctxs, int nsched_ctxs, int *workers, int nworkers)
Definition sc_hypervisor.h:57
void(* size_ctxs)(unsigned *sched_ctxs, int nsched_ctxs, int *workers, int nworkers)
Definition sc_hypervisor.h:52
void(* handle_idle_end)(unsigned sched_ctx, int worker)
Definition sc_hypervisor.h:81
void(* handle_poped_task)(unsigned sched_ctx, int worker, struct starpu_task *task, uint32_t footprint)
Definition sc_hypervisor.h:75
void(* end_ctx)(unsigned sched_ctx)
Definition sc_hypervisor.h:99
const char * name
Definition sc_hypervisor.h:41
unsigned custom
Definition sc_hypervisor.h:46
void(* handle_submitted_job)(struct starpu_codelet *cl, unsigned sched_ctx, uint32_t footprint, size_t data_size)
Definition sc_hypervisor.h:93
void(* start_ctx)(unsigned sched_ctx)
Definition sc_hypervisor.h:105
Definition sc_hypervisor.h:35