changes

[cdsspec-compiler.git] / benchmark / ms-queue / main.c

diff --git a/benchmark/ms-queue/main.c b/benchmark/ms-queue/main.c
index b541b010c2837d04e798b6db73a2eb4d3dbc4f31..63846670512c3f5e9ff64b36a4ca54d00a712011 100644 (file)
--- a/benchmark/ms-queue/main.c
+++ b/benchmark/ms-queue/main.c
@@ -19,34 +19,63 @@ int get_thread_num()
        for (i = 0; i < num_threads; i++)
                if (curr.priv == threads[i].priv)
                        return i;
-       MODEL_ASSERT(0);
+       //MODEL_ASSERT(0);
        return -1;
 }
 
+bool succ1, succ2;
+
 static void main_task(void *param)
 {
+
        unsigned int val;
        int pid = *((int *)param);
-
+/*
        if (!pid) {
                input[0] = 17;
-               enqueue(queue, input[0]);
-               output[0] = dequeue(queue);
+               succ1 = dequeue(queue, &input[0]);
        } else {
                input[1] = 37;
                enqueue(queue, input[1]);
-               output[1] = dequeue(queue);
+       }
+*/
+       if (pid % 2 == 0) {
+               input[0] = 17;
+               enqueue(queue, input[0]);
+               printf("Thrd %d Enqueue %d.\n", get_thread_num(), input[0]);
+               
+               succ1 = dequeue(queue, &output[0]);
+               if (succ1)
+                       printf("Thrd %d: Dequeue %d.\n", get_thread_num(), output[0]);
+               else
+                       printf("Thrd %d: Dequeue NULL.\n", get_thread_num());
+               
+       } else if (pid % 2 == 1) {
+               input[1] = 37;
+               enqueue(queue, input[1]);
+               printf("Thrd %d Enqueue %d.\n", get_thread_num(), input[1]);
+               
+               succ2 = dequeue(queue, &output[1]);
+               if (succ2)
+                       printf("Thrd %d: Dequeue %d.\n", get_thread_num(), output[1]);
+               else
+                       printf("Thrd %d: Dequeue NULL.\n", get_thread_num());
        }
 }
 
 int user_main(int argc, char **argv)
 {
+       /**
+               @Begin
+               @Entry_point
+               @End
+       */
        int i;
        int *param;
        unsigned int in_sum = 0, out_sum = 0;
 
        queue = calloc(1, sizeof(*queue));
-       MODEL_ASSERT(queue);
+       //MODEL_ASSERT(queue);
 
        num_threads = procs;
        threads = malloc(num_threads * sizeof(thrd_t));
@@ -61,7 +90,7 @@ int user_main(int argc, char **argv)
        }
        for (i = 0; i < num_threads; i++)
                thrd_join(threads[i]);
-
+/*
        for (i = 0; i < num_threads; i++) {
                in_sum += input[i];
                out_sum += output[i];
@@ -70,7 +99,8 @@ int user_main(int argc, char **argv)
                printf("input[%d] = %u\n", i, input[i]);
        for (i = 0; i < num_threads; i++)
                printf("output[%d] = %u\n", i, output[i]);
-       MODEL_ASSERT(in_sum == out_sum);
+       //MODEL_ASSERT(in_sum == out_sum);
+       */
 
        free(param);
        free(threads);