|
@@ -1135,7 +1135,7 @@ int _starpu_fetch_task_input(struct starpu_task *task, struct _starpu_job *j, in
|
|
if (async)
|
|
if (async)
|
|
{
|
|
{
|
|
ret = _starpu_fetch_data_on_node(handle, node, local_replicate, mode, 0, task, STARPU_FETCH, 1,
|
|
ret = _starpu_fetch_data_on_node(handle, node, local_replicate, mode, 0, task, STARPU_FETCH, 1,
|
|
- _starpu_fetch_task_input_cb, worker, 0, "_starpu_fetch_task_input");
|
|
|
|
|
|
+ _starpu_fetch_task_input_cb, worker, task->priority, "_starpu_fetch_task_input");
|
|
#ifdef STARPU_SIMGRID
|
|
#ifdef STARPU_SIMGRID
|
|
if (_starpu_simgrid_fetching_input_cost())
|
|
if (_starpu_simgrid_fetching_input_cost())
|
|
starpu_sleep(0.000001);
|
|
starpu_sleep(0.000001);
|
|
@@ -1150,7 +1150,7 @@ int _starpu_fetch_task_input(struct starpu_task *task, struct _starpu_job *j, in
|
|
}
|
|
}
|
|
else
|
|
else
|
|
{
|
|
{
|
|
- ret = fetch_data(handle, node, local_replicate, mode, task, 0);
|
|
|
|
|
|
+ ret = fetch_data(handle, node, local_replicate, mode, task, task->priority);
|
|
#ifdef STARPU_SIMGRID
|
|
#ifdef STARPU_SIMGRID
|
|
if (_starpu_simgrid_fetching_input_cost())
|
|
if (_starpu_simgrid_fetching_input_cost())
|
|
starpu_sleep(0.000001);
|
|
starpu_sleep(0.000001);
|