From 73f1bbae2afaa1644a6cf6063998e2bff82a25c3 Mon Sep 17 00:00:00 2001
From: Michael Ploujnikov <ploujj@gmail.com>
Date: Mon, 1 Feb 2010 17:02:24 -0500
Subject: [PATCH] added two sync tests one with a single thread and one with
 100 randomly sleeping ones

---
 tests/30backend-threadpool.tests | 11 ++++++
 tests/backend/test-threadpool.c  | 61 ++++++++++++++++++++++++++++++++
 2 files changed, 72 insertions(+)

diff --git a/tests/30backend-threadpool.tests b/tests/30backend-threadpool.tests
index 23c4d456a..b356c1b19 100644
--- a/tests/30backend-threadpool.tests
+++ b/tests/30backend-threadpool.tests
@@ -25,4 +25,15 @@ END
 TEST "many sleepy threads" many-sleepy-threads <<END
 END
 
+TEST "simple sync" simple-sync <<END
+err: syncing with the other thread
+err: the other thread received its arguments
+err: result is 0
+END
+
+TEST "sync many" sync-many <<END
+err: result is 0
+err: value is 84
+END
+
 PLANNED "error cleared on join"
diff --git a/tests/backend/test-threadpool.c b/tests/backend/test-threadpool.c
index 7609a144e..10ee17fe4 100644
--- a/tests/backend/test-threadpool.c
+++ b/tests/backend/test-threadpool.c
@@ -54,6 +54,25 @@ void sleep_fn(void * arg)
   *(int *)arg = result;
 }
 
+
+void other_fn(void * arg)
+{
+  int input = *(int *)arg;
+  lumiera_thread_sync (); // the main thread can discard the argument storage
+  input -= 42;
+  ECHO ("result is %d", input);
+}
+
+void sleeping_worker_fn(void * arg)
+{
+  int input = *(int *)arg;
+  int delay = rand () % 100000;
+  usleep (delay);
+  lumiera_thread_sync (); // the main thread can discard the argument storage
+  input -= 42;
+  ECHO ("result is %d", input);
+}
+
 TESTS_BEGIN
 
 TEST ("threadpool-basic")
@@ -226,4 +245,46 @@ TEST ("many-random-sleepy-threads (compiletest only)")
   lumiera_threadpool_destroy();
 }
 
+TEST ("simple-sync")
+{
+  lumiera_threadpool_init ();
+
+  int value = 42;
+
+  LumieraThread other = lumiera_thread_run (LUMIERA_THREADCLASS_IDLE,
+					     &other_fn,
+					     (void *)&value,
+					     "other thread",
+					     &NOBUG_FLAG (test));
+
+  ECHO ("syncing with the other thread");
+  lumiera_thread_sync_other (other);
+  ECHO ("the other thread received its arguments");
+  value += 42;
+
+  lumiera_threadpool_destroy ();
+}
+
+TEST ("sync-many")
+{
+  lumiera_threadpool_init ();
+
+  int value = 42;
+  int workers = 100;
+  LumieraThread threads[workers];
+
+  for (int i = 0; i < workers; i++)
+    {
+      threads[i] = lumiera_thread_run (LUMIERA_THREADCLASS_IDLE,
+				       &sleeping_worker_fn,
+				       (void *)&value,
+				       "worker thread",
+				       &NOBUG_FLAG (test));
+      lumiera_thread_sync_other (threads[i]);
+    }
+  value += 42;
+  ECHO ("value is %d", value);
+  lumiera_threadpool_destroy ();
+}
+
 TESTS_END