Browse Source

Use the PTHREAD_COND_SIGNAL to check if there are errors.

Cédric Augonnet 14 years ago
parent
commit
e8d1dd8a10

+ 1 - 1
src/core/workers.c

@@ -419,7 +419,7 @@ void starpu_shutdown(void)
 	PTHREAD_MUTEX_LOCK(&init_mutex);
 	initialized = UNINITIALIZED;
 	/* Let someone else that wants to initialize it again do it */
-	pthread_cond_signal(&init_cond);
+	PTHREAD_COND_SIGNAL(&init_cond);
 	PTHREAD_MUTEX_UNLOCK(&init_mutex);
 }
 

+ 1 - 1
src/sched_policies/deque_modeling_policy_data_aware.c

@@ -255,7 +255,7 @@ int _starpu_fifo_push_sorted_task(struct starpu_fifo_taskq_s *fifo_queue, pthrea
 	fifo_queue->ntasks++;
 	fifo_queue->nprocessed++;
 
-	pthread_cond_signal(sched_cond);
+	PTHREAD_COND_SIGNAL(sched_cond);
 	PTHREAD_MUTEX_UNLOCK(sched_mutex);
 
 	return 0;

+ 2 - 2
src/sched_policies/fifo_queues.c

@@ -54,7 +54,7 @@ int _starpu_fifo_push_prio_task(struct starpu_fifo_taskq_s *fifo_queue, pthread_
 	fifo_queue->ntasks++;
 	fifo_queue->nprocessed++;
 
-	pthread_cond_signal(sched_cond);
+	PTHREAD_COND_SIGNAL(sched_cond);
 	PTHREAD_MUTEX_UNLOCK(sched_mutex);
 
 	return 0;
@@ -69,7 +69,7 @@ int _starpu_fifo_push_task(struct starpu_fifo_taskq_s *fifo_queue, pthread_mutex
 	fifo_queue->ntasks++;
 	fifo_queue->nprocessed++;
 
-	pthread_cond_signal(sched_cond);
+	PTHREAD_COND_SIGNAL(sched_cond);
 	PTHREAD_MUTEX_UNLOCK(sched_mutex);
 
 	return 0;