From: Julian Seward <jseward@acm.org>
Date: Sun, 17 Dec 2006 17:40:06 +0000 (+0000)
Subject: Add locking so this produces repeatable results (Bart Van Assche).
X-Git-Tag: svn/VALGRIND_3_3_0~479
X-Git-Url: http://git.ipfire.org/cgi-bin/gitweb.cgi?a=commitdiff_plain;h=c8ecd6a81fb5418b0671eb9dde9621af987213f2;p=thirdparty%2Fvalgrind.git

Add locking so this produces repeatable results (Bart Van Assche).


git-svn-id: svn://svn.valgrind.org/valgrind/trunk@6407
---

diff --git a/none/tests/pth_detached.c b/none/tests/pth_detached.c
index 237cef454c..fa27b6fad4 100644
--- a/none/tests/pth_detached.c
+++ b/none/tests/pth_detached.c
@@ -8,20 +8,37 @@
 #include <stdlib.h>
 #include <unistd.h>
 
-static int s_finished_count;
+static int s_finished_count = 0;
+static pthread_spinlock_t s_spinlock;
+
+void increment_finished_count()
+{
+  pthread_spin_lock(&s_spinlock);
+  s_finished_count++;
+  pthread_spin_unlock(&s_spinlock);
+}
+
+int get_finished_count()
+{
+  int result;
+  pthread_spin_lock(&s_spinlock);
+  result = s_finished_count;
+  pthread_spin_unlock(&s_spinlock);
+  return result;
+}
 
 static void* thread_func1(void* arg)
 {
   write(STDOUT_FILENO, ".", 1);
-  s_finished_count++;
+  increment_finished_count();
   return 0;
 }
 
 static void* thread_func2(void* arg)
 {
   pthread_detach(pthread_self());
-  write(STDOUT_FILENO, "*", 1);
-  s_finished_count++;
+  write(STDOUT_FILENO, ".", 1);
+  increment_finished_count();
   return 0;
 }
 
@@ -32,7 +49,9 @@ int main(int argc, char** argv)
   int i;
   int detachstate;
   pthread_attr_t attr;
-  
+
+  pthread_spin_init(&s_spinlock, 0);
+
   pthread_attr_init(&attr);
   pthread_attr_setdetachstate(&attr, PTHREAD_CREATE_DETACHED);
   assert(pthread_attr_getdetachstate(&attr, &detachstate) == 0);
@@ -57,12 +76,15 @@ int main(int argc, char** argv)
   pthread_attr_destroy(&attr);
 
   // Wait until all detached threads have written their output to stdout.
-  while (s_finished_count < count1 + count2)
+  while (get_finished_count() < count1 + count2)
   {
     struct timespec delay = { 0, 1 * 1000 * 1000 };
     nanosleep(&delay, 0);
   }
 
   printf("\n");
+
+  pthread_spin_destroy(&s_spinlock);
+
   return 0;
 }
diff --git a/none/tests/pth_detached.stdout.exp b/none/tests/pth_detached.stdout.exp
index 8dae8ec843..0ced6c1a8b 100644
--- a/none/tests/pth_detached.stdout.exp
+++ b/none/tests/pth_detached.stdout.exp
@@ -1 +1 @@
-....................................................................................................****************************************************************************************************
+........................................................................................................................................................................................................