StarPU Handbook
starpu_task.h
Go to the documentation of this file.
1 /* StarPU --- Runtime system for heterogeneous multicore architectures.
2  *
3  * Copyright (C) 2009-2020 Université de Bordeaux, CNRS (LaBRI UMR 5800), Inria
4  * Copyright (C) 2011 Télécom-SudParis
5  * Copyright (C) 2016 Uppsala University
6  *
7  * StarPU is free software; you can redistribute it and/or modify
8  * it under the terms of the GNU Lesser General Public License as published by
9  * the Free Software Foundation; either version 2.1 of the License, or (at
10  * your option) any later version.
11  *
12  * StarPU is distributed in the hope that it will be useful, but
13  * WITHOUT ANY WARRANTY; without even the implied warranty of
14  * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.
15  *
16  * See the GNU Lesser General Public License in COPYING.LGPL for more details.
17  */
18 
19 #ifndef __STARPU_TASK_H__
20 #define __STARPU_TASK_H__
21 
22 #include <starpu.h>
23 #include <errno.h>
24 #include <assert.h>
25 
26 #if defined STARPU_USE_CUDA && !defined STARPU_DONT_INCLUDE_CUDA_HEADERS
27 # include <cuda.h>
28 #endif
29 
30 #ifdef __cplusplus
31 extern "C"
32 {
33 #endif
34 
48 #define STARPU_NOWHERE ((1ULL)<<0)
49 
55 #define STARPU_CPU ((1ULL)<<1)
56 
62 #define STARPU_CUDA ((1ULL)<<3)
63 
69 #define STARPU_OPENCL ((1ULL)<<6)
70 
76 #define STARPU_MIC ((1ULL)<<7)
77 
83 #define STARPU_MPI_MS ((1ULL)<<9)
84 
89 #define STARPU_CODELET_SIMGRID_EXECUTE (1<<0)
90 
96 #define STARPU_CODELET_SIMGRID_EXECUTE_AND_INJECT (1<<1)
97 
102 #define STARPU_CODELET_NOPLANS (1<<2)
103 
108 #define STARPU_CUDA_ASYNC (1<<0)
109 
114 #define STARPU_OPENCL_ASYNC (1<<0)
115 
119 #define STARPU_MAIN_RAM 0
120 
121 
127 {
143 };
144 
146 {
148 #define STARPU_TASK_INVALID 0
158 };
159 
163 typedef void (*starpu_cpu_func_t)(void **, void*);
164 
168 typedef void (*starpu_cuda_func_t)(void **, void*);
169 
173 typedef void (*starpu_opencl_func_t)(void **, void*);
174 
178 typedef void (*starpu_mic_kernel_t)(void **, void*);
179 
184 
188 typedef void (*starpu_mpi_ms_kernel_t)(void **, void*);
189 
194 
202 #define STARPU_MULTIPLE_CPU_IMPLEMENTATIONS ((starpu_cpu_func_t) -1)
203 
211 #define STARPU_MULTIPLE_CUDA_IMPLEMENTATIONS ((starpu_cuda_func_t) -1)
212 
220 #define STARPU_MULTIPLE_OPENCL_IMPLEMENTATIONS ((starpu_opencl_func_t) -1)
221 
227 #define STARPU_VARIABLE_NBUFFERS (-1)
228 
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)
238 
239 struct starpu_task;
240 
249 {
264  uint32_t where;
265 
271  int (*can_execute)(unsigned workerid, struct starpu_task *task, unsigned nimpl);
272 
281 
288 
294  starpu_cpu_func_t cpu_func STARPU_DEPRECATED;
295 
301  starpu_cuda_func_t cuda_func STARPU_DEPRECATED;
302 
309 
326 
341 
348 
362 
369 
385 
401 
410 
424  int nbuffers;
425 
436 
449 
459  unsigned specific_nodes;
460 
469 
481  int *dyn_nodes;
482 
490 
500 
509 
514  const char *name;
515 
520  unsigned color;
521 
525  int flags;
526 
530  int checked;
531 };
532 
537 {
540 };
541 
552 {
560  const char *name;
561 
570 
578  int32_t where;
579 
587  int nbuffers;
588 
589  /* Keep dyn_handles, dyn_interfaces and dyn_modes before the
590  * equivalent static arrays, so we can detect dyn_handles
591  * being NULL while nbuffers being bigger that STARPU_NMAXBUFS
592  * (otherwise the overflow would put a non-NULL) */
593 
633 
669 
679 
694  void *cl_arg;
711  size_t cl_arg_size;
712 
729  void (*callback_func)(void *);
743 
757  void (*prologue_callback_func)(void *);
758 
769 
770  void (*prologue_callback_pop_func)(void *);
771  void *prologue_callback_pop_arg;
772 
782 
796  unsigned cl_arg_free:1;
797 
809  unsigned callback_arg_free:1;
810 
823 
837 
848  unsigned use_tag:1;
849 
861 
871  unsigned synchronous:1;
872 
882 
892  unsigned detach:1;
893 
909  unsigned destroy:1;
910 
920  unsigned regenerate:1;
921 
927  unsigned mf_skip:1;
928 
936  unsigned no_submitorder:1;
937 
943  unsigned scheduled:1;
944  unsigned prefetched:1;
945 
957  unsigned workerid;
958 
973  unsigned workerorder;
974 
987  uint32_t *workerids;
988 
998  unsigned workerids_len;
999 
1022 
1029 
1037  int magic;
1038 
1048  unsigned type;
1049 
1056  unsigned color;
1057 
1064  unsigned sched_ctx;
1065 
1073 
1081 
1087 
1096 
1108  double flops;
1116  double predicted;
1117 
1126  double predicted_start;
1127 
1134 
1141 
1147 
1148 #ifdef STARPU_OPENMP
1149 
1153  struct starpu_omp_task *omp_task;
1154 #else
1155  void *omp_task;
1156 #endif
1157 
1162 
1170  void *sched_data;
1171 };
1172 
1176 #define STARPU_TASK_TYPE_NORMAL 0
1177 
1181 #define STARPU_TASK_TYPE_INTERNAL (1<<0)
1182 
1186 #define STARPU_TASK_TYPE_DATA_ACQUIRE (1<<1)
1187 
1193 /* Note: remember to update starpu_task_init as well */
1194 #define STARPU_TASK_INITIALIZER \
1195 { \
1196  .cl = NULL, \
1197  .where = -1, \
1198  .cl_arg = NULL, \
1199  .cl_arg_size = 0, \
1200  .callback_func = NULL, \
1201  .callback_arg = NULL, \
1202  .priority = STARPU_DEFAULT_PRIO, \
1203  .use_tag = 0, \
1204  .sequential_consistency = 1, \
1205  .synchronous = 0, \
1206  .execute_on_a_specific_worker = 0, \
1207  .workerorder = 0, \
1208  .bundle = NULL, \
1209  .detach = 1, \
1210  .destroy = 0, \
1211  .regenerate = 0, \
1212  .status = STARPU_TASK_INVALID, \
1213  .profiling_info = NULL, \
1214  .predicted = NAN, \
1215  .predicted_transfer = NAN, \
1216  .predicted_start = NAN, \
1217  .starpu_private = NULL, \
1218  .magic = 42, \
1219  .type = 0, \
1220  .color = 0, \
1221  .sched_ctx = STARPU_NMAX_SCHED_CTXS, \
1222  .hypervisor_tag = 0, \
1223  .flops = 0.0, \
1224  .scheduled = 0, \
1225  .prefetched = 0, \
1226  .dyn_handles = NULL, \
1227  .dyn_interfaces = NULL, \
1228  .dyn_modes = NULL, \
1229  .name = NULL, \
1230  .possibly_parallel = 0 \
1231 }
1232 
1238 #define STARPU_TASK_GET_NBUFFERS(task) ((unsigned)((task)->cl->nbuffers == STARPU_VARIABLE_NBUFFERS ? ((task)->nbuffers) : ((task)->cl->nbuffers)))
1239 
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)
1249 
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)
1259 
1267 #define STARPU_CODELET_GET_MODE(codelet, i) \
1268  (((codelet)->dyn_modes) ? (codelet)->dyn_modes[i] : (assert(i < STARPU_NMAXBUFS), (codelet)->modes[i]))
1269 
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)
1279 
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) )
1291 
1299 #define STARPU_TASK_SET_MODE(task, mode, i) \
1300  do { \
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; \
1303  else \
1304  STARPU_CODELET_SET_MODE((task)->cl, mode, i); \
1305  } while(0)
1306 
1314 #define STARPU_CODELET_GET_NODE(codelet, i) (((codelet)->dyn_nodes) ? (codelet)->dyn_nodes[i] : (codelet)->nodes[i])
1315 
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)
1325 
1333 void starpu_task_init(struct starpu_task *task);
1334 
1346 void starpu_task_clean(struct starpu_task *task);
1347 
1359 
1368 void starpu_task_destroy(struct starpu_task *task);
1369 
1387 int starpu_task_submit(struct starpu_task *task) STARPU_WARN_UNUSED_RESULT;
1388 
1394 int starpu_task_submit_to_ctx(struct starpu_task *task, unsigned sched_ctx_id);
1395 
1396 int starpu_task_finished(struct starpu_task *task) STARPU_WARN_UNUSED_RESULT;
1397 
1405 int starpu_task_wait(struct starpu_task *task) STARPU_WARN_UNUSED_RESULT;
1406 
1412 int starpu_task_wait_array(struct starpu_task **tasks, unsigned nb_tasks) STARPU_WARN_UNUSED_RESULT;
1413 
1419 int starpu_task_wait_for_all(void);
1420 
1426 int starpu_task_wait_for_n_submitted(unsigned n);
1427 
1432 int starpu_task_wait_for_all_in_ctx(unsigned sched_ctx_id);
1433 
1439 int starpu_task_wait_for_n_submitted_in_ctx(unsigned sched_ctx_id, unsigned n);
1440 
1445 
1451 int starpu_task_nready(void);
1452 
1456 int starpu_task_nsubmitted(void);
1457 
1470 void starpu_iteration_push(unsigned long iteration);
1471 
1477 void starpu_iteration_pop(void);
1478 
1479 void starpu_do_schedule(void);
1480 
1486 void starpu_codelet_init(struct starpu_codelet *cl);
1487 
1492 
1498 struct starpu_task *starpu_task_get_current(void);
1499 
1510 int starpu_task_get_current_data_node(unsigned i);
1511 
1515 const char *starpu_task_get_model_name(struct starpu_task *task);
1516 
1521 const char *starpu_task_get_name(struct starpu_task *task);
1522 
1526 struct starpu_task *starpu_task_dup(struct starpu_task *task);
1527 
1532 void starpu_task_set_implementation(struct starpu_task *task, unsigned impl);
1533 
1538 unsigned starpu_task_get_implementation(struct starpu_task *task);
1539 
1544 void starpu_create_sync_task(starpu_tag_t sync_tag, unsigned ndeps, starpu_tag_t *deps, void (*callback)(void *), void *callback_arg);
1545 
1549 void starpu_create_callback_task(void (*callback)(void *), void *callback_arg);
1550 
1555 void starpu_task_watchdog_set_hook(void (*hook)(void *), void *hook_arg);
1556 
1559 #ifdef __cplusplus
1560 }
1561 #endif
1562 
1563 #endif /* __STARPU_TASK_H__ */
starpu_profiling_task_info
Definition: starpu_profiling.h:48
starpu_task::handles
starpu_data_handle_t handles[STARPU_NMAXBUFS]
Definition: starpu_task.h:646
starpu_task_dup
struct starpu_task * starpu_task_dup(struct starpu_task *task)
starpu_codelet::opencl_funcs
starpu_opencl_func_t opencl_funcs[STARPU_MAXIMPLEMENTATIONS]
Definition: starpu_task.h:361
starpu_data_descr::handle
starpu_data_handle_t handle
Definition: starpu_task.h:538
starpu_codelet::cuda_func
starpu_cuda_func_t cuda_func
Definition: starpu_task.h:301
starpu_task::handles_sequential_consistency
unsigned char * handles_sequential_consistency
Definition: starpu_task.h:678
starpu_codelet::flags
int flags
Definition: starpu_task.h:525
starpu_codelet::nodes
int nodes[STARPU_NMAXBUFS]
Definition: starpu_task.h:468
starpu_task::callback_arg_free
unsigned callback_arg_free
Definition: starpu_task.h:809
starpu_task::dyn_interfaces
void ** dyn_interfaces
Definition: starpu_task.h:615
STARPU_TASK_STOPPED
@ STARPU_TASK_STOPPED
Definition: starpu_task.h:157
starpu_task_get_model_name
const char * starpu_task_get_model_name(struct starpu_task *task)
starpu_task::workerids
uint32_t * workerids
Definition: starpu_task.h:987
starpu_data_descr::mode
enum starpu_data_access_mode mode
Definition: starpu_task.h:539
starpu_task::priority
int priority
Definition: starpu_task.h:1021
starpu_perfmodel
Definition: starpu_perfmodel.h:188
starpu_task_wait_array
int starpu_task_wait_array(struct starpu_task **tasks, unsigned nb_tasks) STARPU_WARN_UNUSED_RESULT
starpu_codelet_init
void starpu_codelet_init(struct starpu_codelet *cl)
starpu_codelet::mpi_ms_funcs
starpu_mpi_ms_func_t mpi_ms_funcs[STARPU_MAXIMPLEMENTATIONS]
Definition: starpu_task.h:400
STARPU_NMAXBUFS
#define STARPU_NMAXBUFS
Definition: starpu_config.h:184
starpu_codelet::opencl_func
starpu_opencl_func_t opencl_func
Definition: starpu_task.h:308
STARPU_MAXIMPLEMENTATIONS
#define STARPU_MAXIMPLEMENTATIONS
Definition: starpu_config.h:242
starpu_task::destroy
unsigned destroy
Definition: starpu_task.h:909
starpu_task::sched_ctx
unsigned sched_ctx
Definition: starpu_task.h:1064
starpu_task::omp_task
struct starpu_omp_task * omp_task
Definition: starpu_task.h:1153
starpu_task::predicted
double predicted
Definition: starpu_task.h:1116
starpu_task::hypervisor_tag
int hypervisor_tag
Definition: starpu_task.h:1072
starpu_codelet::mic_funcs
starpu_mic_func_t mic_funcs[STARPU_MAXIMPLEMENTATIONS]
Definition: starpu_task.h:384
starpu_codelet::modes
enum starpu_data_access_mode modes[STARPU_NMAXBUFS]
Definition: starpu_task.h:435
starpu_codelet::cpu_func
starpu_cpu_func_t cpu_func
Definition: starpu_task.h:294
starpu_codelet::nbuffers
int nbuffers
Definition: starpu_task.h:424
starpu_task_get_current_data_node
int starpu_task_get_current_data_node(unsigned i)
starpu_codelet::where
uint32_t where
Definition: starpu_task.h:264
STARPU_TASK_BLOCKED_ON_TAG
@ STARPU_TASK_BLOCKED_ON_TAG
Definition: starpu_task.h:154
starpu_codelet::color
unsigned color
Definition: starpu_task.h:520
starpu_codelet::cuda_funcs
starpu_cuda_func_t cuda_funcs[STARPU_MAXIMPLEMENTATIONS]
Definition: starpu_task.h:340
starpu_task_clean
void starpu_task_clean(struct starpu_task *task)
starpu_data_access_mode
starpu_data_access_mode
Definition: starpu_data.h:54
starpu_task_wait_for_all_in_ctx
int starpu_task_wait_for_all_in_ctx(unsigned sched_ctx_id)
starpu_iteration_push
void starpu_iteration_push(unsigned long iteration)
starpu_task::cl_arg_size
size_t cl_arg_size
Definition: starpu_task.h:711
starpu_codelet::cpu_funcs_name
const char * cpu_funcs_name[STARPU_MAXIMPLEMENTATIONS]
Definition: starpu_task.h:409
starpu_tag_t
uint64_t starpu_tag_t
Definition: starpu_task_dep.h:127
starpu_mpi_ms_kernel_t
void(* starpu_mpi_ms_kernel_t)(void **, void *)
Definition: starpu_task.h:188
starpu_task_bundle_t
struct _starpu_task_bundle * starpu_task_bundle_t
Definition: starpu_task_bundle.h:40
starpu_task::predicted_transfer
double predicted_transfer
Definition: starpu_task.h:1125
starpu_codelet_type
starpu_codelet_type
Definition: starpu_task.h:126
starpu_task::prev
struct starpu_task * prev
Definition: starpu_task.h:1133
STARPU_NMAXWORKERS
#define STARPU_NMAXWORKERS
Definition: starpu_config.h:226
starpu_task::bundle
starpu_task_bundle_t bundle
Definition: starpu_task.h:1086
STARPU_TASK_RUNNING
@ STARPU_TASK_RUNNING
Definition: starpu_task.h:152
starpu_task::regenerate
unsigned regenerate
Definition: starpu_task.h:920
starpu_task_set_implementation
void starpu_task_set_implementation(struct starpu_task *task, unsigned impl)
starpu_task::dyn_modes
enum starpu_data_access_mode * dyn_modes
Definition: starpu_task.h:632
starpu_codelet::model
struct starpu_perfmodel * model
Definition: starpu_task.h:489
starpu_task::prologue_callback_arg
void * prologue_callback_arg
Definition: starpu_task.h:768
starpu_task_submit
int starpu_task_submit(struct starpu_task *task) STARPU_WARN_UNUSED_RESULT
starpu_task::execute_on_a_specific_worker
unsigned execute_on_a_specific_worker
Definition: starpu_task.h:881
starpu_task::nb_termination_call_required
unsigned nb_termination_call_required
Definition: starpu_task.h:1161
starpu_task::use_tag
unsigned use_tag
Definition: starpu_task.h:848
starpu_task::magic
int magic
Definition: starpu_task.h:1037
starpu_codelet
Definition: starpu_task.h:248
STARPU_SPMD
@ STARPU_SPMD
Definition: starpu_task.h:131
starpu_task::cl_arg
void * cl_arg
Definition: starpu_task.h:694
STARPU_TASK_BLOCKED_ON_TASK
@ STARPU_TASK_BLOCKED_ON_TASK
Definition: starpu_task.h:155
starpu_task::color
unsigned color
Definition: starpu_task.h:1056
starpu_task::dyn_handles
starpu_data_handle_t * dyn_handles
Definition: starpu_task.h:607
starpu_codelet::opencl_flags
char opencl_flags[STARPU_MAXIMPLEMENTATIONS]
Definition: starpu_task.h:368
starpu_task::modes
enum starpu_data_access_mode modes[STARPU_NMAXBUFS]
Definition: starpu_task.h:668
starpu_task::callback_func
void(* callback_func)(void *)
Definition: starpu_task.h:729
starpu_task::possibly_parallel
unsigned possibly_parallel
Definition: starpu_task.h:1080
starpu_codelet::specific_nodes
unsigned specific_nodes
Definition: starpu_task.h:459
starpu_task::workerid
unsigned workerid
Definition: starpu_task.h:957
starpu_codelet_display_stats
void starpu_codelet_display_stats(struct starpu_codelet *cl)
starpu_task::starpu_private
void * starpu_private
Definition: starpu_task.h:1146
starpu_task::nbuffers
int nbuffers
Definition: starpu_task.h:587
starpu_data_handle_t
struct _starpu_data_state * starpu_data_handle_t
Definition: starpu_data.h:44
starpu_task_submit_to_ctx
int starpu_task_submit_to_ctx(struct starpu_task *task, unsigned sched_ctx_id)
starpu_task::detach
unsigned detach
Definition: starpu_task.h:892
starpu.h
starpu_task::where
int32_t where
Definition: starpu_task.h:578
starpu_task::cl_arg_free
unsigned cl_arg_free
Definition: starpu_task.h:796
starpu_opencl_func_t
void(* starpu_opencl_func_t)(void **, void *)
Definition: starpu_task.h:173
starpu_task_get_current
struct starpu_task * starpu_task_get_current(void)
STARPU_SEQ
@ STARPU_SEQ
Definition: starpu_task.h:128
starpu_task_create
struct starpu_task * starpu_task_create(void) STARPU_ATTRIBUTE_MALLOC
starpu_task::prologue_callback_func
void(* prologue_callback_func)(void *)
Definition: starpu_task.h:757
starpu_task
Definition: starpu_task.h:551
starpu_task_wait_for_n_submitted_in_ctx
int starpu_task_wait_for_n_submitted_in_ctx(unsigned sched_ctx_id, unsigned n)
starpu_task::flops
double flops
Definition: starpu_task.h:1108
starpu_codelet::checked
int checked
Definition: starpu_task.h:530
starpu_task::scheduled
unsigned scheduled
Definition: starpu_task.h:943
starpu_task::interfaces
void * interfaces[STARPU_NMAXBUFS]
Definition: starpu_task.h:653
starpu_iteration_pop
void starpu_iteration_pop(void)
starpu_task::sched_data
void * sched_data
Definition: starpu_task.h:1170
starpu_task::prologue_callback_arg_free
unsigned prologue_callback_arg_free
Definition: starpu_task.h:822
STARPU_TASK_FINISHED
@ STARPU_TASK_FINISHED
Definition: starpu_task.h:153
starpu_cpu_func_t
void(* starpu_cpu_func_t)(void **, void *)
Definition: starpu_task.h:163
starpu_task::next
struct starpu_task * next
Definition: starpu_task.h:1140
starpu_task_init
void starpu_task_init(struct starpu_task *task)
starpu_task_nsubmitted
int starpu_task_nsubmitted(void)
starpu_task::mf_skip
unsigned mf_skip
Definition: starpu_task.h:927
starpu_task_wait_for_n_submitted
int starpu_task_wait_for_n_submitted(unsigned n)
starpu_codelet::can_execute
int(* can_execute)(unsigned workerid, struct starpu_task *task, unsigned nimpl)
Definition: starpu_task.h:271
starpu_task::workerorder
unsigned workerorder
Definition: starpu_task.h:973
starpu_mic_func_t
starpu_mic_kernel_t(* starpu_mic_func_t)(void)
Definition: starpu_task.h:183
starpu_create_callback_task
void starpu_create_callback_task(void(*callback)(void *), void *callback_arg)
STARPU_TASK_READY
@ STARPU_TASK_READY
Definition: starpu_task.h:151
STARPU_TASK_INVALID
@ STARPU_TASK_INVALID
Definition: starpu_task.h:147
STARPU_FORKJOIN
@ STARPU_FORKJOIN
Definition: starpu_task.h:137
starpu_task::no_submitorder
unsigned no_submitorder
Definition: starpu_task.h:936
starpu_task_get_implementation
unsigned starpu_task_get_implementation(struct starpu_task *task)
starpu_task::name
const char * name
Definition: starpu_task.h:560
STARPU_TASK_BLOCKED_ON_DATA
@ STARPU_TASK_BLOCKED_ON_DATA
Definition: starpu_task.h:156
starpu_task::profiling_info
struct starpu_profiling_task_info * profiling_info
Definition: starpu_task.h:1095
starpu_task::status
enum starpu_task_status status
Definition: starpu_task.h:1028
starpu_task::tag_id
starpu_tag_t tag_id
Definition: starpu_task.h:781
starpu_codelet::cpu_funcs
starpu_cpu_func_t cpu_funcs[STARPU_MAXIMPLEMENTATIONS]
Definition: starpu_task.h:325
starpu_mic_kernel_t
void(* starpu_mic_kernel_t)(void **, void *)
Definition: starpu_task.h:178
starpu_task::synchronous
unsigned synchronous
Definition: starpu_task.h:871
starpu_task_wait
int starpu_task_wait(struct starpu_task *task) STARPU_WARN_UNUSED_RESULT
starpu_task_destroy
void starpu_task_destroy(struct starpu_task *task)
starpu_task_status
starpu_task_status
Definition: starpu_task.h:145
starpu_task_nready
int starpu_task_nready(void)
starpu_task_watchdog_set_hook
void starpu_task_watchdog_set_hook(void(*hook)(void *), void *hook_arg)
starpu_codelet::type
enum starpu_codelet_type type
Definition: starpu_task.h:280
starpu_task::sequential_consistency
unsigned sequential_consistency
Definition: starpu_task.h:860
starpu_codelet::max_parallelism
int max_parallelism
Definition: starpu_task.h:287
starpu_task::prologue_callback_pop_arg_free
unsigned prologue_callback_pop_arg_free
Definition: starpu_task.h:836
starpu_task_wait_for_no_ready
int starpu_task_wait_for_no_ready(void)
STARPU_TASK_BLOCKED
@ STARPU_TASK_BLOCKED
Definition: starpu_task.h:149
starpu_task::workerids_len
unsigned workerids_len
Definition: starpu_task.h:998
starpu_codelet::name
const char * name
Definition: starpu_task.h:514
starpu_task::cl
struct starpu_codelet * cl
Definition: starpu_task.h:569
starpu_codelet::dyn_modes
enum starpu_data_access_mode * dyn_modes
Definition: starpu_task.h:448
starpu_task_get_name
const char * starpu_task_get_name(struct starpu_task *task)
starpu_data_descr
Definition: starpu_task.h:536
starpu_cuda_func_t
void(* starpu_cuda_func_t)(void **, void *)
Definition: starpu_task.h:168
starpu_codelet::energy_model
struct starpu_perfmodel * energy_model
Definition: starpu_task.h:499
starpu_codelet::cuda_flags
char cuda_flags[STARPU_MAXIMPLEMENTATIONS]
Definition: starpu_task.h:347
starpu_codelet::per_worker_stats
unsigned long per_worker_stats[STARPU_NMAXWORKERS]
Definition: starpu_task.h:508
starpu_codelet::dyn_nodes
int * dyn_nodes
Definition: starpu_task.h:481
starpu_task::type
unsigned type
Definition: starpu_task.h:1048
starpu_mpi_ms_func_t
starpu_mpi_ms_kernel_t(* starpu_mpi_ms_func_t)(void)
Definition: starpu_task.h:193
starpu_task_wait_for_all
int starpu_task_wait_for_all(void)
starpu_task::callback_arg
void * callback_arg
Definition: starpu_task.h:742
STARPU_ATTRIBUTE_MALLOC
#define STARPU_ATTRIBUTE_MALLOC
Definition: starpu_util.h:112
starpu_create_sync_task
void starpu_create_sync_task(starpu_tag_t sync_tag, unsigned ndeps, starpu_tag_t *deps, void(*callback)(void *), void *callback_arg)