23 #include <common/config.h>
28 #define STARPU_DYNAMIC_DEPS_SIZE 1
31 #ifndef STARPU_DYNAMIC_DEPS_SIZE
32 #define STARPU_NMAXDEPS 256
47 unsigned ndeps_completed;
62 #ifdef STARPU_DYNAMIC_DEPS_SIZE
73 STARPU_CG_APPS=(1<<0),
94 enum _starpu_cg_type cg_type;
111 starpu_pthread_mutex_t cg_mutex;
112 starpu_pthread_cond_t cg_cond;
117 typedef struct _starpu_notify_job_start_data _starpu_notify_job_start_data;
119 void _starpu_notify_dependencies(
struct _starpu_job *j);
120 void _starpu_job_notify_start(
struct _starpu_job *j,
struct starpu_perfmodel_arch* perf_arch);
121 void _starpu_job_notify_ready_soon(
struct _starpu_job *j, _starpu_notify_job_start_data *data);
126 int _starpu_list_task_successors_in_cg_list(
struct _starpu_cg_list *successors,
unsigned ndeps,
struct starpu_task *task_array[]);
127 int _starpu_list_task_scheduled_successors_in_cg_list(
struct _starpu_cg_list *successors,
unsigned ndeps,
struct starpu_task *task_array[]);
128 int _starpu_list_tag_successors_in_cg_list(
struct _starpu_cg_list *successors,
unsigned ndeps, starpu_tag_t tag_array[]);
129 void _starpu_notify_cg(
void *pred,
struct _starpu_cg *cg);
130 void _starpu_notify_cg_list(
void *pred,
struct _starpu_cg_list *successors);
131 void _starpu_notify_job_start_cg_list(
void *pred,
struct _starpu_cg_list *successors, _starpu_notify_job_start_data *data);
132 void _starpu_notify_task_dependencies(
struct _starpu_job *j);
133 void _starpu_notify_job_start_tasks(
struct _starpu_job *j, _starpu_notify_job_start_data *data);
unsigned ntags
Definition: cg.h:82
unsigned nsuccs
Definition: cg.h:61
struct _starpu_spinlock lock
Definition: cg.h:43
unsigned remaining
Definition: cg.h:84
unsigned succ_list_size
Definition: cg.h:64
unsigned terminated
Definition: cg.h:58
unsigned ndeps
Definition: cg.h:46
Definition: starpu_spinlock.h:82