Go to the documentation of this file.
19 #ifndef __STARPU_TASK_H__
20 #define __STARPU_TASK_H__
26 #if defined STARPU_USE_CUDA && !defined STARPU_DONT_INCLUDE_CUDA_HEADERS
48 #define STARPU_NOWHERE ((1ULL)<<0)
55 #define STARPU_CPU ((1ULL)<<1)
62 #define STARPU_CUDA ((1ULL)<<3)
69 #define STARPU_OPENCL ((1ULL)<<6)
76 #define STARPU_MIC ((1ULL)<<7)
83 #define STARPU_MPI_MS ((1ULL)<<9)
89 #define STARPU_CODELET_SIMGRID_EXECUTE (1<<0)
96 #define STARPU_CODELET_SIMGRID_EXECUTE_AND_INJECT (1<<1)
102 #define STARPU_CODELET_NOPLANS (1<<2)
108 #define STARPU_CUDA_ASYNC (1<<0)
114 #define STARPU_OPENCL_ASYNC (1<<0)
119 #define STARPU_MAIN_RAM 0
148 #define STARPU_TASK_INVALID 0
202 #define STARPU_MULTIPLE_CPU_IMPLEMENTATIONS ((starpu_cpu_func_t) -1)
211 #define STARPU_MULTIPLE_CUDA_IMPLEMENTATIONS ((starpu_cuda_func_t) -1)
220 #define STARPU_MULTIPLE_OPENCL_IMPLEMENTATIONS ((starpu_opencl_func_t) -1)
227 #define STARPU_VARIABLE_NBUFFERS (-1)
234 #define STARPU_SPECIFIC_NODE_LOCAL (-1)
235 #define STARPU_SPECIFIC_NODE_CPU (-2)
236 #define STARPU_SPECIFIC_NODE_SLOW (-3)
237 #define STARPU_SPECIFIC_NODE_FAST (-4)
770 void (*prologue_callback_pop_func)(
void *);
771 void *prologue_callback_pop_arg;
944 unsigned prefetched:1;
1126 double predicted_start;
1148 #ifdef STARPU_OPENMP
1176 #define STARPU_TASK_TYPE_NORMAL 0
1181 #define STARPU_TASK_TYPE_INTERNAL (1<<0)
1186 #define STARPU_TASK_TYPE_DATA_ACQUIRE (1<<1)
1194 #define STARPU_TASK_INITIALIZER \
1200 .callback_func = NULL, \
1201 .callback_arg = NULL, \
1202 .priority = STARPU_DEFAULT_PRIO, \
1204 .sequential_consistency = 1, \
1206 .execute_on_a_specific_worker = 0, \
1212 .status = STARPU_TASK_INVALID, \
1213 .profiling_info = NULL, \
1215 .predicted_transfer = NAN, \
1216 .predicted_start = NAN, \
1217 .starpu_private = NULL, \
1221 .sched_ctx = STARPU_NMAX_SCHED_CTXS, \
1222 .hypervisor_tag = 0, \
1226 .dyn_handles = NULL, \
1227 .dyn_interfaces = NULL, \
1228 .dyn_modes = NULL, \
1230 .possibly_parallel = 0 \
1238 #define STARPU_TASK_GET_NBUFFERS(task) ((unsigned)((task)->cl->nbuffers == STARPU_VARIABLE_NBUFFERS ? ((task)->nbuffers) : ((task)->cl->nbuffers)))
1247 #define STARPU_TASK_GET_HANDLE(task, i) (((task)->dyn_handles) ? (task)->dyn_handles[i] : (task)->handles[i])
1248 #define STARPU_TASK_GET_HANDLES(task) (((task)->dyn_handles) ? (task)->dyn_handles : (task)->handles)
1257 #define STARPU_TASK_SET_HANDLE(task, handle, i) \
1258 do { if ((task)->dyn_handles) (task)->dyn_handles[i] = handle; else (task)->handles[i] = handle; } while(0)
1267 #define STARPU_CODELET_GET_MODE(codelet, i) \
1268 (((codelet)->dyn_modes) ? (codelet)->dyn_modes[i] : (assert(i < STARPU_NMAXBUFS), (codelet)->modes[i]))
1277 #define STARPU_CODELET_SET_MODE(codelet, mode, i) \
1278 do { if ((codelet)->dyn_modes) (codelet)->dyn_modes[i] = mode; else (codelet)->modes[i] = mode; } while(0)
1287 #define STARPU_TASK_GET_MODE(task, i) \
1288 ((task)->cl->nbuffers == STARPU_VARIABLE_NBUFFERS || (task)->dyn_modes ? \
1289 (((task)->dyn_modes) ? (task)->dyn_modes[i] : (task)->modes[i]) : \
1290 STARPU_CODELET_GET_MODE((task)->cl, i) )
1299 #define STARPU_TASK_SET_MODE(task, mode, i) \
1301 if ((task)->cl->nbuffers == STARPU_VARIABLE_NBUFFERS || (task)->cl->nbuffers > STARPU_NMAXBUFS) \
1302 if ((task)->dyn_modes) (task)->dyn_modes[i] = mode; else (task)->modes[i] = mode; \
1304 STARPU_CODELET_SET_MODE((task)->cl, mode, i); \
1314 #define STARPU_CODELET_GET_NODE(codelet, i) (((codelet)->dyn_nodes) ? (codelet)->dyn_nodes[i] : (codelet)->nodes[i])
1323 #define STARPU_CODELET_SET_NODE(codelet, __node, i) \
1324 do { if ((codelet)->dyn_nodes) (codelet)->dyn_nodes[i] = __node; else (codelet)->nodes[i] = __node; } while(0)
1396 int starpu_task_finished(
struct starpu_task *task) STARPU_WARN_UNUSED_RESULT;
1479 void starpu_do_schedule(
void);
Definition: starpu_profiling.h:48
starpu_data_handle_t handles[STARPU_NMAXBUFS]
Definition: starpu_task.h:646
struct starpu_task * starpu_task_dup(struct starpu_task *task)
starpu_opencl_func_t opencl_funcs[STARPU_MAXIMPLEMENTATIONS]
Definition: starpu_task.h:361
starpu_data_handle_t handle
Definition: starpu_task.h:538
starpu_cuda_func_t cuda_func
Definition: starpu_task.h:301
unsigned char * handles_sequential_consistency
Definition: starpu_task.h:678
int flags
Definition: starpu_task.h:525
int nodes[STARPU_NMAXBUFS]
Definition: starpu_task.h:468
unsigned callback_arg_free
Definition: starpu_task.h:809
void ** dyn_interfaces
Definition: starpu_task.h:615
@ STARPU_TASK_STOPPED
Definition: starpu_task.h:157
const char * starpu_task_get_model_name(struct starpu_task *task)
uint32_t * workerids
Definition: starpu_task.h:987
enum starpu_data_access_mode mode
Definition: starpu_task.h:539
int priority
Definition: starpu_task.h:1021
int starpu_task_wait_array(struct starpu_task **tasks, unsigned nb_tasks) STARPU_WARN_UNUSED_RESULT
void starpu_codelet_init(struct starpu_codelet *cl)
starpu_mpi_ms_func_t mpi_ms_funcs[STARPU_MAXIMPLEMENTATIONS]
Definition: starpu_task.h:400
#define STARPU_NMAXBUFS
Definition: starpu_config.h:184
starpu_opencl_func_t opencl_func
Definition: starpu_task.h:308
#define STARPU_MAXIMPLEMENTATIONS
Definition: starpu_config.h:242
unsigned destroy
Definition: starpu_task.h:909
unsigned sched_ctx
Definition: starpu_task.h:1064
struct starpu_omp_task * omp_task
Definition: starpu_task.h:1153
double predicted
Definition: starpu_task.h:1116
int hypervisor_tag
Definition: starpu_task.h:1072
starpu_mic_func_t mic_funcs[STARPU_MAXIMPLEMENTATIONS]
Definition: starpu_task.h:384
enum starpu_data_access_mode modes[STARPU_NMAXBUFS]
Definition: starpu_task.h:435
starpu_cpu_func_t cpu_func
Definition: starpu_task.h:294
int nbuffers
Definition: starpu_task.h:424
int starpu_task_get_current_data_node(unsigned i)
uint32_t where
Definition: starpu_task.h:264
@ STARPU_TASK_BLOCKED_ON_TAG
Definition: starpu_task.h:154
unsigned color
Definition: starpu_task.h:520
starpu_cuda_func_t cuda_funcs[STARPU_MAXIMPLEMENTATIONS]
Definition: starpu_task.h:340
void starpu_task_clean(struct starpu_task *task)
starpu_data_access_mode
Definition: starpu_data.h:54
int starpu_task_wait_for_all_in_ctx(unsigned sched_ctx_id)
void starpu_iteration_push(unsigned long iteration)
size_t cl_arg_size
Definition: starpu_task.h:711
const char * cpu_funcs_name[STARPU_MAXIMPLEMENTATIONS]
Definition: starpu_task.h:409
uint64_t starpu_tag_t
Definition: starpu_task_dep.h:127
void(* starpu_mpi_ms_kernel_t)(void **, void *)
Definition: starpu_task.h:188
struct _starpu_task_bundle * starpu_task_bundle_t
Definition: starpu_task_bundle.h:40
double predicted_transfer
Definition: starpu_task.h:1125
starpu_codelet_type
Definition: starpu_task.h:126
struct starpu_task * prev
Definition: starpu_task.h:1133
#define STARPU_NMAXWORKERS
Definition: starpu_config.h:226
starpu_task_bundle_t bundle
Definition: starpu_task.h:1086
@ STARPU_TASK_RUNNING
Definition: starpu_task.h:152
unsigned regenerate
Definition: starpu_task.h:920
void starpu_task_set_implementation(struct starpu_task *task, unsigned impl)
enum starpu_data_access_mode * dyn_modes
Definition: starpu_task.h:632
struct starpu_perfmodel * model
Definition: starpu_task.h:489
void * prologue_callback_arg
Definition: starpu_task.h:768
int starpu_task_submit(struct starpu_task *task) STARPU_WARN_UNUSED_RESULT
unsigned execute_on_a_specific_worker
Definition: starpu_task.h:881
unsigned nb_termination_call_required
Definition: starpu_task.h:1161
unsigned use_tag
Definition: starpu_task.h:848
int magic
Definition: starpu_task.h:1037
Definition: starpu_task.h:248
@ STARPU_SPMD
Definition: starpu_task.h:131
void * cl_arg
Definition: starpu_task.h:694
@ STARPU_TASK_BLOCKED_ON_TASK
Definition: starpu_task.h:155
unsigned color
Definition: starpu_task.h:1056
starpu_data_handle_t * dyn_handles
Definition: starpu_task.h:607
char opencl_flags[STARPU_MAXIMPLEMENTATIONS]
Definition: starpu_task.h:368
enum starpu_data_access_mode modes[STARPU_NMAXBUFS]
Definition: starpu_task.h:668
void(* callback_func)(void *)
Definition: starpu_task.h:729
unsigned possibly_parallel
Definition: starpu_task.h:1080
unsigned specific_nodes
Definition: starpu_task.h:459
unsigned workerid
Definition: starpu_task.h:957
void starpu_codelet_display_stats(struct starpu_codelet *cl)
void * starpu_private
Definition: starpu_task.h:1146
int nbuffers
Definition: starpu_task.h:587
struct _starpu_data_state * starpu_data_handle_t
Definition: starpu_data.h:44
int starpu_task_submit_to_ctx(struct starpu_task *task, unsigned sched_ctx_id)
unsigned detach
Definition: starpu_task.h:892
int32_t where
Definition: starpu_task.h:578
unsigned cl_arg_free
Definition: starpu_task.h:796
void(* starpu_opencl_func_t)(void **, void *)
Definition: starpu_task.h:173
struct starpu_task * starpu_task_get_current(void)
@ STARPU_SEQ
Definition: starpu_task.h:128
struct starpu_task * starpu_task_create(void) STARPU_ATTRIBUTE_MALLOC
void(* prologue_callback_func)(void *)
Definition: starpu_task.h:757
Definition: starpu_task.h:551
int starpu_task_wait_for_n_submitted_in_ctx(unsigned sched_ctx_id, unsigned n)
double flops
Definition: starpu_task.h:1108
int checked
Definition: starpu_task.h:530
unsigned scheduled
Definition: starpu_task.h:943
void * interfaces[STARPU_NMAXBUFS]
Definition: starpu_task.h:653
void starpu_iteration_pop(void)
void * sched_data
Definition: starpu_task.h:1170
unsigned prologue_callback_arg_free
Definition: starpu_task.h:822
@ STARPU_TASK_FINISHED
Definition: starpu_task.h:153
void(* starpu_cpu_func_t)(void **, void *)
Definition: starpu_task.h:163
struct starpu_task * next
Definition: starpu_task.h:1140
void starpu_task_init(struct starpu_task *task)
int starpu_task_nsubmitted(void)
unsigned mf_skip
Definition: starpu_task.h:927
int starpu_task_wait_for_n_submitted(unsigned n)
int(* can_execute)(unsigned workerid, struct starpu_task *task, unsigned nimpl)
Definition: starpu_task.h:271
unsigned workerorder
Definition: starpu_task.h:973
starpu_mic_kernel_t(* starpu_mic_func_t)(void)
Definition: starpu_task.h:183
void starpu_create_callback_task(void(*callback)(void *), void *callback_arg)
@ STARPU_TASK_READY
Definition: starpu_task.h:151
@ STARPU_TASK_INVALID
Definition: starpu_task.h:147
@ STARPU_FORKJOIN
Definition: starpu_task.h:137
unsigned no_submitorder
Definition: starpu_task.h:936
unsigned starpu_task_get_implementation(struct starpu_task *task)
const char * name
Definition: starpu_task.h:560
@ STARPU_TASK_BLOCKED_ON_DATA
Definition: starpu_task.h:156
struct starpu_profiling_task_info * profiling_info
Definition: starpu_task.h:1095
enum starpu_task_status status
Definition: starpu_task.h:1028
starpu_tag_t tag_id
Definition: starpu_task.h:781
starpu_cpu_func_t cpu_funcs[STARPU_MAXIMPLEMENTATIONS]
Definition: starpu_task.h:325
void(* starpu_mic_kernel_t)(void **, void *)
Definition: starpu_task.h:178
unsigned synchronous
Definition: starpu_task.h:871
int starpu_task_wait(struct starpu_task *task) STARPU_WARN_UNUSED_RESULT
void starpu_task_destroy(struct starpu_task *task)
starpu_task_status
Definition: starpu_task.h:145
int starpu_task_nready(void)
void starpu_task_watchdog_set_hook(void(*hook)(void *), void *hook_arg)
enum starpu_codelet_type type
Definition: starpu_task.h:280
unsigned sequential_consistency
Definition: starpu_task.h:860
int max_parallelism
Definition: starpu_task.h:287
unsigned prologue_callback_pop_arg_free
Definition: starpu_task.h:836
int starpu_task_wait_for_no_ready(void)
@ STARPU_TASK_BLOCKED
Definition: starpu_task.h:149
unsigned workerids_len
Definition: starpu_task.h:998
const char * name
Definition: starpu_task.h:514
struct starpu_codelet * cl
Definition: starpu_task.h:569
enum starpu_data_access_mode * dyn_modes
Definition: starpu_task.h:448
const char * starpu_task_get_name(struct starpu_task *task)
Definition: starpu_task.h:536
void(* starpu_cuda_func_t)(void **, void *)
Definition: starpu_task.h:168
struct starpu_perfmodel * energy_model
Definition: starpu_task.h:499
char cuda_flags[STARPU_MAXIMPLEMENTATIONS]
Definition: starpu_task.h:347
unsigned long per_worker_stats[STARPU_NMAXWORKERS]
Definition: starpu_task.h:508
int * dyn_nodes
Definition: starpu_task.h:481
unsigned type
Definition: starpu_task.h:1048
starpu_mpi_ms_kernel_t(* starpu_mpi_ms_func_t)(void)
Definition: starpu_task.h:193
int starpu_task_wait_for_all(void)
void * callback_arg
Definition: starpu_task.h:742
void starpu_create_sync_task(starpu_tag_t sync_tag, unsigned ndeps, starpu_tag_t *deps, void(*callback)(void *), void *callback_arg)