|
@@ -982,7 +982,7 @@ static void dmda_post_exec_hook(struct starpu_task * task)
|
|
|
{
|
|
|
|
|
|
struct _starpu_dmda_data *dt = (struct _starpu_dmda_data*)starpu_sched_ctx_get_policy_data(task->sched_ctx);
|
|
|
- unsigned workerid = task->workerid;
|
|
|
+ int workerid = starpu_worker_get_id();
|
|
|
struct _starpu_fifo_taskq *fifo = dt->queue_array[workerid];
|
|
|
starpu_pthread_mutex_t *sched_mutex;
|
|
|
starpu_pthread_cond_t *sched_cond;
|