StarPU Handbook - StarPU Installation
starpu_task.h
Go to the documentation of this file.
1/* StarPU --- Runtime system for heterogeneous multicore architectures.
2 *
3 * Copyright (C) 2009-2023 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#ifdef STARPU_USE_CUDA
27#include <cuda.h>
28#endif
29
30#ifdef __cplusplus
31extern "C" {
32#endif
33
47#define STARPU_NOWHERE ((1ULL) << 0)
48
52#define STARPU_WORKER_TO_MASK(worker_archtype) (1ULL << (worker_archtype + 1))
53
59#define STARPU_CPU STARPU_WORKER_TO_MASK(STARPU_CPU_WORKER)
60
66#define STARPU_CUDA STARPU_WORKER_TO_MASK(STARPU_CUDA_WORKER)
67
73#define STARPU_HIP STARPU_WORKER_TO_MASK(STARPU_HIP_WORKER)
74
80#define STARPU_OPENCL STARPU_WORKER_TO_MASK(STARPU_OPENCL_WORKER)
81
87#define STARPU_MAX_FPGA STARPU_WORKER_TO_MASK(STARPU_MAX_FPGA_WORKER)
88
94#define STARPU_MPI_MS STARPU_WORKER_TO_MASK(STARPU_MPI_MS_WORKER)
95
101#define STARPU_TCPIP_MS STARPU_WORKER_TO_MASK(STARPU_TCPIP_MS_WORKER)
102
107#define STARPU_CODELET_SIMGRID_EXECUTE (1 << 0)
108
114#define STARPU_CODELET_SIMGRID_EXECUTE_AND_INJECT (1 << 1)
115
120#define STARPU_CODELET_NOPLANS (1 << 2)
121
126#define STARPU_CUDA_ASYNC (1 << 0)
127
132#define STARPU_HIP_ASYNC (1 << 0)
133
138#define STARPU_OPENCL_ASYNC (1 << 0)
139
143#define STARPU_MAIN_RAM 0
144
150{
151 STARPU_SEQ = 0,
167
169{
171#define STARPU_TASK_INIT 0
172#define STARPU_TASK_INVALID STARPU_TASK_INIT
182
186typedef void (*starpu_cpu_func_t)(void **, void *);
187
191typedef void (*starpu_cuda_func_t)(void **, void *);
192
196typedef void (*starpu_hip_func_t)(void **, void *);
197
201typedef void (*starpu_opencl_func_t)(void **, void *);
202
206typedef void (*starpu_max_fpga_func_t)(void **, void *);
207
212typedef int (*starpu_bubble_func_t)(struct starpu_task *t, void *arg);
213
218typedef void (*starpu_bubble_gen_dag_func_t)(struct starpu_task *t, void *arg);
219
227#define STARPU_MULTIPLE_CPU_IMPLEMENTATIONS ((starpu_cpu_func_t)-1)
228
236#define STARPU_MULTIPLE_CUDA_IMPLEMENTATIONS ((starpu_cuda_func_t)-1)
237
245#define STARPU_MULTIPLE_HIP_IMPLEMENTATIONS ((starpu_hip_func_t)-1)
246
254#define STARPU_MULTIPLE_OPENCL_IMPLEMENTATIONS ((starpu_opencl_func_t)-1)
255
261#define STARPU_VARIABLE_NBUFFERS (-1)
262
268#define STARPU_SPECIFIC_NODE_LOCAL (-1)
269
275#define STARPU_SPECIFIC_NODE_CPU (-2)
276
281#define STARPU_SPECIFIC_NODE_SLOW (-3)
282
287#define STARPU_SPECIFIC_NODE_FAST (-4)
288
294#define STARPU_SPECIFIC_NODE_LOCAL_OR_CPU (-5)
295
302#define STARPU_SPECIFIC_NODE_NONE (-6)
303
304struct starpu_transaction;
305struct _starpu_trs_epoch;
306typedef struct _starpu_trs_epoch *starpu_trs_epoch_t;
307struct starpu_task;
308
334{
349 uint32_t where;
350
356 int (*can_execute)(unsigned workerid, struct starpu_task *task, unsigned nimpl);
357
366
373
379 starpu_cpu_func_t cpu_func STARPU_DEPRECATED;
380
386 starpu_cuda_func_t cuda_func STARPU_DEPRECATED;
387
394
411
426
433
448
455
469
476
493
502
508
513
528
539
552
563
572
585
593
603
612
617 const char *name;
618
625 unsigned color;
626
639 void (*callback_func)(void *);
640
644 int flags;
645
646 struct starpu_perf_counter_sample *perf_counter_sample;
647 struct starpu_perf_counter_sample_cl_values *perf_counter_values;
648
653};
654
659
664{
667};
668
679{
687 const char *name;
688
693 const char *file;
694
699 int line;
700
709
717 int32_t where;
718
727
728 /* Keep dyn_handles, dyn_interfaces and dyn_modes before the
729 * equivalent static arrays, so we can detect dyn_handles
730 * being NULL while nbuffers being bigger that STARPU_NMAXBUFS
731 * (otherwise the overflow would put a non-NULL) */
732
772
786
794
810
820
835 void *cl_arg;
853
862 void *cl_ret;
863
871
886 void (*epilogue_callback_func)(void *);
887
895
914 void (*callback_func)(void *);
915
929
943 void (*prologue_callback_func)(void *);
944
955
970
981
985 struct starpu_transaction *transaction;
986
990 starpu_trs_epoch_t trs_epoch;
991
1001
1012 unsigned cl_arg_free : 1;
1013
1020 unsigned cl_ret_free : 1;
1021
1033 unsigned callback_arg_free : 1;
1034
1043
1056
1070
1081 unsigned use_tag : 1;
1082
1094
1104 unsigned synchronous : 1;
1105
1115
1125 unsigned detach : 1;
1126
1145 unsigned destroy : 1;
1146
1156 unsigned regenerate : 1;
1157
1165 unsigned no_submitorder : 1;
1166
1172 unsigned char mf_skip;
1173
1179 unsigned char failed;
1180
1186 unsigned char scheduled;
1187
1193 unsigned char prefetched;
1194
1206 unsigned workerid;
1207
1222 unsigned workerorder;
1223
1236 uint32_t *workerids;
1237
1248
1271
1280
1289
1299 unsigned type;
1300
1307 unsigned color;
1308
1315 unsigned sched_ctx;
1316
1324
1332
1338
1347
1360 double flops;
1369
1378 double predicted_start;
1379
1386
1393
1399
1400#ifdef STARPU_OPENMP
1405 struct starpu_omp_task *omp_task;
1406#else
1407 void *omp_task;
1408#endif
1409
1414 unsigned long bubble_parent;
1415
1421
1427
1433
1439
1445
1454};
1455
1459#define STARPU_TASK_TYPE_NORMAL 0
1460
1464#define STARPU_TASK_TYPE_INTERNAL (1 << 0)
1465
1469#define STARPU_TASK_TYPE_DATA_ACQUIRE (1 << 1)
1470
1476/* Note: remember to update starpu_task_init and starpu_task_ft_create_retry
1477 * as well */
1478#define STARPU_TASK_INITIALIZER \
1479 { \
1480 .cl = NULL, \
1481 .where = -1, \
1482 .cl_arg = NULL, \
1483 .cl_arg_size = 0, \
1484 .cl_ret = NULL, \
1485 .cl_ret_size = 0, \
1486 .callback_func = NULL, \
1487 .callback_arg = NULL, \
1488 .epilogue_callback_func = NULL, \
1489 .epilogue_callback_arg = NULL, \
1490 .priority = STARPU_DEFAULT_PRIO, \
1491 .use_tag = 0, \
1492 .sequential_consistency = 1, \
1493 .synchronous = 0, \
1494 .execute_on_a_specific_worker = 0, \
1495 .workerorder = 0, \
1496 .bundle = NULL, \
1497 .detach = 1, \
1498 .destroy = 0, \
1499 .regenerate = 0, \
1500 .status = STARPU_TASK_INIT, \
1501 .profiling_info = NULL, \
1502 .predicted = NAN, \
1503 .predicted_transfer = NAN, \
1504 .predicted_start = NAN, \
1505 .starpu_private = NULL, \
1506 .magic = 42, \
1507 .type = 0, \
1508 .color = 0, \
1509 .sched_ctx = STARPU_NMAX_SCHED_CTXS, \
1510 .hypervisor_tag = 0, \
1511 .flops = 0.0, \
1512 .scheduled = 0, \
1513 .prefetched = 0, \
1514 .dyn_handles = NULL, \
1515 .dyn_interfaces = NULL, \
1516 .dyn_modes = NULL, \
1517 .name = NULL, \
1518 .possibly_parallel = 0 \
1519 }
1520
1526#define STARPU_TASK_GET_NBUFFERS(task) ((unsigned)((task)->cl->nbuffers == STARPU_VARIABLE_NBUFFERS ? ((task)->nbuffers) : ((task)->cl->nbuffers)))
1527
1535#define STARPU_TASK_GET_HANDLE(task, i) (((task)->dyn_handles) ? (task)->dyn_handles[i] : (task)->handles[i])
1536
1543#define STARPU_TASK_GET_HANDLES(task) (((task)->dyn_handles) ? (task)->dyn_handles : (task)->handles)
1544
1552#define STARPU_TASK_SET_HANDLE(task, handle, i) \
1553 do { \
1554 if ((task)->dyn_handles) \
1555 (task)->dyn_handles[i] = handle; \
1556 else \
1557 (task)->handles[i] = handle; \
1558 } \
1559 while (0)
1560
1568#define STARPU_CODELET_GET_MODE(codelet, i) \
1569 (((codelet)->dyn_modes) ? (codelet)->dyn_modes[i] : (assert(i < STARPU_NMAXBUFS), (codelet)->modes[i]))
1570
1578#define STARPU_CODELET_SET_MODE(codelet, mode, i) \
1579 do { \
1580 if ((codelet)->dyn_modes) \
1581 (codelet)->dyn_modes[i] = mode; \
1582 else \
1583 (codelet)->modes[i] = mode; \
1584 } \
1585 while (0)
1586
1594#define STARPU_TASK_GET_MODE(task, i) \
1595 ((task)->cl->nbuffers == STARPU_VARIABLE_NBUFFERS || (task)->dyn_modes ? (((task)->dyn_modes) ? (task)->dyn_modes[i] : (task)->modes[i]) : STARPU_CODELET_GET_MODE((task)->cl, i))
1596
1604#define STARPU_TASK_SET_MODE(task, mode, i) \
1605 do { \
1606 if ((task)->cl->nbuffers == STARPU_VARIABLE_NBUFFERS || (task)->cl->nbuffers > STARPU_NMAXBUFS) \
1607 if ((task)->dyn_modes) \
1608 (task)->dyn_modes[i] = mode; \
1609 else \
1610 (task)->modes[i] = mode; \
1611 else \
1612 { \
1613 enum starpu_data_access_mode cl_mode = STARPU_CODELET_GET_MODE((task)->cl, i); \
1614 STARPU_ASSERT_MSG(cl_mode == mode, \
1615 "Task <%s> can't set its %d-th buffer mode to %d as the codelet it derives from uses %d", \
1616 (task)->cl->name, i, mode, cl_mode); \
1617 } \
1618 } \
1619 while (0)
1620
1628#define STARPU_CODELET_GET_NODE(codelet, i) (((codelet)->dyn_nodes) ? (codelet)->dyn_nodes[i] : (codelet)->nodes[i])
1629
1637#define STARPU_CODELET_SET_NODE(codelet, __node, i) \
1638 do { \
1639 if ((codelet)->dyn_nodes) \
1640 (codelet)->dyn_nodes[i] = __node; \
1641 else \
1642 (codelet)->nodes[i] = __node; \
1643 } \
1644 while (0)
1645
1655
1669
1682
1693
1704
1713
1732int starpu_task_submit(struct starpu_task *task) STARPU_WARN_UNUSED_RESULT;
1733
1734#ifdef STARPU_USE_FXT
1735static inline int starpu_task_submit_line(struct starpu_task *task, const char *file, int line)
1736{
1737 task->file = file;
1738 task->line = line;
1739 return starpu_task_submit(task);
1740}
1741#define starpu_task_submit(task) starpu_task_submit_line((task), __FILE__, __LINE__)
1742#endif
1743
1752int starpu_task_submit_nodeps(struct starpu_task *task) STARPU_WARN_UNUSED_RESULT;
1753
1760int starpu_task_submit_to_ctx(struct starpu_task *task, unsigned sched_ctx_id);
1761
1766int starpu_task_finished(struct starpu_task *task) STARPU_WARN_UNUSED_RESULT;
1767
1776int starpu_task_wait(struct starpu_task *task) STARPU_WARN_UNUSED_RESULT;
1777
1784int starpu_task_wait_array(struct starpu_task **tasks, unsigned nb_tasks) STARPU_WARN_UNUSED_RESULT;
1785
1793
1801
1807int starpu_task_wait_for_all_in_ctx(unsigned sched_ctx_id);
1808
1815int starpu_task_wait_for_n_submitted_in_ctx(unsigned sched_ctx_id, unsigned n);
1816
1822
1830
1836
1851void starpu_iteration_push(unsigned long iteration);
1852
1864
1872
1878
1886
1900
1905const char *starpu_task_get_model_name(struct starpu_task *task);
1906
1912const char *starpu_task_get_name(struct starpu_task *task);
1913
1919
1925void starpu_task_set_implementation(struct starpu_task *task, unsigned impl);
1926
1933
1939void starpu_create_sync_task(starpu_tag_t sync_tag, unsigned ndeps, starpu_tag_t *deps, void (*callback)(void *), void *callback_arg);
1940
1945void starpu_create_callback_task(void (*callback)(void *), void *callback_arg);
1946
1960void starpu_task_ft_prologue(void *check_ft);
1961
1978struct starpu_task *starpu_task_ft_create_retry(const struct starpu_task *meta_task, const struct starpu_task *template_task, void (*check_ft)(void *));
1979
1991
1997void starpu_task_ft_success(struct starpu_task *meta_task);
1998
2004void starpu_task_watchdog_set_hook(void (*hook)(void *), void *hook_arg);
2005
2010
2019
2028
2043struct starpu_transaction *starpu_transaction_open(int (*do_start_func)(void *buffer, void *arg), void *do_start_arg);
2044
2049void starpu_transaction_next_epoch(struct starpu_transaction *p_trs, void *do_start_arg);
2050
2055void starpu_transaction_close(struct starpu_transaction *p_trs);
2056
2059#ifdef __cplusplus
2060}
2061#endif
2062
2063#endif /* __STARPU_TASK_H__ */
void(* starpu_bubble_gen_dag_func_t)(struct starpu_task *t, void *arg)
Definition: starpu_task.h:218
int(* starpu_bubble_func_t)(struct starpu_task *t, void *arg)
Definition: starpu_task.h:212
starpu_task_bundle_t bundle
Definition: starpu_task.h:1337
unsigned specific_nodes
Definition: starpu_task.h:562
void(* callback_func)(void *)
Definition: starpu_task.h:914
starpu_max_fpga_func_t max_fpga_funcs[STARPU_MAXIMPLEMENTATIONS]
Definition: starpu_task.h:492
int max_parallelism
Definition: starpu_task.h:372
void * bubble_func_arg
Definition: starpu_task.h:1426
unsigned sched_ctx
Definition: starpu_task.h:1315
starpu_bubble_gen_dag_func_t bubble_gen_dag_func
Definition: starpu_task.h:1432
unsigned nb_termination_call_required
Definition: starpu_task.h:1444
unsigned synchronous
Definition: starpu_task.h:1104
int checked
Definition: starpu_task.h:652
int nbuffers
Definition: starpu_task.h:527
void * cl_ret
Definition: starpu_task.h:862
void * cl_arg
Definition: starpu_task.h:835
void(* epilogue_callback_func)(void *)
Definition: starpu_task.h:886
starpu_opencl_func_t opencl_func
Definition: starpu_task.h:393
double predicted_transfer
Definition: starpu_task.h:1377
struct starpu_perfmodel * model
Definition: starpu_task.h:592
unsigned long per_worker_stats[STARPU_NMAXWORKERS]
Definition: starpu_task.h:611
starpu_bubble_gen_dag_func_t bubble_gen_dag_func
Definition: starpu_task.h:512
int(* can_execute)(unsigned workerid, struct starpu_task *task, unsigned nimpl)
Definition: starpu_task.h:356
starpu_bubble_func_t bubble_func
Definition: starpu_task.h:507
char opencl_flags[STARPU_MAXIMPLEMENTATIONS]
Definition: starpu_task.h:475
unsigned use_tag
Definition: starpu_task.h:1081
unsigned callback_arg_free
Definition: starpu_task.h:1033
unsigned epilogue_callback_arg_free
Definition: starpu_task.h:1042
starpu_trs_epoch_t trs_epoch
Definition: starpu_task.h:990
starpu_cuda_func_t cuda_func
Definition: starpu_task.h:386
unsigned cl_arg_free
Definition: starpu_task.h:1012
unsigned destroy
Definition: starpu_task.h:1145
int * dyn_nodes
Definition: starpu_task.h:584
enum starpu_data_access_mode modes[STARPU_NMAXBUFS]
Definition: starpu_task.h:809
void * prologue_callback_arg
Definition: starpu_task.h:954
int hypervisor_tag
Definition: starpu_task.h:1323
int32_t where
Definition: starpu_task.h:717
uint32_t where
Definition: starpu_task.h:349
void(* callback_func)(void *)
Definition: starpu_task.h:639
int line
Definition: starpu_task.h:699
unsigned execute_on_a_specific_worker
Definition: starpu_task.h:1114
starpu_data_handle_t * dyn_handles
Definition: starpu_task.h:746
starpu_cpu_func_t cpu_funcs[STARPU_MAXIMPLEMENTATIONS]
Definition: starpu_task.h:410
void * starpu_private
Definition: starpu_task.h:1398
unsigned type
Definition: starpu_task.h:1299
unsigned prologue_callback_arg_free
Definition: starpu_task.h:1055
size_t cl_ret_size
Definition: starpu_task.h:870
enum starpu_data_access_mode modes[STARPU_NMAXBUFS]
Definition: starpu_task.h:538
unsigned workerid
Definition: starpu_task.h:1206
unsigned char mf_skip
Definition: starpu_task.h:1172
unsigned workerorder
Definition: starpu_task.h:1222
struct starpu_transaction * transaction
Definition: starpu_task.h:985
enum starpu_task_status status
Definition: starpu_task.h:1279
starpu_opencl_func_t opencl_funcs[STARPU_MAXIMPLEMENTATIONS]
Definition: starpu_task.h:468
unsigned workerids_len
Definition: starpu_task.h:1247
struct starpu_profiling_task_info * profiling_info
Definition: starpu_task.h:1346
const char * name
Definition: starpu_task.h:687
double flops
Definition: starpu_task.h:1360
starpu_tag_t tag_id
Definition: starpu_task.h:1000
void * prologue_callback_pop_arg
Definition: starpu_task.h:980
starpu_bubble_func_t bubble_func
Definition: starpu_task.h:1420
void ** dyn_interfaces
Definition: starpu_task.h:754
unsigned char failed
Definition: starpu_task.h:1179
unsigned cl_ret_free
Definition: starpu_task.h:1020
const char * file
Definition: starpu_task.h:693
unsigned possibly_parallel
Definition: starpu_task.h:1331
double predicted
Definition: starpu_task.h:1368
unsigned char * handles_sequential_consistency
Definition: starpu_task.h:819
unsigned char prefetched
Definition: starpu_task.h:1193
unsigned detach
Definition: starpu_task.h:1125
int priority
Definition: starpu_task.h:1270
unsigned char scheduled
Definition: starpu_task.h:1186
enum starpu_data_access_mode * dyn_modes
Definition: starpu_task.h:551
void * callback_arg
Definition: starpu_task.h:928
starpu_cuda_func_t cuda_funcs[STARPU_MAXIMPLEMENTATIONS]
Definition: starpu_task.h:425
int nbuffers
Definition: starpu_task.h:726
char cuda_flags[STARPU_MAXIMPLEMENTATIONS]
Definition: starpu_task.h:432
char hip_flags[STARPU_MAXIMPLEMENTATIONS]
Definition: starpu_task.h:454
void * bubble_gen_dag_func_arg
Definition: starpu_task.h:1438
struct starpu_omp_task * omp_task
Definition: starpu_task.h:1405
enum starpu_data_access_mode mode
Definition: starpu_task.h:666
int nodes[STARPU_NMAXBUFS]
Definition: starpu_task.h:571
unsigned color
Definition: starpu_task.h:1307
starpu_hip_func_t hip_funcs[STARPU_MAXIMPLEMENTATIONS]
Definition: starpu_task.h:447
const char * cpu_funcs_name[STARPU_MAXIMPLEMENTATIONS]
Definition: starpu_task.h:501
struct starpu_codelet * cl
Definition: starpu_task.h:708
int magic
Definition: starpu_task.h:1288
starpu_data_handle_t handle
Definition: starpu_task.h:665
uint32_t * workerids
Definition: starpu_task.h:1236
int flags
Definition: starpu_task.h:644
void(* prologue_callback_pop_func)(void *)
Definition: starpu_task.h:969
starpu_cpu_func_t cpu_func
Definition: starpu_task.h:379
unsigned color
Definition: starpu_task.h:625
unsigned long bubble_parent
Definition: starpu_task.h:1414
size_t cl_arg_size
Definition: starpu_task.h:852
void * sched_data
Definition: starpu_task.h:1453
const char * name
Definition: starpu_task.h:617
struct starpu_task * prev
Definition: starpu_task.h:1385
struct starpu_task * next
Definition: starpu_task.h:1392
void(* prologue_callback_func)(void *)
Definition: starpu_task.h:943
enum starpu_data_access_mode * dyn_modes
Definition: starpu_task.h:771
unsigned sequential_consistency
Definition: starpu_task.h:1093
unsigned prologue_callback_pop_arg_free
Definition: starpu_task.h:1069
void * epilogue_callback_arg
Definition: starpu_task.h:894
unsigned regenerate
Definition: starpu_task.h:1156
starpu_data_handle_t handles[STARPU_NMAXBUFS]
Definition: starpu_task.h:785
enum starpu_codelet_type type
Definition: starpu_task.h:365
unsigned no_submitorder
Definition: starpu_task.h:1165
struct starpu_perfmodel * energy_model
Definition: starpu_task.h:602
void * interfaces[STARPU_NMAXBUFS]
Definition: starpu_task.h:793
starpu_task_status
Definition: starpu_task.h:169
void(* starpu_cuda_func_t)(void **, void *)
Definition: starpu_task.h:191
void starpu_codelet_display_stats(struct starpu_codelet *cl)
int starpu_task_nready(void)
void(* starpu_cpu_func_t)(void **, void *)
Definition: starpu_task.h:186
int starpu_task_wait_array(struct starpu_task **tasks, unsigned nb_tasks)
int starpu_task_wait(struct starpu_task *task)
void starpu_do_schedule(void)
int starpu_task_submit_to_ctx(struct starpu_task *task, unsigned sched_ctx_id)
char * starpu_task_status_get_as_string(enum starpu_task_status status)
void starpu_codelet_init(struct starpu_codelet *cl)
struct starpu_task * starpu_task_create(void) STARPU_ATTRIBUTE_MALLOC
void starpu_task_ft_prologue(void *check_ft)
int starpu_task_wait_for_no_ready(void)
struct starpu_task * starpu_task_create_sync(starpu_data_handle_t handle, enum starpu_data_access_mode mode) STARPU_ATTRIBUTE_MALLOC
void(* starpu_opencl_func_t)(void **, void *)
Definition: starpu_task.h:201
int starpu_task_wait_for_n_submitted(unsigned n)
const char * starpu_task_get_name(struct starpu_task *task)
void starpu_task_ft_failed(struct starpu_task *task)
const char * starpu_task_get_model_name(struct starpu_task *task)
void starpu_set_limit_max_submitted_tasks(int limit_min)
void starpu_iteration_pop(void)
void starpu_create_sync_task(starpu_tag_t sync_tag, unsigned ndeps, starpu_tag_t *deps, void(*callback)(void *), void *callback_arg)
int starpu_task_get_current_data_node(unsigned i)
void starpu_set_limit_min_submitted_tasks(int limit_min)
void starpu_task_destroy(struct starpu_task *task)
void starpu_task_watchdog_set_hook(void(*hook)(void *), void *hook_arg)
void starpu_create_callback_task(void(*callback)(void *), void *callback_arg)
struct starpu_task * starpu_task_ft_create_retry(const struct starpu_task *meta_task, const struct starpu_task *template_task, void(*check_ft)(void *))
int starpu_task_submit_nodeps(struct starpu_task *task)
void starpu_task_set_implementation(struct starpu_task *task, unsigned impl)
unsigned starpu_task_get_implementation(struct starpu_task *task)
struct starpu_task * starpu_task_get_current(void)
int starpu_task_wait_for_n_submitted_in_ctx(unsigned sched_ctx_id, unsigned n)
starpu_codelet_type
Definition: starpu_task.h:150
int starpu_task_finished(struct starpu_task *task)
void starpu_task_ft_success(struct starpu_task *meta_task)
int starpu_task_wait_for_all(void)
void starpu_iteration_push(unsigned long iteration)
int starpu_task_submit(struct starpu_task *task)
struct starpu_codelet starpu_codelet_nop
#define STARPU_NMAXBUFS
Definition: starpu_config.h:238
void starpu_task_init(struct starpu_task *task)
int starpu_task_nsubmitted(void)
void(* starpu_max_fpga_func_t)(void **, void *)
Definition: starpu_task.h:206
void(* starpu_hip_func_t)(void **, void *)
Definition: starpu_task.h:196
void starpu_task_clean(struct starpu_task *task)
void starpu_task_set_destroy(struct starpu_task *task)
int starpu_task_wait_for_all_in_ctx(unsigned sched_ctx_id)
struct starpu_task * starpu_task_dup(struct starpu_task *task)
@ STARPU_TASK_BLOCKED_ON_DATA
Definition: starpu_task.h:179
@ STARPU_TASK_READY
Definition: starpu_task.h:174
@ STARPU_TASK_BLOCKED_ON_TAG
Definition: starpu_task.h:177
@ STARPU_TASK_STOPPED
Definition: starpu_task.h:180
@ STARPU_TASK_INIT
Definition: starpu_task.h:170
@ STARPU_TASK_BLOCKED_ON_TASK
Definition: starpu_task.h:178
@ STARPU_TASK_RUNNING
Definition: starpu_task.h:175
@ STARPU_TASK_BLOCKED
Definition: starpu_task.h:173
@ STARPU_TASK_FINISHED
Definition: starpu_task.h:176
@ STARPU_FORKJOIN
Definition: starpu_task.h:160
@ STARPU_SPMD
Definition: starpu_task.h:154
@ STARPU_SEQ
Definition: starpu_task.h:151
Definition: starpu_task.h:334
Definition: starpu_task.h:664
Definition: starpu_task.h:679
starpu_data_access_mode
Definition: starpu_data.h:55
struct _starpu_data_state * starpu_data_handle_t
Definition: starpu_data.h:44
uint64_t starpu_tag_t
Definition: starpu_task_dep.h:134
Definition: starpu_perfmodel.h:186
Definition: starpu_profiling.h:54
#define STARPU_MAXIMPLEMENTATIONS
Definition: starpu_config.h:312
struct _starpu_task_bundle * starpu_task_bundle_t
Definition: starpu_task_bundle.h:39
#define STARPU_ATTRIBUTE_MALLOC
Definition: starpu_util.h:129
void starpu_transaction_close(struct starpu_transaction *p_trs)
struct starpu_transaction * starpu_transaction_open(int(*do_start_func)(void *buffer, void *arg), void *do_start_arg)
void starpu_transaction_next_epoch(struct starpu_transaction *p_trs, void *do_start_arg)
#define STARPU_NMAXWORKERS
Definition: starpu_config.h:296