|
|
@@ -44,11 +44,11 @@ static int _starpu_src_common_finalize_job (struct _starpu_job *j, struct _starp
|
|
|
{
|
|
|
struct _starpu_combined_worker * cb_worker = _starpu_get_combined_worker_struct(worker->combined_workerid);
|
|
|
|
|
|
- starpu_pthread_mutex_lock(&cb_worker->count_mutex);
|
|
|
+ STARPU_PTHREAD_MUTEX_LOCK(&cb_worker->count_mutex);
|
|
|
count = cb_worker->count--;
|
|
|
if(count == 0)
|
|
|
cb_worker->count = cb_worker->worker_size - 1;
|
|
|
- starpu_pthread_mutex_unlock(&cb_worker->count_mutex);
|
|
|
+ STARPU_PTHREAD_MUTEX_UNLOCK(&cb_worker->count_mutex);
|
|
|
}
|
|
|
|
|
|
/* Finalize the execution */
|
