Test inserting priority messages

test/test_threadqueue.c

@@ -54,6 +54,32 @@ START_TEST (test_thread_queue_one_thread)
 
 END_TEST
 
+START_TEST (test_thread_queue_priority_msg)
+
+    struct uc_threadqueue queue;
+    int i;
+
+    struct uc_threadmsg msg[3];
+    memset(&msg, 0, sizeof msg);
+
+    fail_if(uc_thread_queue_init(&queue, 3) != 0);
+
+
+    for (i = 0; i < 3; i++) {
+        msg[i].msgtype = -1; //negative == add at head
+        fail_if(uc_thread_queue_add(&queue, &msg[i]) != 0);
+    }
+
+    for (i = 2; i >= 0; i--) {
+        struct uc_threadmsg *my_msg;
+        fail_if(uc_thread_queue_get(&queue, &my_msg) != 0);
+        
+        fail_if(my_msg != &msg[i]);
+    }
+
+    fail_if(uc_thread_queue_destroy(&queue, NULL, NULL) != 0);
+
+END_TEST
 
 
 
@@ -350,6 +376,7 @@ Suite *threadqueue_suite(void)
 
     tcase_add_test(tc1, test_thread_queue_length);
     tcase_add_test(tc1, test_thread_queue_one_thread);
+    tcase_add_test(tc1, test_thread_queue_priority_msg);
     tcase_add_test(tc1, test_thread_queue_walk);
     tcase_add_test(tc1, test_thread_queue_reader_writer);
     tcase_add_test(tc1, test_thread_queue_reader_writer_len_1);