StarPU Handbook - StarPU Performances
Loading...
Searching...
No Matches
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
46#define STARPU_NOWHERE ((1ULL) << 0)
47
51#define STARPU_WORKER_TO_MASK(worker_archtype) (1ULL << (worker_archtype + 1))
52
58#define STARPU_CPU STARPU_WORKER_TO_MASK(STARPU_CPU_WORKER)
59
65#define STARPU_CUDA STARPU_WORKER_TO_MASK(STARPU_CUDA_WORKER)
66
72#define STARPU_HIP STARPU_WORKER_TO_MASK(STARPU_HIP_WORKER)
73
79#define STARPU_OPENCL STARPU_WORKER_TO_MASK(STARPU_OPENCL_WORKER)
80
86#define STARPU_MAX_FPGA STARPU_WORKER_TO_MASK(STARPU_MAX_FPGA_WORKER)
87
93#define STARPU_MPI_MS STARPU_WORKER_TO_MASK(STARPU_MPI_MS_WORKER)
94
100#define STARPU_TCPIP_MS STARPU_WORKER_TO_MASK(STARPU_TCPIP_MS_WORKER)
101
106#define STARPU_CODELET_SIMGRID_EXECUTE (1 << 0)
107
113#define STARPU_CODELET_SIMGRID_EXECUTE_AND_INJECT (1 << 1)
114
119#define STARPU_CODELET_NOPLANS (1 << 2)
120
126#define STARPU_CUDA_ASYNC (1 << 0)
127
132#define STARPU_HIP_ASYNC (1 << 0)
133
139#define STARPU_OPENCL_ASYNC (1 << 0)
140
144#define STARPU_MAIN_RAM 0
145
168
186
190typedef void (*starpu_cpu_func_t)(void **, void *);
191
195typedef void (*starpu_cuda_func_t)(void **, void *);
196
200typedef void (*starpu_hip_func_t)(void **, void *);
201
205typedef void (*starpu_opencl_func_t)(void **, void *);
206
210typedef void (*starpu_max_fpga_func_t)(void **, void *);
211
216typedef int (*starpu_bubble_func_t)(struct starpu_task *t, void *arg);
217
222typedef void (*starpu_bubble_gen_dag_func_t)(struct starpu_task *t, void *arg);
223
231#define STARPU_MULTIPLE_CPU_IMPLEMENTATIONS ((starpu_cpu_func_t)-1)
232
240#define STARPU_MULTIPLE_CUDA_IMPLEMENTATIONS ((starpu_cuda_func_t)-1)
241
249#define STARPU_MULTIPLE_HIP_IMPLEMENTATIONS ((starpu_hip_func_t)-1)
250
258#define STARPU_MULTIPLE_OPENCL_IMPLEMENTATIONS ((starpu_opencl_func_t)-1)
259
265#define STARPU_VARIABLE_NBUFFERS (-1)
266
272#define STARPU_SPECIFIC_NODE_LOCAL (-1)
273
279#define STARPU_SPECIFIC_NODE_CPU (-2)
280
285#define STARPU_SPECIFIC_NODE_SLOW (-3)
286
291#define STARPU_SPECIFIC_NODE_FAST (-4)
292
298#define STARPU_SPECIFIC_NODE_LOCAL_OR_CPU (-5)
299
306#define STARPU_SPECIFIC_NODE_NONE (-6)
307
308struct starpu_transaction;
309struct _starpu_trs_epoch;
310typedef struct _starpu_trs_epoch *starpu_trs_epoch_t;
311struct starpu_task;
312
338{
353 uint32_t where;
354
360 int (*can_execute)(unsigned workerid, struct starpu_task *task, unsigned nimpl);
361
370
377
383 starpu_cpu_func_t cpu_func STARPU_DEPRECATED;
384
390 starpu_cuda_func_t cuda_func STARPU_DEPRECATED;
391
398
415
430
437
452
459
473
480
497
506
512
517
532
543
556
565
581
594
602
612
621
626 const char *name;
627
634 unsigned color;
635
648 void (*callback_func)(void *);
649
653 int flags;
654
655 struct starpu_perf_counter_sample *perf_counter_sample;
656 struct starpu_perf_counter_sample_cl_values *perf_counter_values;
657
662};
663
668
677
688{
696 const char *name;
697
702 const char *file;
703
708 int line;
709
718
726 int32_t where;
727
736
758
767
785
799
807
823
833
856 void *cl_arg;
874
883 void *cl_ret;
884
892
907 void (*epilogue_callback_func)(void *);
908
916
935 void (*callback_func)(void *);
936
950
964 void (*prologue_callback_func)(void *);
965
976
991
1002
1006 struct starpu_transaction *transaction;
1007
1011 starpu_trs_epoch_t trs_epoch;
1012
1022
1033 unsigned cl_arg_free : 1;
1034
1041 unsigned cl_ret_free : 1;
1042
1054 unsigned callback_arg_free : 1;
1055
1064
1077
1091
1102 unsigned use_tag : 1;
1103
1115
1125 unsigned synchronous : 1;
1126
1136
1146 unsigned detach : 1;
1147
1166 unsigned destroy : 1;
1167
1177 unsigned regenerate : 1;
1178
1186 unsigned no_submitorder : 1;
1187
1193 unsigned char mf_skip;
1194
1200 unsigned char failed;
1201
1207 unsigned char scheduled;
1208
1214 unsigned char prefetched;
1215
1227 unsigned workerid;
1228
1243 unsigned workerorder;
1244
1257 uint32_t *workerids;
1258
1269
1292
1301
1310
1320 unsigned type;
1321
1328 unsigned color;
1329
1336 unsigned sched_ctx;
1337
1345
1353
1359
1368
1381 double flops;
1390
1399 double predicted_start;
1400
1407
1414
1420
1421#ifdef STARPU_OPENMP
1426 struct starpu_omp_task *omp_task;
1427#else
1428 void *omp_task;
1429#endif
1430
1435 unsigned long bubble_parent;
1436
1442
1448
1454
1460
1466
1475};
1476
1480#define STARPU_TASK_TYPE_NORMAL 0
1481
1485#define STARPU_TASK_TYPE_INTERNAL (1 << 0)
1486
1490#define STARPU_TASK_TYPE_DATA_ACQUIRE (1 << 1)
1491
1492/* Note: remember to update starpu_task_init and starpu_task_ft_create_retry
1493 * as well */
1499#define STARPU_TASK_INITIALIZER \
1500 { \
1501 .cl = NULL, \
1502 .where = -1, \
1503 .cl_arg = NULL, \
1504 .cl_arg_size = 0, \
1505 .cl_ret = NULL, \
1506 .cl_ret_size = 0, \
1507 .callback_func = NULL, \
1508 .callback_arg = NULL, \
1509 .epilogue_callback_func = NULL, \
1510 .epilogue_callback_arg = NULL, \
1511 .priority = STARPU_DEFAULT_PRIO, \
1512 .use_tag = 0, \
1513 .sequential_consistency = 1, \
1514 .synchronous = 0, \
1515 .execute_on_a_specific_worker = 0, \
1516 .workerorder = 0, \
1517 .bundle = NULL, \
1518 .detach = 1, \
1519 .destroy = 0, \
1520 .regenerate = 0, \
1521 .status = STARPU_TASK_INIT, \
1522 .profiling_info = NULL, \
1523 .predicted = NAN, \
1524 .predicted_transfer = NAN, \
1525 .predicted_start = NAN, \
1526 .starpu_private = NULL, \
1527 .magic = 42, \
1528 .type = 0, \
1529 .color = 0, \
1530 .sched_ctx = STARPU_NMAX_SCHED_CTXS, \
1531 .hypervisor_tag = 0, \
1532 .flops = 0.0, \
1533 .scheduled = 0, \
1534 .prefetched = 0, \
1535 .dyn_handles = NULL, \
1536 .dyn_interfaces = NULL, \
1537 .dyn_modes = NULL, \
1538 .name = NULL, \
1539 .possibly_parallel = 0 \
1540 }
1541
1547#define STARPU_TASK_GET_NBUFFERS(task) ((unsigned)((task)->cl->nbuffers == STARPU_VARIABLE_NBUFFERS ? ((task)->nbuffers) : ((task)->cl->nbuffers)))
1548
1556#define STARPU_TASK_GET_HANDLE(task, i) (((task)->dyn_handles) ? (task)->dyn_handles[i] : (task)->handles[i])
1557
1564#define STARPU_TASK_GET_HANDLES(task) (((task)->dyn_handles) ? (task)->dyn_handles : (task)->handles)
1565
1573#define STARPU_TASK_SET_HANDLE(task, handle, i) \
1574 do { \
1575 if ((task)->dyn_handles) \
1576 (task)->dyn_handles[i] = handle; \
1577 else \
1578 (task)->handles[i] = handle; \
1579 } \
1580 while (0)
1581
1589#define STARPU_CODELET_GET_MODE(codelet, i) \
1590 (((codelet)->dyn_modes) ? (codelet)->dyn_modes[i] : (assert(i < STARPU_NMAXBUFS), (codelet)->modes[i]))
1591
1599#define STARPU_CODELET_SET_MODE(codelet, mode, i) \
1600 do { \
1601 if ((codelet)->dyn_modes) \
1602 (codelet)->dyn_modes[i] = mode; \
1603 else \
1604 (codelet)->modes[i] = mode; \
1605 } \
1606 while (0)
1607
1615#define STARPU_TASK_GET_MODE(task, i) \
1616 ((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))
1617
1625#define STARPU_TASK_SET_MODE(task, mode, i) \
1626 do { \
1627 if ((task)->cl->nbuffers == STARPU_VARIABLE_NBUFFERS || (task)->cl->nbuffers > STARPU_NMAXBUFS) \
1628 if ((task)->dyn_modes) \
1629 (task)->dyn_modes[i] = mode; \
1630 else \
1631 (task)->modes[i] = mode; \
1632 else \
1633 { \
1634 enum starpu_data_access_mode cl_mode = STARPU_CODELET_GET_MODE((task)->cl, i); \
1635 STARPU_ASSERT_MSG(cl_mode == mode, \
1636 "Task <%s> can't set its %d-th buffer mode to %d as the codelet it derives from uses %d", \
1637 (task)->cl->name, i, mode, cl_mode); \
1638 } \
1639 } \
1640 while (0)
1641
1649#define STARPU_CODELET_GET_NODE(codelet, i) (((codelet)->dyn_nodes) ? (codelet)->dyn_nodes[i] : (codelet)->nodes[i])
1650
1658#define STARPU_CODELET_SET_NODE(codelet, __node, i) \
1659 do { \
1660 if ((codelet)->dyn_nodes) \
1661 (codelet)->dyn_nodes[i] = __node; \
1662 else \
1663 (codelet)->nodes[i] = __node; \
1664 } \
1665 while (0)
1666
1676
1690
1703
1714
1725
1734
1753int starpu_task_submit(struct starpu_task *task) STARPU_WARN_UNUSED_RESULT;
1754
1755#ifdef STARPU_USE_FXT
1756static inline int starpu_task_submit_line(struct starpu_task *task, const char *file, int line)
1757{
1758 task->file = file;
1759 task->line = line;
1760 return starpu_task_submit(task);
1761}
1762#define starpu_task_submit(task) starpu_task_submit_line((task), __FILE__, __LINE__)
1763#endif
1764
1773int starpu_task_submit_nodeps(struct starpu_task *task) STARPU_WARN_UNUSED_RESULT;
1774
1781int starpu_task_submit_to_ctx(struct starpu_task *task, unsigned sched_ctx_id);
1782
1787int starpu_task_finished(struct starpu_task *task) STARPU_WARN_UNUSED_RESULT;
1788
1797int starpu_task_wait(struct starpu_task *task) STARPU_WARN_UNUSED_RESULT;
1798
1805int starpu_task_wait_array(struct starpu_task **tasks, unsigned nb_tasks) STARPU_WARN_UNUSED_RESULT;
1806
1814
1822
1828int starpu_task_wait_for_all_in_ctx(unsigned sched_ctx_id);
1829
1836int starpu_task_wait_for_n_submitted_in_ctx(unsigned sched_ctx_id, unsigned n);
1837
1843
1851
1857
1872void starpu_iteration_push(unsigned long iteration);
1873
1885
1893
1899
1907
1921
1926const char *starpu_task_get_model_name(struct starpu_task *task);
1927
1933const char *starpu_task_get_name(struct starpu_task *task);
1934
1940
1946void starpu_task_set_implementation(struct starpu_task *task, unsigned impl);
1947
1954
1960void starpu_create_sync_task(starpu_tag_t sync_tag, unsigned ndeps, starpu_tag_t *deps, void (*callback)(void *), void *callback_arg);
1961
1966void starpu_create_callback_task(void (*callback)(void *), void *callback_arg);
1967
1981void starpu_task_ft_prologue(void *check_ft);
1982
1999struct starpu_task *starpu_task_ft_create_retry(const struct starpu_task *meta_task, const struct starpu_task *template_task, void (*check_ft)(void *));
2000
2012
2018void starpu_task_ft_success(struct starpu_task *meta_task);
2019
2025void starpu_task_watchdog_set_hook(void (*hook)(void *), void *hook_arg);
2026
2031
2040
2049
2064struct starpu_transaction *starpu_transaction_open(int (*do_start_func)(void *buffer, void *arg), void *do_start_arg);
2065
2070void starpu_transaction_next_epoch(struct starpu_transaction *p_trs, void *do_start_arg);
2071
2076void starpu_transaction_close(struct starpu_transaction *p_trs);
2077
2080#ifdef __cplusplus
2081}
2082#endif
2083
2084#endif /* __STARPU_TASK_H__ */
void(* starpu_bubble_gen_dag_func_t)(struct starpu_task *t, void *arg)
Definition starpu_task.h:222
int(* starpu_bubble_func_t)(struct starpu_task *t, void *arg)
Definition starpu_task.h:216
starpu_task_bundle_t bundle
Definition starpu_task.h:1358
unsigned specific_nodes
Definition starpu_task.h:564
void(* callback_func)(void *)
Definition starpu_task.h:935
starpu_max_fpga_func_t max_fpga_funcs[STARPU_MAXIMPLEMENTATIONS]
Definition starpu_task.h:496
int max_parallelism
Definition starpu_task.h:376
void * bubble_func_arg
Definition starpu_task.h:1447
unsigned sched_ctx
Definition starpu_task.h:1336
starpu_bubble_gen_dag_func_t bubble_gen_dag_func
Definition starpu_task.h:1453
unsigned nb_termination_call_required
Definition starpu_task.h:1465
unsigned synchronous
Definition starpu_task.h:1125
int checked
Definition starpu_task.h:661
int nbuffers
Definition starpu_task.h:531
void * cl_ret
Definition starpu_task.h:883
void * cl_arg
Definition starpu_task.h:856
void(* epilogue_callback_func)(void *)
Definition starpu_task.h:907
starpu_opencl_func_t opencl_func
Definition starpu_task.h:397
double predicted_transfer
Definition starpu_task.h:1398
struct starpu_perfmodel * model
Definition starpu_task.h:601
unsigned long per_worker_stats[STARPU_NMAXWORKERS]
Definition starpu_task.h:620
starpu_bubble_gen_dag_func_t bubble_gen_dag_func
Definition starpu_task.h:516
int(* can_execute)(unsigned workerid, struct starpu_task *task, unsigned nimpl)
Definition starpu_task.h:360
starpu_bubble_func_t bubble_func
Definition starpu_task.h:511
char opencl_flags[STARPU_MAXIMPLEMENTATIONS]
Definition starpu_task.h:479
unsigned use_tag
Definition starpu_task.h:1102
unsigned callback_arg_free
Definition starpu_task.h:1054
unsigned epilogue_callback_arg_free
Definition starpu_task.h:1063
starpu_trs_epoch_t trs_epoch
Definition starpu_task.h:1011
starpu_cuda_func_t cuda_func
Definition starpu_task.h:390
unsigned cl_arg_free
Definition starpu_task.h:1033
unsigned destroy
Definition starpu_task.h:1166
int * dyn_nodes
Definition starpu_task.h:593
enum starpu_data_access_mode modes[STARPU_NMAXBUFS]
Definition starpu_task.h:822
void * prologue_callback_arg
Definition starpu_task.h:975
int hypervisor_tag
Definition starpu_task.h:1344
int32_t where
Definition starpu_task.h:726
uint32_t where
Definition starpu_task.h:353
void(* callback_func)(void *)
Definition starpu_task.h:648
int line
Definition starpu_task.h:708
unsigned execute_on_a_specific_worker
Definition starpu_task.h:1135
starpu_data_handle_t * dyn_handles
Definition starpu_task.h:757
starpu_cpu_func_t cpu_funcs[STARPU_MAXIMPLEMENTATIONS]
Definition starpu_task.h:414
void * starpu_private
Definition starpu_task.h:1419
unsigned type
Definition starpu_task.h:1320
unsigned prologue_callback_arg_free
Definition starpu_task.h:1076
size_t cl_ret_size
Definition starpu_task.h:891
enum starpu_data_access_mode modes[STARPU_NMAXBUFS]
Definition starpu_task.h:542
unsigned workerid
Definition starpu_task.h:1227
unsigned char mf_skip
Definition starpu_task.h:1193
unsigned workerorder
Definition starpu_task.h:1243
struct starpu_transaction * transaction
Definition starpu_task.h:1006
enum starpu_task_status status
Definition starpu_task.h:1300
starpu_opencl_func_t opencl_funcs[STARPU_MAXIMPLEMENTATIONS]
Definition starpu_task.h:472
unsigned workerids_len
Definition starpu_task.h:1268
struct starpu_profiling_task_info * profiling_info
Definition starpu_task.h:1367
const char * name
Definition starpu_task.h:696
double flops
Definition starpu_task.h:1381
starpu_tag_t tag_id
Definition starpu_task.h:1021
void * prologue_callback_pop_arg
Definition starpu_task.h:1001
starpu_bubble_func_t bubble_func
Definition starpu_task.h:1441
void ** dyn_interfaces
Definition starpu_task.h:766
unsigned char failed
Definition starpu_task.h:1200
unsigned cl_ret_free
Definition starpu_task.h:1041
const char * file
Definition starpu_task.h:702
unsigned possibly_parallel
Definition starpu_task.h:1352
double predicted
Definition starpu_task.h:1389
unsigned char * handles_sequential_consistency
Definition starpu_task.h:832
unsigned char prefetched
Definition starpu_task.h:1214
unsigned detach
Definition starpu_task.h:1146
int priority
Definition starpu_task.h:1291
unsigned char scheduled
Definition starpu_task.h:1207
enum starpu_data_access_mode * dyn_modes
Definition starpu_task.h:555
void * callback_arg
Definition starpu_task.h:949
starpu_cuda_func_t cuda_funcs[STARPU_MAXIMPLEMENTATIONS]
Definition starpu_task.h:429
int nbuffers
Definition starpu_task.h:735
char cuda_flags[STARPU_MAXIMPLEMENTATIONS]
Definition starpu_task.h:436
char hip_flags[STARPU_MAXIMPLEMENTATIONS]
Definition starpu_task.h:458
void * bubble_gen_dag_func_arg
Definition starpu_task.h:1459
struct starpu_omp_task * omp_task
Definition starpu_task.h:1426
enum starpu_data_access_mode mode
Definition starpu_task.h:675
int nodes[STARPU_NMAXBUFS]
Definition starpu_task.h:580
unsigned color
Definition starpu_task.h:1328
starpu_hip_func_t hip_funcs[STARPU_MAXIMPLEMENTATIONS]
Definition starpu_task.h:451
const char * cpu_funcs_name[STARPU_MAXIMPLEMENTATIONS]
Definition starpu_task.h:505
struct starpu_codelet * cl
Definition starpu_task.h:717
int magic
Definition starpu_task.h:1309
starpu_data_handle_t handle
Definition starpu_task.h:674
uint32_t * workerids
Definition starpu_task.h:1257
int flags
Definition starpu_task.h:653
void(* prologue_callback_pop_func)(void *)
Definition starpu_task.h:990
starpu_cpu_func_t cpu_func
Definition starpu_task.h:383
unsigned color
Definition starpu_task.h:634
unsigned long bubble_parent
Definition starpu_task.h:1435
size_t cl_arg_size
Definition starpu_task.h:873
void * sched_data
Definition starpu_task.h:1474
const char * name
Definition starpu_task.h:626
struct starpu_task * prev
Definition starpu_task.h:1406
struct starpu_task * next
Definition starpu_task.h:1413
void(* prologue_callback_func)(void *)
Definition starpu_task.h:964
enum starpu_data_access_mode * dyn_modes
Definition starpu_task.h:784
unsigned sequential_consistency
Definition starpu_task.h:1114
unsigned prologue_callback_pop_arg_free
Definition starpu_task.h:1090
void * epilogue_callback_arg
Definition starpu_task.h:915
unsigned regenerate
Definition starpu_task.h:1177
starpu_data_handle_t handles[STARPU_NMAXBUFS]
Definition starpu_task.h:798
enum starpu_codelet_type type
Definition starpu_task.h:369
unsigned no_submitorder
Definition starpu_task.h:1186
struct starpu_perfmodel * energy_model
Definition starpu_task.h:611
void * interfaces[STARPU_NMAXBUFS]
Definition starpu_task.h:806
starpu_task_status
Definition starpu_task.h:173
void(* starpu_cuda_func_t)(void **, void *)
Definition starpu_task.h:195
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:190
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:205
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:151
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:254
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:210
void(* starpu_hip_func_t)(void **, void *)
Definition starpu_task.h:200
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:183
@ STARPU_TASK_READY
Definition starpu_task.h:178
@ STARPU_TASK_BLOCKED_ON_TAG
Definition starpu_task.h:181
@ STARPU_TASK_STOPPED
Definition starpu_task.h:184
@ STARPU_TASK_BLOCKED_ON_TASK
Definition starpu_task.h:182
@ STARPU_TASK_RUNNING
Definition starpu_task.h:179
@ STARPU_TASK_BLOCKED
Definition starpu_task.h:177
@ STARPU_TASK_FINISHED
Definition starpu_task.h:180
@ STARPU_FORKJOIN
Definition starpu_task.h:161
@ STARPU_SPMD
Definition starpu_task.h:155
@ STARPU_SEQ
Definition starpu_task.h:152
Definition starpu_task.h:338
Definition starpu_task.h:673
Definition starpu_task.h:688
starpu_data_access_mode
Definition starpu_data.h:56
struct _starpu_data_state * starpu_data_handle_t
Definition starpu_data.h:45
uint64_t starpu_tag_t
Definition starpu_task_dep.h:134
Definition starpu_perfmodel.h:192
Definition starpu_profiling.h:54
#define STARPU_MAXIMPLEMENTATIONS
Definition starpu_config.h:328
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:312