machinarium: add condition tests

test-suite/machinarium_test.c

@@ -17,6 +17,8 @@ extern void test_sleep_cancel0(void);
 extern void test_sleep_cancel1(void);
 
 extern void test_wait(void);
+extern void test_condition0(void);
+extern void test_condition1(void);
 
 int
 main(int argc, char *argv[])
@@ -28,5 +30,7 @@ main(int argc, char *argv[])
 	machinarium_test(test_sleep_cancel0);
 	machinarium_test(test_sleep_cancel1);
 	machinarium_test(test_wait);
+	machinarium_test(test_condition0);
+	machinarium_test(test_condition1);
 	return 0;
 }

test-suite/makefile

@@ -11,7 +11,9 @@ OBJECTS    = machinarium_test.o \
              test_sleep_yield.o \
              test_sleep_cancel0.o \
              test_sleep_cancel1.o \
-             test_wait.o
+             test_wait.o \
+             test_condition0.o \
+             test_condition1.o
 all: clean $(OBJECTS) machinarium_test
 machinarium_test:
 	$(CC) $(OBJECTS) $(LFLAGS) -o machinarium_test

test-suite/test_condition0.c

@@ -0,0 +1,53 @@
+
+/*
+ * machinarium.
+ *
+ * Cooperative multitasking engine.
+*/
+
+#include <machinarium.h>
+#include <machinarium_test.h>
+
+static void
+test_condition_fiber(void *arg)
+{
+	machine_t machine = arg;
+	int rc = machine_condition(machine, 1000);
+	test(rc == 0);
+}
+
+static void
+test_waiter(void *arg)
+{
+	machine_t machine = arg;
+
+	int64_t a;
+	a = machine_create_fiber(machine, test_condition_fiber, machine);
+	test(a != -1);
+
+	machine_sleep(machine, 0);
+
+	int rc;
+	rc = machine_signal(machine, a);
+	test(rc != -1);
+
+	machine_sleep(machine, 0);
+
+	machine_stop(machine);
+}
+
+void
+test_condition0(void)
+{
+	machine_t machine = machine_create();
+	test(machine != NULL);
+
+	int rc;
+	rc = machine_create_fiber(machine, test_waiter, machine);
+	test(rc != -1);
+
+	machine_start(machine);
+
+	rc = machine_free(machine);
+	test(rc != -1);
+}

test-suite/test_condition1.c

@@ -0,0 +1,51 @@
+
+/*
+ * machinarium.
+ *
+ * Cooperative multitasking engine.
+*/
+
+#include <machinarium.h>
+#include <machinarium_test.h>
+
+static void
+test_condition_fiber(void *arg)
+{
+	machine_t machine = arg;
+	int rc = machine_condition(machine, 1);
+	test(rc == -1);
+}
+
+static void
+test_waiter(void *arg)
+{
+	machine_t machine = arg;
+
+	int64_t a;
+	a = machine_create_fiber(machine, test_condition_fiber, machine);
+	test(a != -1);
+
+	machine_sleep(machine, 100);
+
+	int rc;
+	rc = machine_signal(machine, a);
+	test(rc == -1);
+
+	machine_stop(machine);
+}
+
+void
+test_condition1(void)
+{
+	machine_t machine = machine_create();
+	test(machine != NULL);
+
+	int rc;
+	rc = machine_create_fiber(machine, test_waiter, machine);
+	test(rc != -1);
+
+	machine_start(machine);
+
+	rc = machine_free(machine);
+	test(rc != -1);
+}