From: Arnaud Giersch <arnaud.giersch@iut-bm.univ-fcomte.fr>
Date: Wed, 8 Feb 2012 22:53:27 +0000 (+0100)
Subject: Parmap: use INT_MAX as number of threads to wake by futex_wake.
X-Git-Tag: exp_20120216~34
X-Git-Url: http://info.iut-bm.univ-fcomte.fr/pub/gitweb/simgrid.git/commitdiff_plain/7e6a623d771b9ef0f6e3f893ba9213154d07bc54

Parmap: use INT_MAX as number of threads to wake by futex_wake.

We want to wake up everybody anyway.
---

diff --git a/src/xbt/parmap.c b/src/xbt/parmap.c
index 41bf72392f..103fe7fddf 100644
--- a/src/xbt/parmap.c
+++ b/src/xbt/parmap.c
@@ -12,6 +12,7 @@
 
 #ifdef HAVE_FUTEX_H
 #include <linux/futex.h>
+#include <limits.h>
 #endif
 
 #include "xbt/parmap.h"
@@ -383,7 +384,7 @@ static void xbt_parmap_futex_worker_signal(xbt_parmap_t parmap)
   unsigned count = __sync_add_and_fetch(&parmap->thread_counter, 1);
   if (count == parmap->num_workers) {
     /* all workers have finished, wake the controller */
-    futex_wake(&parmap->thread_counter, 1);
+    futex_wake(&parmap->thread_counter, INT_MAX);
   }
 }
 
@@ -399,7 +400,7 @@ static void xbt_parmap_futex_master_signal(xbt_parmap_t parmap)
   parmap->thread_counter = 1;
   __sync_add_and_fetch(&parmap->work, 1);
   /* wake all workers */
-  futex_wake(&parmap->work, parmap->num_workers - 1);
+  futex_wake(&parmap->work, INT_MAX);
 }
 
 /**