|
|
@@ -390,6 +390,7 @@ struct starpu_task *_starpu_get_worker_task(struct _starpu_worker *worker, int w
|
|
|
_starpu_worker_leave_sched_op(worker);
|
|
|
STARPU_PTHREAD_COND_BROADCAST(&worker->sched_cond);
|
|
|
|
|
|
+#ifndef STARPU_NON_BLOCKING_DRIVERS
|
|
|
int cond_no_keep_awake = !worker->state_keep_awake;
|
|
|
int cond_can_block = _starpu_worker_can_block(memnode, worker);
|
|
|
int cond_no_last_awake = !_starpu_sched_ctx_last_worker_awake(worker);
|
|
|
@@ -431,6 +432,7 @@ struct starpu_task *_starpu_get_worker_task(struct _starpu_worker *worker, int w
|
|
|
STARPU_PTHREAD_MUTEX_UNLOCK_SCHED(&worker->sched_mutex);
|
|
|
}
|
|
|
else
|
|
|
+#endif
|
|
|
{
|
|
|
//_STARPU_DEBUG("worker %u wont sleep: %d|%d|%d|%d|%d\n", worker->workerid, cond_no_keep_awake, cond_can_block, cond_no_last_awake, cond_no_block_in_parallel_rq, cond_no_unblock_in_parallel_rq);
|
|
|
_starpu_worker_set_status_scheduling_done(workerid);
|
