|
@@ -130,7 +130,7 @@ int _starpu_barrier_counter_increment_until_full_counter(struct _starpu_barrier_
|
|
{
|
|
{
|
|
/* have those not happy enough tell us how much again */
|
|
/* have those not happy enough tell us how much again */
|
|
barrier_c->min_threshold = 0;
|
|
barrier_c->min_threshold = 0;
|
|
- STARPU_PTHREAD_COND_BROADCAST(&barrier->cond);
|
|
|
|
|
|
+ STARPU_PTHREAD_COND_BROADCAST(&barrier_c->cond2);
|
|
}
|
|
}
|
|
|
|
|
|
STARPU_PTHREAD_MUTEX_UNLOCK(&barrier->mutex);
|
|
STARPU_PTHREAD_MUTEX_UNLOCK(&barrier->mutex);
|
|
@@ -144,6 +144,7 @@ int _starpu_barrier_counter_increment(struct _starpu_barrier_counter *barrier_c,
|
|
|
|
|
|
barrier->reached_start++;
|
|
barrier->reached_start++;
|
|
barrier->reached_flops += flops;
|
|
barrier->reached_flops += flops;
|
|
|
|
+ STARPU_PTHREAD_COND_BROADCAST(&barrier_c->cond2);
|
|
STARPU_PTHREAD_MUTEX_UNLOCK(&barrier->mutex);
|
|
STARPU_PTHREAD_MUTEX_UNLOCK(&barrier->mutex);
|
|
return 0;
|
|
return 0;
|
|
}
|
|
}
|