|
|
@@ -50,46 +50,81 @@
|
|
|
#define _STARPU_SCHED_NTASKS_THRESHOLD_DEFAULT 2
|
|
|
#define _STARPU_SCHED_EXP_LEN_THRESHOLD_DEFAULT 1000000000.0
|
|
|
|
|
|
-void starpu_sched_component_initialize_simple_scheduler(starpu_sched_component_create_t create_decision_component, void *data, unsigned flags, unsigned sched_ctx_id)
|
|
|
+void starpu_sched_component_initialize_simple_schedulers(unsigned sched_ctx_id, unsigned ndecisions, ...)
|
|
|
{
|
|
|
struct starpu_sched_tree * t;
|
|
|
struct starpu_sched_component *last = NULL; /* Stores the last created component, from top to bottom */
|
|
|
unsigned i, j, n;
|
|
|
+ struct starpu_sched_component *userchoice_component = NULL;
|
|
|
struct starpu_sched_component *decision_component = NULL;
|
|
|
struct starpu_sched_component *no_perfmodel_component = NULL;
|
|
|
struct starpu_sched_component *calibrator_component = NULL;
|
|
|
+ unsigned sched;
|
|
|
+ va_list varg_list;
|
|
|
+ unsigned decide_flags;
|
|
|
+ unsigned flags;
|
|
|
|
|
|
/* Start building the tree */
|
|
|
t = starpu_sched_tree_create(sched_ctx_id);
|
|
|
t->root = NULL;
|
|
|
starpu_sched_ctx_set_policy_data(sched_ctx_id, (void*)t);
|
|
|
|
|
|
- /* Create combined workers if requested */
|
|
|
- if (flags & STARPU_SCHED_SIMPLE_COMBINED_WORKERS)
|
|
|
- starpu_sched_find_all_worker_combinations();
|
|
|
-
|
|
|
- /* Components parameters */
|
|
|
+ STARPU_ASSERT(ndecisions >= 1);
|
|
|
|
|
|
- if (flags & STARPU_SCHED_SIMPLE_FIFO_ABOVE_PRIO || flags & STARPU_SCHED_SIMPLE_FIFOS_BELOW_PRIO)
|
|
|
+ if (ndecisions != 1)
|
|
|
{
|
|
|
- /* The application may use any integer */
|
|
|
- if (starpu_sched_ctx_min_priority_is_set(sched_ctx_id) == 0)
|
|
|
- starpu_sched_ctx_set_min_priority(sched_ctx_id, INT_MIN);
|
|
|
- if (starpu_sched_ctx_max_priority_is_set(sched_ctx_id) == 0)
|
|
|
- starpu_sched_ctx_set_max_priority(sched_ctx_id, INT_MAX);
|
|
|
+ /* Take choice between schedulers from user */
|
|
|
+ userchoice_component = starpu_sched_component_userchoice_create(t, NULL);
|
|
|
+ t->root = userchoice_component;
|
|
|
}
|
|
|
|
|
|
- /* See what the component will decide */
|
|
|
+
|
|
|
unsigned nbelow;
|
|
|
unsigned nummaxids;
|
|
|
- nummaxids = starpu_worker_get_count() + starpu_combined_worker_get_count();
|
|
|
- if (starpu_memory_nodes_get_count() > nummaxids)
|
|
|
- nummaxids = starpu_memory_nodes_get_count();
|
|
|
- if (STARPU_ANY_WORKER > nummaxids)
|
|
|
- nummaxids = STARPU_ANY_WORKER;
|
|
|
+
|
|
|
+ va_start(varg_list, ndecisions);
|
|
|
+ for (sched = 0; sched < ndecisions; sched++)
|
|
|
+ {
|
|
|
+ last = userchoice_component;
|
|
|
+
|
|
|
+ starpu_sched_component_create_t create_decision_component = va_arg(varg_list, starpu_sched_component_create_t);
|
|
|
+ void *data = va_arg(varg_list, void *);
|
|
|
+ flags = va_arg(varg_list, unsigned);
|
|
|
+ (void) create_decision_component;
|
|
|
+ (void) data;
|
|
|
+
|
|
|
+ /* Create combined workers if requested */
|
|
|
+ if (flags & STARPU_SCHED_SIMPLE_COMBINED_WORKERS)
|
|
|
+ starpu_sched_find_all_worker_combinations();
|
|
|
+
|
|
|
+ /* Components parameters */
|
|
|
+
|
|
|
+ if (flags & STARPU_SCHED_SIMPLE_FIFO_ABOVE_PRIO || flags & STARPU_SCHED_SIMPLE_FIFOS_BELOW_PRIO)
|
|
|
+ {
|
|
|
+ /* The application may use any integer */
|
|
|
+ if (starpu_sched_ctx_min_priority_is_set(sched_ctx_id) == 0)
|
|
|
+ starpu_sched_ctx_set_min_priority(sched_ctx_id, INT_MIN);
|
|
|
+ if (starpu_sched_ctx_max_priority_is_set(sched_ctx_id) == 0)
|
|
|
+ starpu_sched_ctx_set_max_priority(sched_ctx_id, INT_MAX);
|
|
|
+ }
|
|
|
+
|
|
|
+ /* See what the component will decide */
|
|
|
+ nummaxids = starpu_worker_get_count() + starpu_combined_worker_get_count();
|
|
|
+ if (starpu_memory_nodes_get_count() > nummaxids)
|
|
|
+ nummaxids = starpu_memory_nodes_get_count();
|
|
|
+ if (STARPU_ANY_WORKER > nummaxids)
|
|
|
+ nummaxids = STARPU_ANY_WORKER;
|
|
|
+
|
|
|
+ if (sched == 0)
|
|
|
+ decide_flags = flags & STARPU_SCHED_SIMPLE_DECIDE_MASK;
|
|
|
+ else
|
|
|
+ STARPU_ASSERT(decide_flags == (flags & STARPU_SCHED_SIMPLE_DECIDE_MASK));
|
|
|
+ }
|
|
|
+ va_end(varg_list);
|
|
|
+
|
|
|
unsigned below_id[nummaxids];
|
|
|
|
|
|
- switch (flags & STARPU_SCHED_SIMPLE_DECIDE_MASK)
|
|
|
+ switch (decide_flags)
|
|
|
{
|
|
|
case STARPU_SCHED_SIMPLE_DECIDE_WORKERS:
|
|
|
/* Count workers */
|
|
|
@@ -134,162 +169,193 @@ void starpu_sched_component_initialize_simple_scheduler(starpu_sched_component_c
|
|
|
}
|
|
|
STARPU_ASSERT(nbelow > 0);
|
|
|
|
|
|
- if (nbelow == 1)
|
|
|
- {
|
|
|
- /* Oh, no choice, we don't actually need to decide, just
|
|
|
- * use an eager scheduler */
|
|
|
- decision_component = starpu_sched_component_eager_create(t, NULL);
|
|
|
- /* But make sure we have a fifo above it, fifos below it would
|
|
|
- * possibly refuse tasks out of available room */
|
|
|
- flags |= STARPU_SCHED_SIMPLE_FIFO_ABOVE;
|
|
|
- }
|
|
|
- else
|
|
|
+ struct starpu_sched_component *last_below[nbelow];
|
|
|
+ memset(&last_below, 0, sizeof(last_below));
|
|
|
+
|
|
|
+ if (ndecisions != 1)
|
|
|
{
|
|
|
- decision_component = create_decision_component(t, data);
|
|
|
+ /* Will need to stage pulls, create one per choice */
|
|
|
+ for (i = 0; i < nbelow; i++)
|
|
|
+ last_below[i] = starpu_sched_component_stage_create(t, NULL);
|
|
|
}
|
|
|
|
|
|
- /* First, a fifo if requested */
|
|
|
- if (flags & STARPU_SCHED_SIMPLE_FIFO_ABOVE)
|
|
|
+ va_start(varg_list, ndecisions);
|
|
|
+ for (sched = 0; sched < ndecisions; sched++)
|
|
|
{
|
|
|
- struct starpu_sched_component *fifo_above;
|
|
|
- if (flags & STARPU_SCHED_SIMPLE_FIFO_ABOVE_PRIO)
|
|
|
+ last = userchoice_component;
|
|
|
+
|
|
|
+ starpu_sched_component_create_t create_decision_component = va_arg(varg_list, starpu_sched_component_create_t);
|
|
|
+ void *data = va_arg(varg_list, void *);
|
|
|
+ flags = va_arg(varg_list, unsigned);
|
|
|
+
|
|
|
+ if (nbelow == 1)
|
|
|
{
|
|
|
- fifo_above = starpu_sched_component_prio_create(t, NULL);
|
|
|
+ /* Oh, no choice, we don't actually need to decide, just
|
|
|
+ * use an eager scheduler */
|
|
|
+ decision_component = starpu_sched_component_eager_create(t, NULL);
|
|
|
+ /* But make sure we have a fifo above it, fifos below it would
|
|
|
+ * possibly refuse tasks out of available room */
|
|
|
+ flags |= STARPU_SCHED_SIMPLE_FIFO_ABOVE;
|
|
|
}
|
|
|
else
|
|
|
{
|
|
|
- fifo_above = starpu_sched_component_fifo_create(t, NULL);
|
|
|
+ decision_component = create_decision_component(t, data);
|
|
|
}
|
|
|
- last = t->root = fifo_above;
|
|
|
- }
|
|
|
|
|
|
- /* Then, perfmodel calibration if requested, and plug the scheduling decision-making component to it */
|
|
|
- if (flags & STARPU_SCHED_SIMPLE_PERFMODEL)
|
|
|
- {
|
|
|
- no_perfmodel_component = starpu_sched_component_eager_create(t, NULL);
|
|
|
- calibrator_component = starpu_sched_component_eager_calibration_create(t, NULL);
|
|
|
-
|
|
|
- struct starpu_sched_component_perfmodel_select_data perfmodel_select_data =
|
|
|
+ /* First, a fifo if requested */
|
|
|
+ if (flags & STARPU_SCHED_SIMPLE_FIFO_ABOVE)
|
|
|
+ {
|
|
|
+ struct starpu_sched_component *fifo_above;
|
|
|
+ if (flags & STARPU_SCHED_SIMPLE_FIFO_ABOVE_PRIO)
|
|
|
{
|
|
|
- .calibrator_component = calibrator_component,
|
|
|
- .no_perfmodel_component = no_perfmodel_component,
|
|
|
- .perfmodel_component = decision_component,
|
|
|
- };
|
|
|
-
|
|
|
- struct starpu_sched_component * perfmodel_select_component = starpu_sched_component_perfmodel_select_create(t, &perfmodel_select_data);
|
|
|
-
|
|
|
- if (!t->root)
|
|
|
- t->root = perfmodel_select_component;
|
|
|
- else
|
|
|
- starpu_sched_component_connect(last, perfmodel_select_component);
|
|
|
+ fifo_above = starpu_sched_component_prio_create(t, NULL);
|
|
|
+ }
|
|
|
+ else
|
|
|
+ {
|
|
|
+ fifo_above = starpu_sched_component_fifo_create(t, NULL);
|
|
|
+ }
|
|
|
+ if (!last)
|
|
|
+ last = t->root = fifo_above;
|
|
|
+ else
|
|
|
+ {
|
|
|
+ starpu_sched_component_connect(last, fifo_above);
|
|
|
+ last = fifo_above;
|
|
|
+ }
|
|
|
+ }
|
|
|
|
|
|
- starpu_sched_component_connect(perfmodel_select_component, decision_component);
|
|
|
- starpu_sched_component_connect(perfmodel_select_component, calibrator_component);
|
|
|
- starpu_sched_component_connect(perfmodel_select_component, no_perfmodel_component);
|
|
|
- }
|
|
|
- else
|
|
|
- {
|
|
|
- /* No perfmodel calibration */
|
|
|
- if (!t->root)
|
|
|
- /* Plug decision_component directly */
|
|
|
- t->root = decision_component;
|
|
|
- else
|
|
|
- /* Plug decision_component to fifo */
|
|
|
- starpu_sched_component_connect(last, decision_component);
|
|
|
- }
|
|
|
+ /* Then, perfmodel calibration if requested, and plug the scheduling decision-making component to it */
|
|
|
+ if (flags & STARPU_SCHED_SIMPLE_PERFMODEL)
|
|
|
+ {
|
|
|
+ no_perfmodel_component = starpu_sched_component_eager_create(t, NULL);
|
|
|
+ calibrator_component = starpu_sched_component_eager_calibration_create(t, NULL);
|
|
|
|
|
|
- /* Take default ntasks_threshold */
|
|
|
- unsigned ntasks_threshold;
|
|
|
- if (starpu_sched_component_is_heft(decision_component) ||
|
|
|
- starpu_sched_component_is_mct(decision_component) ||
|
|
|
- starpu_sched_component_is_heteroprio(decision_component)) {
|
|
|
- /* These need more queueing to allow CPUs to take some share of the work */
|
|
|
- ntasks_threshold = _STARPU_SCHED_NTASKS_THRESHOLD_HEFT;
|
|
|
- } else {
|
|
|
- ntasks_threshold = _STARPU_SCHED_NTASKS_THRESHOLD_DEFAULT;
|
|
|
- }
|
|
|
- /* But let user tune it */
|
|
|
- ntasks_threshold = starpu_get_env_number_default("STARPU_NTASKS_THRESHOLD", ntasks_threshold);
|
|
|
+ struct starpu_sched_component_perfmodel_select_data perfmodel_select_data =
|
|
|
+ {
|
|
|
+ .calibrator_component = calibrator_component,
|
|
|
+ .no_perfmodel_component = no_perfmodel_component,
|
|
|
+ .perfmodel_component = decision_component,
|
|
|
+ };
|
|
|
|
|
|
- double exp_len_threshold = _STARPU_SCHED_EXP_LEN_THRESHOLD_DEFAULT;
|
|
|
- exp_len_threshold = starpu_get_env_float_default("STARPU_EXP_LEN_THRESHOLD", exp_len_threshold);
|
|
|
+ struct starpu_sched_component * perfmodel_select_component = starpu_sched_component_perfmodel_select_create(t, &perfmodel_select_data);
|
|
|
|
|
|
- int ready = starpu_get_env_number_default("STARPU_SCHED_READY", flags & STARPU_SCHED_SIMPLE_FIFOS_BELOW_READY ? 1 : 0);
|
|
|
+ if (!last)
|
|
|
+ last = t->root = perfmodel_select_component;
|
|
|
+ else
|
|
|
+ starpu_sched_component_connect(last, perfmodel_select_component);
|
|
|
|
|
|
- struct starpu_sched_component_prio_data prio_data =
|
|
|
+ starpu_sched_component_connect(perfmodel_select_component, decision_component);
|
|
|
+ starpu_sched_component_connect(perfmodel_select_component, calibrator_component);
|
|
|
+ starpu_sched_component_connect(perfmodel_select_component, no_perfmodel_component);
|
|
|
+ }
|
|
|
+ else
|
|
|
{
|
|
|
- .ntasks_threshold = ntasks_threshold,
|
|
|
- .exp_len_threshold = exp_len_threshold,
|
|
|
- .ready = ready,
|
|
|
- };
|
|
|
+ /* No perfmodel calibration */
|
|
|
+ if (!last)
|
|
|
+ /* Plug decision_component directly */
|
|
|
+ last = t->root = decision_component;
|
|
|
+ else
|
|
|
+ /* Plug decision_component to fifo */
|
|
|
+ starpu_sched_component_connect(last, decision_component);
|
|
|
+ }
|
|
|
|
|
|
- struct starpu_sched_component_fifo_data fifo_data =
|
|
|
- {
|
|
|
- .ntasks_threshold = ntasks_threshold,
|
|
|
- .exp_len_threshold = exp_len_threshold,
|
|
|
- .ready = ready,
|
|
|
- };
|
|
|
+ /* Take default ntasks_threshold */
|
|
|
+ unsigned ntasks_threshold;
|
|
|
+ if (starpu_sched_component_is_heft(decision_component) ||
|
|
|
+ starpu_sched_component_is_mct(decision_component) ||
|
|
|
+ starpu_sched_component_is_heteroprio(decision_component)) {
|
|
|
+ /* These need more queueing to allow CPUs to take some share of the work */
|
|
|
+ ntasks_threshold = _STARPU_SCHED_NTASKS_THRESHOLD_HEFT;
|
|
|
+ } else {
|
|
|
+ ntasks_threshold = _STARPU_SCHED_NTASKS_THRESHOLD_DEFAULT;
|
|
|
+ }
|
|
|
+ /* But let user tune it */
|
|
|
+ ntasks_threshold = starpu_get_env_number_default("STARPU_NTASKS_THRESHOLD", ntasks_threshold);
|
|
|
|
|
|
+ double exp_len_threshold = _STARPU_SCHED_EXP_LEN_THRESHOLD_DEFAULT;
|
|
|
+ exp_len_threshold = starpu_get_env_float_default("STARPU_EXP_LEN_THRESHOLD", exp_len_threshold);
|
|
|
|
|
|
- /* Create one fifo+eager component pair per choice, below scheduling decision */
|
|
|
- struct starpu_sched_component *last_below[nbelow];
|
|
|
- memset(&last_below, 0, sizeof(last_below));
|
|
|
- for(i = 0; i < nbelow; i++)
|
|
|
- {
|
|
|
- last = decision_component;
|
|
|
- if (flags & STARPU_SCHED_SIMPLE_FIFOS_BELOW
|
|
|
- && !((flags & STARPU_SCHED_SIMPLE_DECIDE_MASK) == STARPU_SCHED_SIMPLE_DECIDE_WORKERS
|
|
|
- && i >= starpu_worker_get_count()))
|
|
|
- {
|
|
|
- struct starpu_sched_component *fifo_below;
|
|
|
- if (flags & STARPU_SCHED_SIMPLE_FIFOS_BELOW_PRIO)
|
|
|
+ int ready = starpu_get_env_number_default("STARPU_SCHED_READY", flags & STARPU_SCHED_SIMPLE_FIFOS_BELOW_READY ? 1 : 0);
|
|
|
+
|
|
|
+ struct starpu_sched_component_prio_data prio_data =
|
|
|
{
|
|
|
- fifo_below = starpu_sched_component_prio_create(t, &prio_data);
|
|
|
- }
|
|
|
- else
|
|
|
+ .ntasks_threshold = ntasks_threshold,
|
|
|
+ .exp_len_threshold = exp_len_threshold,
|
|
|
+ .ready = ready,
|
|
|
+ };
|
|
|
+
|
|
|
+ struct starpu_sched_component_fifo_data fifo_data =
|
|
|
{
|
|
|
- fifo_below = starpu_sched_component_fifo_create(t, &fifo_data);
|
|
|
- }
|
|
|
- starpu_sched_component_connect(last, fifo_below);
|
|
|
- last = fifo_below;
|
|
|
- }
|
|
|
- switch (flags & STARPU_SCHED_SIMPLE_DECIDE_MASK)
|
|
|
+ .ntasks_threshold = ntasks_threshold,
|
|
|
+ .exp_len_threshold = exp_len_threshold,
|
|
|
+ .ready = ready,
|
|
|
+ };
|
|
|
+
|
|
|
+ /* Create one fifo+eager component pair per choice, below scheduling decision */
|
|
|
+ for(i = 0; i < nbelow; i++)
|
|
|
{
|
|
|
- case STARPU_SCHED_SIMPLE_DECIDE_WORKERS:
|
|
|
- /* 1-1 mapping between choice and worker, no need for an eager component */
|
|
|
- n = 1;
|
|
|
- break;
|
|
|
- case STARPU_SCHED_SIMPLE_DECIDE_MEMNODES:
|
|
|
- n = 0;
|
|
|
- for (j = 0; j < starpu_worker_get_count() + starpu_combined_worker_get_count(); j++)
|
|
|
- if (starpu_worker_get_memory_node(j) == below_id[i])
|
|
|
- n++;
|
|
|
- break;
|
|
|
- case STARPU_SCHED_SIMPLE_DECIDE_ARCHS:
|
|
|
- n = starpu_worker_get_count_by_type(i);
|
|
|
- break;
|
|
|
- default:
|
|
|
- STARPU_ABORT();
|
|
|
- }
|
|
|
- STARPU_ASSERT(n >= 1);
|
|
|
- if (n > 1) {
|
|
|
- /* Several workers for this choice, need to introduce
|
|
|
- * a component to distribute the work */
|
|
|
- struct starpu_sched_component *distribute;
|
|
|
- if (flags & STARPU_SCHED_SIMPLE_WS_BELOW)
|
|
|
+ last = decision_component;
|
|
|
+
|
|
|
+ if (flags & STARPU_SCHED_SIMPLE_FIFOS_BELOW
|
|
|
+ && !(decide_flags == STARPU_SCHED_SIMPLE_DECIDE_WORKERS
|
|
|
+ && i >= starpu_worker_get_count()))
|
|
|
{
|
|
|
- distribute = starpu_sched_component_work_stealing_create(t, NULL);
|
|
|
+ struct starpu_sched_component *fifo_below;
|
|
|
+ if (flags & STARPU_SCHED_SIMPLE_FIFOS_BELOW_PRIO)
|
|
|
+ {
|
|
|
+ fifo_below = starpu_sched_component_prio_create(t, &prio_data);
|
|
|
+ }
|
|
|
+ else
|
|
|
+ {
|
|
|
+ fifo_below = starpu_sched_component_fifo_create(t, &fifo_data);
|
|
|
+ }
|
|
|
+ starpu_sched_component_connect(last, fifo_below);
|
|
|
+ last = fifo_below;
|
|
|
}
|
|
|
- else
|
|
|
+ switch (decide_flags)
|
|
|
{
|
|
|
- distribute = starpu_sched_component_eager_create(t, NULL);
|
|
|
+ case STARPU_SCHED_SIMPLE_DECIDE_WORKERS:
|
|
|
+ /* 1-1 mapping between choice and worker, no need for an eager component */
|
|
|
+ n = 1;
|
|
|
+ break;
|
|
|
+ case STARPU_SCHED_SIMPLE_DECIDE_MEMNODES:
|
|
|
+ n = 0;
|
|
|
+ for (j = 0; j < starpu_worker_get_count() + starpu_combined_worker_get_count(); j++)
|
|
|
+ if (starpu_worker_get_memory_node(j) == below_id[i])
|
|
|
+ n++;
|
|
|
+ break;
|
|
|
+ case STARPU_SCHED_SIMPLE_DECIDE_ARCHS:
|
|
|
+ n = starpu_worker_get_count_by_type(i);
|
|
|
+ break;
|
|
|
+ default:
|
|
|
+ STARPU_ABORT();
|
|
|
+ }
|
|
|
+ STARPU_ASSERT(n >= 1);
|
|
|
+ if (n > 1) {
|
|
|
+ /* Several workers for this choice, need to introduce
|
|
|
+ * a component to distribute the work */
|
|
|
+ struct starpu_sched_component *distribute;
|
|
|
+ if (flags & STARPU_SCHED_SIMPLE_WS_BELOW)
|
|
|
+ {
|
|
|
+ distribute = starpu_sched_component_work_stealing_create(t, NULL);
|
|
|
+ }
|
|
|
+ else
|
|
|
+ {
|
|
|
+ distribute = starpu_sched_component_eager_create(t, NULL);
|
|
|
+ }
|
|
|
+
|
|
|
+ starpu_sched_component_connect(last, distribute);
|
|
|
+ last = distribute;
|
|
|
}
|
|
|
|
|
|
- starpu_sched_component_connect(last, distribute);
|
|
|
- last = distribute;
|
|
|
+ if (ndecisions != 1)
|
|
|
+ /* Connect to stage component */
|
|
|
+ starpu_sched_component_connect(last, last_below[i]);
|
|
|
+ else
|
|
|
+ /* Directly let it connected to worker */
|
|
|
+ last_below[i] = last;
|
|
|
}
|
|
|
- last_below[i] = last;
|
|
|
}
|
|
|
+ va_end(varg_list);
|
|
|
|
|
|
/* Finish by creating components per worker */
|
|
|
for(i = 0; i < starpu_worker_get_count() + starpu_combined_worker_get_count(); i++)
|
|
|
@@ -308,7 +374,7 @@ void starpu_sched_component_initialize_simple_scheduler(starpu_sched_component_c
|
|
|
worker = impl_component;
|
|
|
}
|
|
|
|
|
|
- switch (flags & STARPU_SCHED_SIMPLE_DECIDE_MASK)
|
|
|
+ switch (decide_flags)
|
|
|
{
|
|
|
case STARPU_SCHED_SIMPLE_DECIDE_WORKERS:
|
|
|
id = i;
|
|
|
@@ -334,6 +400,7 @@ void starpu_sched_component_initialize_simple_scheduler(starpu_sched_component_c
|
|
|
starpu_sched_component_connect(last, worker);
|
|
|
|
|
|
/* Plug perfmodel calibrator if requested */
|
|
|
+ /* FIXME: this won't work with several scheduling decisions */
|
|
|
if (flags & STARPU_SCHED_SIMPLE_PERFMODEL)
|
|
|
{
|
|
|
starpu_sched_component_connect(no_perfmodel_component, worker);
|
|
|
@@ -345,3 +412,8 @@ void starpu_sched_component_initialize_simple_scheduler(starpu_sched_component_c
|
|
|
starpu_sched_tree_update_workers(t);
|
|
|
starpu_sched_tree_update_workers_in_ctx(t);
|
|
|
}
|
|
|
+
|
|
|
+void starpu_sched_component_initialize_simple_scheduler(starpu_sched_component_create_t create_decision_component, void *data, unsigned flags, unsigned sched_ctx_id)
|
|
|
+{
|
|
|
+ starpu_sched_component_initialize_simple_schedulers(sched_ctx_id, 1, create_decision_component, data, flags);
|
|
|
+}
|
