Loading...
Searching...
No Matches
starpu_task.h
Go to the documentation of this file.
/* StarPU --- Runtime system for heterogeneous multicore architectures.
*
* Copyright (C) 2009-2025 University of Bordeaux, CNRS (LaBRI UMR 5800), Inria
* Copyright (C) 2011 Télécom Sud Paris
* Copyright (C) 2016 Uppsala University
*
* StarPU is free software; you can redistribute it and/or modify
* it under the terms of the GNU Lesser General Public License as published by
* the Free Software Foundation; either version 2.1 of the License, or (at
* your option) any later version.
*
* StarPU is distributed in the hope that it will be useful, but
* WITHOUT ANY WARRANTY; without even the implied warranty of
* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.
*
* See the GNU Lesser General Public License in COPYING.LGPL for more details.
*/
#include <starpu.h>
#ifndef __STARPU_TASK_H__
#define __STARPU_TASK_H__
#include <errno.h>
#include <assert.h>
#ifdef STARPU_USE_CUDA
#include <cuda.h>
#endif
#ifdef __cplusplus
extern "C" {
#endif
#define STARPU_NOWHERE ((1ULL) << 0)
#define STARPU_WORKER_TO_MASK(worker_archtype) (1ULL << (worker_archtype + 1))
#define STARPU_CPU STARPU_WORKER_TO_MASK(STARPU_CPU_WORKER)
#define STARPU_CUDA STARPU_WORKER_TO_MASK(STARPU_CUDA_WORKER)
#define STARPU_HIP STARPU_WORKER_TO_MASK(STARPU_HIP_WORKER)
#define STARPU_OPENCL STARPU_WORKER_TO_MASK(STARPU_OPENCL_WORKER)
#define STARPU_MAX_FPGA STARPU_WORKER_TO_MASK(STARPU_MAX_FPGA_WORKER)
#define STARPU_MPI_MS STARPU_WORKER_TO_MASK(STARPU_MPI_MS_WORKER)
#define STARPU_TCPIP_MS STARPU_WORKER_TO_MASK(STARPU_TCPIP_MS_WORKER)
#define STARPU_CODELET_SIMGRID_EXECUTE (1 << 0)
#define STARPU_CODELET_SIMGRID_EXECUTE_AND_INJECT (1 << 1)
#define STARPU_CODELET_NOPLANS (1 << 2)
#define STARPU_CUDA_ASYNC (1 << 0)
#define STARPU_HIP_ASYNC (1 << 0)
#define STARPU_OPENCL_ASYNC (1 << 0)
#define STARPU_MAIN_RAM 0
enum starpu_codelet_type
{
STARPU_SEQ = 0,
STARPU_SPMD,
STARPU_FORKJOIN
};
enum starpu_task_status
{
STARPU_TASK_INIT,
#define STARPU_TASK_INIT 0
#define STARPU_TASK_INVALID STARPU_TASK_INIT
STARPU_TASK_BLOCKED,
STARPU_TASK_READY,
STARPU_TASK_RUNNING,
STARPU_TASK_FINISHED,
STARPU_TASK_BLOCKED_ON_TAG,
STARPU_TASK_BLOCKED_ON_TASK,
STARPU_TASK_BLOCKED_ON_DATA,
STARPU_TASK_STOPPED
};
typedef void (*starpu_cpu_func_t)(void **, void *);
typedef void (*starpu_cuda_func_t)(void **, void *);
typedef void (*starpu_hip_func_t)(void **, void *);
typedef void (*starpu_opencl_func_t)(void **, void *);
typedef void (*starpu_max_fpga_func_t)(void **, void *);
typedef int (*starpu_bubble_func_t)(struct starpu_task *t, void *arg);
typedef void (*starpu_bubble_gen_dag_func_t)(struct starpu_task *t, void *arg);
#define STARPU_MULTIPLE_CPU_IMPLEMENTATIONS ((starpu_cpu_func_t)-1)
#define STARPU_MULTIPLE_CUDA_IMPLEMENTATIONS ((starpu_cuda_func_t)-1)
#define STARPU_MULTIPLE_HIP_IMPLEMENTATIONS ((starpu_hip_func_t)-1)
#define STARPU_MULTIPLE_OPENCL_IMPLEMENTATIONS ((starpu_opencl_func_t)-1)
#define STARPU_VARIABLE_NBUFFERS (-1)
#define STARPU_SPECIFIC_NODE_LOCAL (-1)
#define STARPU_SPECIFIC_NODE_CPU (-2)
#define STARPU_SPECIFIC_NODE_SLOW (-3)
#define STARPU_SPECIFIC_NODE_FAST (-4)
#define STARPU_SPECIFIC_NODE_LOCAL_OR_CPU (-5)
#define STARPU_SPECIFIC_NODE_NONE (-6)
struct starpu_transaction;
struct _starpu_trs_epoch;
typedef struct _starpu_trs_epoch *starpu_trs_epoch_t;
struct starpu_task;
struct starpu_codelet
{
uint32_t where;
int (*can_execute)(unsigned workerid, struct starpu_task *task, unsigned nimpl);
enum starpu_codelet_type type;
int max_parallelism;
starpu_cpu_func_t cpu_func STARPU_DEPRECATED;
starpu_cuda_func_t cuda_func STARPU_DEPRECATED;
starpu_opencl_func_t opencl_func STARPU_DEPRECATED;
starpu_cpu_func_t cpu_funcs[STARPU_MAXIMPLEMENTATIONS];
starpu_cuda_func_t cuda_funcs[STARPU_MAXIMPLEMENTATIONS];
char cuda_flags[STARPU_MAXIMPLEMENTATIONS];
starpu_hip_func_t hip_funcs[STARPU_MAXIMPLEMENTATIONS];
char hip_flags[STARPU_MAXIMPLEMENTATIONS];
starpu_opencl_func_t opencl_funcs[STARPU_MAXIMPLEMENTATIONS];
char opencl_flags[STARPU_MAXIMPLEMENTATIONS];
starpu_max_fpga_func_t max_fpga_funcs[STARPU_MAXIMPLEMENTATIONS];
const char *cpu_funcs_name[STARPU_MAXIMPLEMENTATIONS];
starpu_bubble_func_t bubble_func;
starpu_bubble_gen_dag_func_t bubble_gen_dag_func;
int nbuffers;
enum starpu_data_access_mode modes[STARPU_NMAXBUFS];
enum starpu_data_access_mode *dyn_modes;
unsigned specific_nodes;
int nodes[STARPU_NMAXBUFS];
int *dyn_nodes;
struct starpu_perfmodel *model;
struct starpu_perfmodel *energy_model;
unsigned long per_worker_stats[STARPU_NMAXWORKERS];
const char *name;
unsigned color;
void (*callback_func)(void *);
int flags;
struct starpu_perf_counter_sample *perf_counter_sample;
struct starpu_perf_counter_sample_cl_values *perf_counter_values;
int checked;
};
extern struct starpu_codelet starpu_codelet_nop;
struct starpu_data_descr
{
starpu_data_handle_t handle;
enum starpu_data_access_mode mode;
};
struct starpu_task
{
const char *name;
const char *file;
int line;
struct starpu_codelet *cl;
int32_t where;
int nbuffers;
starpu_data_handle_t *dyn_handles;
void **dyn_interfaces;
enum starpu_data_access_mode *dyn_modes;
starpu_data_handle_t handles[STARPU_NMAXBUFS];
void *interfaces[STARPU_NMAXBUFS];
enum starpu_data_access_mode modes[STARPU_NMAXBUFS];
unsigned char *handles_sequential_consistency;
void *cl_arg;
size_t cl_arg_size;
void *cl_ret;
size_t cl_ret_size;
void (*epilogue_callback_func)(void *);
void *epilogue_callback_arg;
void (*callback_func)(void *);
void *callback_arg;
void (*prologue_callback_func)(void *);
void *prologue_callback_arg;
void (*prologue_callback_pop_func)(void *);
void *prologue_callback_pop_arg;
struct starpu_transaction *transaction;
starpu_trs_epoch_t trs_epoch;
starpu_tag_t tag_id;
unsigned cl_arg_free : 1;
unsigned cl_ret_free : 1;
unsigned callback_arg_free : 1;
unsigned epilogue_callback_arg_free : 1;
unsigned prologue_callback_arg_free : 1;
unsigned prologue_callback_pop_arg_free : 1;
unsigned use_tag : 1;
unsigned sequential_consistency : 1;
unsigned synchronous : 1;
unsigned execute_on_a_specific_worker : 1;
unsigned detach : 1;
unsigned destroy : 1;
unsigned regenerate : 1;
unsigned no_submitorder : 1;
unsigned char mf_skip;
unsigned char failed;
unsigned char scheduled;
unsigned char prefetched;
unsigned workerid;
unsigned workerorder;
uint32_t *workerids;
unsigned workerids_len;
int priority;
enum starpu_task_status status;
int magic;
unsigned type;
unsigned color;
unsigned sched_ctx;
int hypervisor_tag;
unsigned possibly_parallel;
starpu_task_bundle_t bundle;
struct starpu_profiling_task_info *profiling_info;
double flops;
double predicted;
double predicted_transfer;
double predicted_start;
struct starpu_task *prev;
struct starpu_task *next;
void *starpu_private;
#ifdef STARPU_OPENMP
struct starpu_omp_task *omp_task;
#else
void *omp_task;
#endif
unsigned long bubble_parent;
starpu_bubble_func_t bubble_func;
void *bubble_func_arg;
starpu_bubble_gen_dag_func_t bubble_gen_dag_func;
void *bubble_gen_dag_func_arg;
unsigned nb_termination_call_required;
void *sched_data;
};
#define STARPU_TASK_TYPE_NORMAL 0
#define STARPU_TASK_TYPE_INTERNAL (1 << 0)
#define STARPU_TASK_TYPE_DATA_ACQUIRE (1 << 1)
/* Note: remember to update starpu_task_init and starpu_task_ft_create_retry
* as well */
#define STARPU_TASK_INITIALIZER \
{ \
.cl = NULL, \
.where = -1, \
.cl_arg = NULL, \
.cl_arg_size = 0, \
.cl_ret = NULL, \
.cl_ret_size = 0, \
.callback_func = NULL, \
.callback_arg = NULL, \
.epilogue_callback_func = NULL, \
.epilogue_callback_arg = NULL, \
.priority = STARPU_DEFAULT_PRIO, \
.use_tag = 0, \
.sequential_consistency = 1, \
.synchronous = 0, \
.execute_on_a_specific_worker = 0, \
.workerorder = 0, \
.bundle = NULL, \
.detach = 1, \
.destroy = 0, \
.regenerate = 0, \
.status = STARPU_TASK_INIT, \
.profiling_info = NULL, \
.predicted = NAN, \
.predicted_transfer = NAN, \
.predicted_start = NAN, \
.starpu_private = NULL, \
.magic = 42, \
.type = 0, \
.color = 0, \
.sched_ctx = STARPU_NMAX_SCHED_CTXS, \
.hypervisor_tag = 0, \
.flops = 0.0, \
.scheduled = 0, \
.prefetched = 0, \
.dyn_handles = NULL, \
.dyn_interfaces = NULL, \
.dyn_modes = NULL, \
.name = NULL, \
.possibly_parallel = 0 \
}
#define STARPU_TASK_GET_NBUFFERS(task) ((unsigned)((task)->cl->nbuffers == STARPU_VARIABLE_NBUFFERS ? ((task)->nbuffers) : ((task)->cl->nbuffers)))
#define STARPU_TASK_GET_HANDLE(task, i) (((task)->dyn_handles) ? (task)->dyn_handles[i] : (task)->handles[i])
#define STARPU_TASK_GET_HANDLES(task) (((task)->dyn_handles) ? (task)->dyn_handles : (task)->handles)
#define STARPU_TASK_SET_HANDLE(task, handle, i) \
do { \
if ((task)->dyn_handles) \
(task)->dyn_handles[i] = handle; \
else \
(task)->handles[i] = handle; \
} \
while (0)
#define STARPU_CODELET_GET_MODE(codelet, i) \
(((codelet)->dyn_modes) ? (codelet)->dyn_modes[i] : (assert(i < STARPU_NMAXBUFS), (codelet)->modes[i]))
#define STARPU_CODELET_SET_MODE(codelet, mode, i) \
do { \
if ((codelet)->dyn_modes) \
(codelet)->dyn_modes[i] = mode; \
else \
(codelet)->modes[i] = mode; \
} \
while (0)
#define STARPU_TASK_GET_MODE(task, i) \
((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))
#define STARPU_TASK_SET_MODE(task, mode, i) \
do { \
if ((task)->cl->nbuffers == STARPU_VARIABLE_NBUFFERS || (task)->cl->nbuffers > STARPU_NMAXBUFS) \
if ((task)->dyn_modes) \
(task)->dyn_modes[i] = mode; \
else \
(task)->modes[i] = mode; \
else \
{ \
enum starpu_data_access_mode cl_mode = STARPU_CODELET_GET_MODE((task)->cl, i); \
STARPU_ASSERT_MSG(cl_mode == mode, \
"Task <%s> can't set its %d-th buffer mode to %d as the codelet it derives from uses %d", \
(task)->cl->name, i, mode, cl_mode); \
} \
} \
while (0)
#define STARPU_CODELET_GET_NODE(codelet, i) (((codelet)->dyn_nodes) ? (codelet)->dyn_nodes[i] : (codelet)->nodes[i])
#define STARPU_CODELET_SET_NODE(codelet, __node, i) \
do { \
if ((codelet)->dyn_nodes) \
(codelet)->dyn_nodes[i] = __node; \
else \
(codelet)->nodes[i] = __node; \
} \
while (0)
void starpu_task_init(struct starpu_task *task);
void starpu_task_clean(struct starpu_task *task);
struct starpu_task *starpu_task_create(void) STARPU_ATTRIBUTE_MALLOC;
struct starpu_task *starpu_task_create_sync(starpu_data_handle_t handle, enum starpu_data_access_mode mode) STARPU_ATTRIBUTE_MALLOC;
void starpu_task_destroy(struct starpu_task *task);
void starpu_task_set_destroy(struct starpu_task *task);
int starpu_task_submit(struct starpu_task *task) STARPU_WARN_UNUSED_RESULT;
#ifdef STARPU_USE_FXT
static inline int starpu_task_submit_line(struct starpu_task *task, const char *file, int line)
{
task->file = file;
task->line = line;
return starpu_task_submit(task);
}
#define starpu_task_submit(task) starpu_task_submit_line((task), __FILE__, __LINE__)
#endif
int starpu_task_submit_nodeps(struct starpu_task *task) STARPU_WARN_UNUSED_RESULT;
int starpu_task_submit_to_ctx(struct starpu_task *task, unsigned sched_ctx_id);
int starpu_task_finished(struct starpu_task *task) STARPU_WARN_UNUSED_RESULT;
int starpu_task_wait(struct starpu_task *task) STARPU_WARN_UNUSED_RESULT;
int starpu_task_wait_array(struct starpu_task **tasks, unsigned nb_tasks) STARPU_WARN_UNUSED_RESULT;
int starpu_task_wait_for_all(void);
int starpu_task_wait_for_n_submitted(unsigned n);
int starpu_task_wait_for_all_in_ctx(unsigned sched_ctx_id);
int starpu_task_wait_for_n_submitted_in_ctx(unsigned sched_ctx_id, unsigned n);
int starpu_task_wait_for_no_ready(void);
int starpu_task_nready(void);
int starpu_task_nsubmitted(void);
void starpu_iteration_push(unsigned long iteration);
void starpu_iteration_pop(void);
void starpu_do_schedule(void);
void starpu_codelet_init(struct starpu_codelet *cl);
void starpu_codelet_display_stats(struct starpu_codelet *cl);
struct starpu_task *starpu_task_get_current(void);
int starpu_task_get_current_data_node(unsigned i);
const char *starpu_task_get_model_name(struct starpu_task *task);
const char *starpu_task_get_name(struct starpu_task *task);
struct starpu_task *starpu_task_dup(struct starpu_task *task);
void starpu_task_set_implementation(struct starpu_task *task, unsigned impl);
unsigned starpu_task_get_implementation(struct starpu_task *task);
void starpu_create_sync_task(starpu_tag_t sync_tag, unsigned ndeps, starpu_tag_t *deps, void (*callback)(void *), void *callback_arg);
void starpu_create_callback_task(void (*callback)(void *), void *callback_arg);
void starpu_task_ft_prologue(void *check_ft);
struct starpu_task *starpu_task_ft_create_retry(const struct starpu_task *meta_task, const struct starpu_task *template_task, void (*check_ft)(void *));
void starpu_task_ft_failed(struct starpu_task *task);
void starpu_task_ft_success(struct starpu_task *meta_task);
void starpu_task_watchdog_set_hook(void (*hook)(void *), void *hook_arg);
char *starpu_task_status_get_as_string(enum starpu_task_status status);
void starpu_set_limit_min_submitted_tasks(int limit_min);
void starpu_set_limit_max_submitted_tasks(int limit_min);
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);
void starpu_transaction_close(struct starpu_transaction *p_trs);
#ifdef __cplusplus
}
#endif
#endif /* __STARPU_TASK_H__ */
starpu_bubble_gen_dag_func_t
void(* starpu_bubble_gen_dag_func_t)(struct starpu_task *t, void *arg)
Definition starpu_task.h:223
starpu_bubble_func_t
int(* starpu_bubble_func_t)(struct starpu_task *t, void *arg)
Definition starpu_task.h:217
starpu_task::bundle
starpu_task_bundle_t bundle
Definition starpu_task.h:1359
starpu_codelet::specific_nodes
unsigned specific_nodes
Definition starpu_task.h:565
starpu_task::callback_func
void(* callback_func)(void *)
Definition starpu_task.h:936
starpu_codelet::max_fpga_funcs
starpu_max_fpga_func_t max_fpga_funcs[STARPU_MAXIMPLEMENTATIONS]
Definition starpu_task.h:497
starpu_codelet::max_parallelism
int max_parallelism
Definition starpu_task.h:377
starpu_task::bubble_func_arg
void * bubble_func_arg
Definition starpu_task.h:1448
starpu_task::sched_ctx
unsigned sched_ctx
Definition starpu_task.h:1337
starpu_task::bubble_gen_dag_func
starpu_bubble_gen_dag_func_t bubble_gen_dag_func
Definition starpu_task.h:1454
starpu_task::nb_termination_call_required
unsigned nb_termination_call_required
Definition starpu_task.h:1466
starpu_task::synchronous
unsigned synchronous
Definition starpu_task.h:1126
starpu_codelet::checked
int checked
Definition starpu_task.h:662
starpu_codelet::nbuffers
int nbuffers
Definition starpu_task.h:532
starpu_task::cl_ret
void * cl_ret
Definition starpu_task.h:884
starpu_task::cl_arg
void * cl_arg
Definition starpu_task.h:857
starpu_task::epilogue_callback_func
void(* epilogue_callback_func)(void *)
Definition starpu_task.h:908
starpu_codelet::opencl_func
starpu_opencl_func_t opencl_func
Definition starpu_task.h:398
starpu_task::predicted_transfer
double predicted_transfer
Definition starpu_task.h:1399
starpu_codelet::model
struct starpu_perfmodel * model
Definition starpu_task.h:602
starpu_codelet::per_worker_stats
unsigned long per_worker_stats[STARPU_NMAXWORKERS]
Definition starpu_task.h:621
starpu_codelet::bubble_gen_dag_func
starpu_bubble_gen_dag_func_t bubble_gen_dag_func
Definition starpu_task.h:517
starpu_codelet::can_execute
int(* can_execute)(unsigned workerid, struct starpu_task *task, unsigned nimpl)
Definition starpu_task.h:361
starpu_codelet::bubble_func
starpu_bubble_func_t bubble_func
Definition starpu_task.h:512
starpu_codelet::opencl_flags
char opencl_flags[STARPU_MAXIMPLEMENTATIONS]
Definition starpu_task.h:480
starpu_task::use_tag
unsigned use_tag
Definition starpu_task.h:1103
starpu_task::callback_arg_free
unsigned callback_arg_free
Definition starpu_task.h:1055
starpu_task::epilogue_callback_arg_free
unsigned epilogue_callback_arg_free
Definition starpu_task.h:1064
starpu_task::trs_epoch
starpu_trs_epoch_t trs_epoch
Definition starpu_task.h:1012
starpu_codelet::cuda_func
starpu_cuda_func_t cuda_func
Definition starpu_task.h:391
starpu_task::cl_arg_free
unsigned cl_arg_free
Definition starpu_task.h:1034
starpu_task::destroy
unsigned destroy
Definition starpu_task.h:1167
starpu_codelet::dyn_nodes
int * dyn_nodes
Definition starpu_task.h:594
starpu_task::modes
enum starpu_data_access_mode modes[STARPU_NMAXBUFS]
Definition starpu_task.h:823
starpu_task::prologue_callback_arg
void * prologue_callback_arg
Definition starpu_task.h:976
starpu_task::hypervisor_tag
int hypervisor_tag
Definition starpu_task.h:1345
starpu_task::where
int32_t where
Definition starpu_task.h:727
starpu_codelet::where
uint32_t where
Definition starpu_task.h:354
starpu_codelet::callback_func
void(* callback_func)(void *)
Definition starpu_task.h:649
starpu_task::line
int line
Definition starpu_task.h:709
starpu_task::execute_on_a_specific_worker
unsigned execute_on_a_specific_worker
Definition starpu_task.h:1136
starpu_task::dyn_handles
starpu_data_handle_t * dyn_handles
Definition starpu_task.h:758
starpu_codelet::cpu_funcs
starpu_cpu_func_t cpu_funcs[STARPU_MAXIMPLEMENTATIONS]
Definition starpu_task.h:415
starpu_task::starpu_private
void * starpu_private
Definition starpu_task.h:1420
starpu_task::type
unsigned type
Definition starpu_task.h:1321
starpu_task::prologue_callback_arg_free
unsigned prologue_callback_arg_free
Definition starpu_task.h:1077
starpu_task::cl_ret_size
size_t cl_ret_size
Definition starpu_task.h:892
starpu_codelet::modes
enum starpu_data_access_mode modes[STARPU_NMAXBUFS]
Definition starpu_task.h:543
starpu_task::workerid
unsigned workerid
Definition starpu_task.h:1228
starpu_task::mf_skip
unsigned char mf_skip
Definition starpu_task.h:1194
starpu_task::workerorder
unsigned workerorder
Definition starpu_task.h:1244
starpu_task::transaction
struct starpu_transaction * transaction
Definition starpu_task.h:1007
starpu_task::status
enum starpu_task_status status
Definition starpu_task.h:1301
starpu_codelet::opencl_funcs
starpu_opencl_func_t opencl_funcs[STARPU_MAXIMPLEMENTATIONS]
Definition starpu_task.h:473
starpu_task::workerids_len
unsigned workerids_len
Definition starpu_task.h:1269
starpu_task::profiling_info
struct starpu_profiling_task_info * profiling_info
Definition starpu_task.h:1368
starpu_task::name
const char * name
Definition starpu_task.h:697
starpu_task::flops
double flops
Definition starpu_task.h:1382
starpu_task::tag_id
starpu_tag_t tag_id
Definition starpu_task.h:1022
starpu_task::prologue_callback_pop_arg
void * prologue_callback_pop_arg
Definition starpu_task.h:1002
starpu_task::bubble_func
starpu_bubble_func_t bubble_func
Definition starpu_task.h:1442
starpu_task::dyn_interfaces
void ** dyn_interfaces
Definition starpu_task.h:767
starpu_task::failed
unsigned char failed
Definition starpu_task.h:1201
starpu_task::cl_ret_free
unsigned cl_ret_free
Definition starpu_task.h:1042
starpu_task::file
const char * file
Definition starpu_task.h:703
starpu_task::possibly_parallel
unsigned possibly_parallel
Definition starpu_task.h:1353
starpu_task::predicted
double predicted
Definition starpu_task.h:1390
starpu_task::handles_sequential_consistency
unsigned char * handles_sequential_consistency
Definition starpu_task.h:833
starpu_task::prefetched
unsigned char prefetched
Definition starpu_task.h:1215
starpu_task::detach
unsigned detach
Definition starpu_task.h:1147
starpu_task::priority
int priority
Definition starpu_task.h:1292
starpu_task::scheduled
unsigned char scheduled
Definition starpu_task.h:1208
starpu_codelet::dyn_modes
enum starpu_data_access_mode * dyn_modes
Definition starpu_task.h:556
starpu_task::callback_arg
void * callback_arg
Definition starpu_task.h:950
starpu_codelet::cuda_funcs
starpu_cuda_func_t cuda_funcs[STARPU_MAXIMPLEMENTATIONS]
Definition starpu_task.h:430
starpu_task::nbuffers
int nbuffers
Definition starpu_task.h:736
starpu_codelet::cuda_flags
char cuda_flags[STARPU_MAXIMPLEMENTATIONS]
Definition starpu_task.h:437
starpu_codelet::hip_flags
char hip_flags[STARPU_MAXIMPLEMENTATIONS]
Definition starpu_task.h:459
starpu_task::bubble_gen_dag_func_arg
void * bubble_gen_dag_func_arg
Definition starpu_task.h:1460
starpu_task::omp_task
struct starpu_omp_task * omp_task
Definition starpu_task.h:1427
starpu_data_descr::mode
enum starpu_data_access_mode mode
Definition starpu_task.h:676
starpu_codelet::nodes
int nodes[STARPU_NMAXBUFS]
Definition starpu_task.h:581
starpu_task::color
unsigned color
Definition starpu_task.h:1329
starpu_codelet::hip_funcs
starpu_hip_func_t hip_funcs[STARPU_MAXIMPLEMENTATIONS]
Definition starpu_task.h:452
starpu_codelet::cpu_funcs_name
const char * cpu_funcs_name[STARPU_MAXIMPLEMENTATIONS]
Definition starpu_task.h:506
starpu_task::cl
struct starpu_codelet * cl
Definition starpu_task.h:718
starpu_task::magic
int magic
Definition starpu_task.h:1310
starpu_data_descr::handle
starpu_data_handle_t handle
Definition starpu_task.h:675
starpu_task::workerids
uint32_t * workerids
Definition starpu_task.h:1258
starpu_codelet::flags
int flags
Definition starpu_task.h:654
starpu_task::prologue_callback_pop_func
void(* prologue_callback_pop_func)(void *)
Definition starpu_task.h:991
starpu_codelet::cpu_func
starpu_cpu_func_t cpu_func
Definition starpu_task.h:384
starpu_codelet::color
unsigned color
Definition starpu_task.h:635
starpu_task::bubble_parent
unsigned long bubble_parent
Definition starpu_task.h:1436
starpu_task::cl_arg_size
size_t cl_arg_size
Definition starpu_task.h:874
starpu_task::sched_data
void * sched_data
Definition starpu_task.h:1475
starpu_codelet::name
const char * name
Definition starpu_task.h:627
starpu_task::prev
struct starpu_task * prev
Definition starpu_task.h:1407
starpu_task::next
struct starpu_task * next
Definition starpu_task.h:1414
starpu_task::prologue_callback_func
void(* prologue_callback_func)(void *)
Definition starpu_task.h:965
starpu_task::dyn_modes
enum starpu_data_access_mode * dyn_modes
Definition starpu_task.h:785
starpu_task::sequential_consistency
unsigned sequential_consistency
Definition starpu_task.h:1115
starpu_task::prologue_callback_pop_arg_free
unsigned prologue_callback_pop_arg_free
Definition starpu_task.h:1091
starpu_task::epilogue_callback_arg
void * epilogue_callback_arg
Definition starpu_task.h:916
starpu_task::regenerate
unsigned regenerate
Definition starpu_task.h:1178
starpu_task::handles
starpu_data_handle_t handles[STARPU_NMAXBUFS]
Definition starpu_task.h:799
starpu_codelet::type
enum starpu_codelet_type type
Definition starpu_task.h:370
starpu_task::no_submitorder
unsigned no_submitorder
Definition starpu_task.h:1187
starpu_codelet::energy_model
struct starpu_perfmodel * energy_model
Definition starpu_task.h:612
starpu_task::interfaces
void * interfaces[STARPU_NMAXBUFS]
Definition starpu_task.h:807
starpu_task_status
starpu_task_status
Definition starpu_task.h:174
starpu_cuda_func_t
void(* starpu_cuda_func_t)(void **, void *)
Definition starpu_task.h:196
starpu_codelet_display_stats
void starpu_codelet_display_stats(struct starpu_codelet *cl)
starpu_task_nready
int starpu_task_nready(void)
starpu_cpu_func_t
void(* starpu_cpu_func_t)(void **, void *)
Definition starpu_task.h:191
starpu_task_wait_array
int starpu_task_wait_array(struct starpu_task **tasks, unsigned nb_tasks)
starpu_task_wait
int starpu_task_wait(struct starpu_task *task)
starpu_do_schedule
void starpu_do_schedule(void)
starpu_task_submit_to_ctx
int starpu_task_submit_to_ctx(struct starpu_task *task, unsigned sched_ctx_id)
starpu_task_status_get_as_string
char * starpu_task_status_get_as_string(enum starpu_task_status status)
starpu_codelet_init
void starpu_codelet_init(struct starpu_codelet *cl)
starpu_task_create
struct starpu_task * starpu_task_create(void) STARPU_ATTRIBUTE_MALLOC
starpu_task_ft_prologue
void starpu_task_ft_prologue(void *check_ft)
starpu_task_wait_for_no_ready
int starpu_task_wait_for_no_ready(void)
starpu_task_create_sync
struct starpu_task * starpu_task_create_sync(starpu_data_handle_t handle, enum starpu_data_access_mode mode) STARPU_ATTRIBUTE_MALLOC
starpu_opencl_func_t
void(* starpu_opencl_func_t)(void **, void *)
Definition starpu_task.h:206
starpu_task_wait_for_n_submitted
int starpu_task_wait_for_n_submitted(unsigned n)
starpu_task_get_name
const char * starpu_task_get_name(struct starpu_task *task)
starpu_task_ft_failed
void starpu_task_ft_failed(struct starpu_task *task)
starpu_task_get_model_name
const char * starpu_task_get_model_name(struct starpu_task *task)
starpu_set_limit_max_submitted_tasks
void starpu_set_limit_max_submitted_tasks(int limit_min)
starpu_iteration_pop
void starpu_iteration_pop(void)
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)
starpu_task_get_current_data_node
int starpu_task_get_current_data_node(unsigned i)
starpu_set_limit_min_submitted_tasks
void starpu_set_limit_min_submitted_tasks(int limit_min)
starpu_task_destroy
void starpu_task_destroy(struct starpu_task *task)
starpu_task_watchdog_set_hook
void starpu_task_watchdog_set_hook(void(*hook)(void *), void *hook_arg)
starpu_create_callback_task
void starpu_create_callback_task(void(*callback)(void *), void *callback_arg)
starpu_task_ft_create_retry
struct starpu_task * starpu_task_ft_create_retry(const struct starpu_task *meta_task, const struct starpu_task *template_task, void(*check_ft)(void *))
starpu_task_submit_nodeps
int starpu_task_submit_nodeps(struct starpu_task *task)
starpu_task_set_implementation
void starpu_task_set_implementation(struct starpu_task *task, unsigned impl)
starpu_task_get_implementation
unsigned starpu_task_get_implementation(struct starpu_task *task)
starpu_task_get_current
struct starpu_task * starpu_task_get_current(void)
starpu_task_wait_for_n_submitted_in_ctx
int starpu_task_wait_for_n_submitted_in_ctx(unsigned sched_ctx_id, unsigned n)
starpu_codelet_type
starpu_codelet_type
Definition starpu_task.h:152
starpu_task_finished
int starpu_task_finished(struct starpu_task *task)
starpu_task_ft_success
void starpu_task_ft_success(struct starpu_task *meta_task)
starpu_task_wait_for_all
int starpu_task_wait_for_all(void)
starpu_iteration_push
void starpu_iteration_push(unsigned long iteration)
starpu_codelet_nop
struct starpu_codelet starpu_codelet_nop
STARPU_NMAXBUFS
#define STARPU_NMAXBUFS
Definition starpu_config.h:247
starpu_task_init
void starpu_task_init(struct starpu_task *task)
starpu_task_nsubmitted
int starpu_task_nsubmitted(void)
starpu_max_fpga_func_t
void(* starpu_max_fpga_func_t)(void **, void *)
Definition starpu_task.h:211
starpu_hip_func_t
void(* starpu_hip_func_t)(void **, void *)
Definition starpu_task.h:201
starpu_task_clean
void starpu_task_clean(struct starpu_task *task)
starpu_task_set_destroy
void starpu_task_set_destroy(struct starpu_task *task)
starpu_task_wait_for_all_in_ctx
int starpu_task_wait_for_all_in_ctx(unsigned sched_ctx_id)
starpu_task_dup
struct starpu_task * starpu_task_dup(struct starpu_task *task)
STARPU_TASK_BLOCKED_ON_DATA
@ STARPU_TASK_BLOCKED_ON_DATA
Definition starpu_task.h:184
STARPU_TASK_READY
@ STARPU_TASK_READY
Definition starpu_task.h:179
STARPU_TASK_BLOCKED_ON_TAG
@ STARPU_TASK_BLOCKED_ON_TAG
Definition starpu_task.h:182
STARPU_TASK_STOPPED
@ STARPU_TASK_STOPPED
Definition starpu_task.h:185
STARPU_TASK_BLOCKED_ON_TASK
@ STARPU_TASK_BLOCKED_ON_TASK
Definition starpu_task.h:183
STARPU_TASK_RUNNING
@ STARPU_TASK_RUNNING
Definition starpu_task.h:180
STARPU_TASK_BLOCKED
@ STARPU_TASK_BLOCKED
Definition starpu_task.h:178
STARPU_TASK_FINISHED
@ STARPU_TASK_FINISHED
Definition starpu_task.h:181
STARPU_FORKJOIN
@ STARPU_FORKJOIN
Definition starpu_task.h:162
STARPU_SPMD
@ STARPU_SPMD
Definition starpu_task.h:156
STARPU_SEQ
@ STARPU_SEQ
Definition starpu_task.h:153
starpu_codelet
Definition starpu_task.h:339
starpu_data_descr
Definition starpu_task.h:674
starpu_task
Definition starpu_task.h:689
starpu_data_access_mode
starpu_data_access_mode
Definition starpu_data.h:56
starpu_data_handle_t
struct _starpu_data_state * starpu_data_handle_t
Definition starpu_data.h:45
starpu_tag_t
uint64_t starpu_tag_t
Definition starpu_task_dep.h:134
starpu_perfmodel
Definition starpu_perfmodel.h:193
starpu_profiling_task_info
Definition starpu_profiling.h:55
STARPU_MAXIMPLEMENTATIONS
#define STARPU_MAXIMPLEMENTATIONS
Definition starpu_config.h:321
starpu_task_bundle_t
struct _starpu_task_bundle * starpu_task_bundle_t
Definition starpu_task_bundle.h:39
STARPU_ATTRIBUTE_MALLOC
#define STARPU_ATTRIBUTE_MALLOC
Definition starpu_util.h:129
starpu_transaction_close
void starpu_transaction_close(struct starpu_transaction *p_trs)
starpu_transaction_open
struct starpu_transaction * starpu_transaction_open(int(*do_start_func)(void *buffer, void *arg), void *do_start_arg)
starpu_transaction_next_epoch
void starpu_transaction_next_epoch(struct starpu_transaction *p_trs, void *do_start_arg)
STARPU_NMAXWORKERS
#define STARPU_NMAXWORKERS
Definition starpu_config.h:305
starpu.h