From 1ff2c00399df96359274ca58a1f6f9180d0f09c4 Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?Nils=20O=2E=20Sel=C3=A5sdal?= <noselasd@box.fiane.intra>
Date: Tue, 11 Dec 2012 16:49:34 +0100
Subject: [PATCH] thread_queue signal test

---
 test/threadqueue_signal.c | 70 +++++++++++++++++++++++++++++++++++++++
 1 file changed, 70 insertions(+)
 create mode 100644 test/threadqueue_signal.c

diff --git a/test/threadqueue_signal.c b/test/threadqueue_signal.c
new file mode 100644
index 0000000..7a95528
--- /dev/null
+++ b/test/threadqueue_signal.c
@@ -0,0 +1,70 @@
+
+#include <stdio.h>
+#include <stdlib.h>
+#include <signal.h>
+#include <ucore/ucore_threadqueue.h>
+
+struct uc_threadqueue queue;
+
+
+struct my_msg {
+    struct uc_threadmsg uc_msg;
+    int sig;
+};
+
+void *handler(void *arg)
+{
+    for (;;) {
+        struct uc_threadmsg *msg;
+        struct my_msg *my;
+        if (uc_thread_queue_get(&queue, NULL, &msg) != 0) {
+            printf("uc_threadqueue_get failed\n");
+            return NULL;
+        }
+        my = (struct my_msg*)msg;
+        printf("handler got signal %d\n", my->sig);
+        free(my);
+    }
+
+
+    return NULL;
+}
+
+int main(int argc, char *argv[])
+{
+    pthread_t tid1,tid2;
+    int i;
+    sigset_t set;
+    sigset_t oldset;
+    sigemptyset(&set);
+    sigaddset(&set, SIGUSR1);
+    sigaddset(&set, SIGUSR2);
+    sigaddset(&set, SIGHUP);
+
+    if(pthread_sigmask(SIG_BLOCK, &set, &oldset) != 0) {
+        perror("pthread_sigmask 1");
+    }
+
+    uc_thread_queue_init(&queue, 1);
+
+    if (pthread_create(&tid2, NULL, handler, NULL) != 0) {
+        perror("pthread_create");
+        return 1;
+    }
+
+
+    for (;;) {
+        int sig;
+        if(sigwait(&set, &sig) != 0) {
+            perror("sigwait");
+            break;
+        }
+        struct my_msg *msg = malloc(sizeof *msg);
+        msg->sig = sig;
+        uc_thread_queue_add(&queue, msg);
+
+    
+    }
+
+    return 0;
+}