Wrote a test around the mpsc_queue

[sandbox] / vm / mpsc_queue_test.c

diff --git a/vm/mpsc_queue_test.c b/vm/mpsc_queue_test.c
new file mode 100644 (file)
index 0000000..be869c8
--- /dev/null
+++ b/vm/mpsc_queue_test.c
@@ -0,0 +1,59 @@
+#include <assert.h>
+#include <stdio.h>
+
+#include "mpsc_queue.c"
+
+void noopFreer(void* _) { }
+
+bool test_single_threaded()
+{
+  Queue queue;
+  initializeQueue(&queue);
+
+  int inputs[] = { 0, 1, 2, 3, 4, 5, 6, 7, 8, 9 };
+
+  for(int i = 0; i < 10; i++)
+  {
+    enqueue(&queue, &(inputs[i]));
+  }
+
+  int* outputs[10];
+  int index = 0;
+
+  while(!isEmpty(&queue))
+  {
+    outputs[index++] = dequeue(&queue);
+  }
+
+  for(int i = 0; i < 10; i++)
+  {
+    assert(i == *(outputs[i]));
+  }
+
+  freeQueue(&queue, noopFreer);
+
+  return true;
+}
+
+int main(int argc, char** argv)
+{
+  #define TEST_COUNT 1
+  bool (*tests[TEST_COUNT])() = {
+    test_single_threaded
+  };
+
+  for(int i = 0; i < TEST_COUNT; i++)
+  {
+    if(tests[i]())
+    {
+      printf(".");
+    }
+
+    else
+    {
+      printf("F");
+    }
+  }
+
+  return EXIT_SUCCESS;
+}