[PATCH 04/14] add gsync tests

[Luca Dariz]

---
 tests/test-gsync.c | 87 ++++++++++++++++++++++++++++++++++++++++++++++
 1 file changed, 87 insertions(+)
 create mode 100644 tests/test-gsync.c

diff --git a/tests/test-gsync.c b/tests/test-gsync.c
new file mode 100644
index 00000000..80701606
--- /dev/null
+++ b/tests/test-gsync.c
@@ -0,0 +1,87 @@
+
+#include <syscalls.h>
+#include <testlib.h>
+
+#include <mach/machine/vm_param.h>
+#include <mach/std_types.h>
+#include <mach/mach_types.h>
+#include <mach/vm_wire.h>
+
+#include <mach.user.h>
+#include <gnumach.user.h>
+
+/* Gsync flags.  */
+#ifndef GSYNC_SHARED
+# define GSYNC_SHARED      0x01
+# define GSYNC_QUAD        0x02
+# define GSYNC_TIMED       0x04
+# define GSYNC_BROADCAST   0x08
+# define GSYNC_MUTATE      0x10
+#endif
+
+static uint32_t single_shared;
+static uint64_t single_shared_quad;
+
+static void single_t2(void *arg)
+{
+  int err;
+  msleep(100);
+  err = gsync_wake(mach_task_self(), (vm_offset_t)&single_shared, 0, 0);
+  ASSERT_RET(err, "gsync_wake t2");
+
+  err = thread_terminate(mach_thread_self());
+  ASSERT_RET(err, "thread_terminate");
+}
+
+static void test_single()
+{
+  int err;
+  single_shared = 0;
+  err = gsync_wait(mach_task_self(), (vm_offset_t)&single_shared, 0, 0, 100, 
GSYNC_TIMED);
+  ASSERT(err == KERN_TIMEDOUT, "gsync_wait 1");
+
+  single_shared = 1;
+  err = gsync_wait(mach_task_self(), (vm_offset_t)&single_shared, 0, 0, 100, 
GSYNC_TIMED);
+  ASSERT(err == KERN_INVALID_ARGUMENT, "gsync_wait 2");
+  err = gsync_wait(mach_task_self(), (vm_offset_t)&single_shared, 1, 0, 100, 
GSYNC_TIMED);
+  ASSERT(err == KERN_TIMEDOUT, "gsync_wait 2b");
+
+  err = gsync_wake(mach_task_self(), (vm_offset_t)&single_shared, 0, 0);
+  ASSERT_RET(err, "gsync_wake 1");
+
+  err = gsync_wake(mach_task_self(), (vm_offset_t)&single_shared, 0, 
GSYNC_BROADCAST);
+  ASSERT_RET(err, "gsync_wake 2");
+
+  err = gsync_wake(mach_task_self(), (vm_offset_t)&single_shared, 2, 
GSYNC_MUTATE);
+  ASSERT_RET(err, "gsync_wake 2a");
+  ASSERT(single_shared == 2, "gsync_wake single_shared");
+
+  err = gsync_wake(mach_task_self(), (vm_offset_t)&single_shared, 0, 0);
+  ASSERT_RET(err, "gsync_wake 3");
+  err = gsync_wake(mach_task_self(), (vm_offset_t)&single_shared, 0, 0);
+  ASSERT_RET(err, "gsync_wake 3a");
+
+  single_shared = 1;
+  test_thread_start(mach_task_self(), single_t2, 0);
+  err = gsync_wait(mach_task_self(), (vm_offset_t)&single_shared, 1, 0, 0, 0);
+  ASSERT_RET(err, "gsync_wait 4");
+}
+
+static void test_single2()
+{
+  int err;
+  test_thread_start(mach_task_self(), single_t2, 0);
+  single_shared = 2;
+  err = gsync_wait(mach_task_self(), (vm_offset_t)&single_shared, 2, 0, 0, 0);
+  ASSERT_RET(err, "gsync_wait 1");
+  // should this fail?
+  err = gsync_wake(mach_task_self(), (vm_offset_t)&single_shared, 0, 0);
+  ASSERT_RET(err, "gsync_wake 2");
+}
+
+int main(int argc, char *argv[], int envc, char *envp[])
+{
+  test_single2();
+  test_single();
+  return 0;
+}
-- 
2.39.2