80e0f0d210f2471658e1f3ff54cb0f00b33856c2
[model-checker-benchmarks.git] / ms-queue-loose / testcase3.c
1 #include <stdlib.h>
2 #include <stdio.h>
3 #include <threads.h>
4
5 #include "queue.h"
6 #include "model-assert.h"
7
8 static queue_t *queue;
9 static thrd_t *threads;
10 static unsigned int *input;
11 static unsigned int *output;
12 static int num_threads;
13
14 int get_thread_num()
15 {
16         thrd_t curr = thrd_current();
17         int i;
18         for (i = 0; i < num_threads; i++)
19                 if (curr.priv == threads[i].priv)
20                         return i;
21         MODEL_ASSERT(0);
22         return -1;
23 }
24
25 bool succ1, succ2;
26 atomic_int x[3];
27 unsigned int idx1, idx2;
28 unsigned int reclaimNode;
29
30 static int procs = 2;
31 static void main_task(void *param)
32 {
33         unsigned int val;
34         int pid = *((int *)param);
35         if (pid % procs == 0) {
36                 //atomic_store_explicit(&x[0], 1, memory_order_relaxed);
37                 enqueue(queue, 1, 0);
38                 printf("T2 enqueue %d\n", 1);
39                 succ1 = dequeue(queue, &idx1, &reclaimNode);
40                 if (succ1)
41                         printf("T2 dequeue %d\n", idx1);
42                 else
43                         printf("T2 dequeue NULL\n");
44         } else if (pid % procs == 1) {
45                 enqueue(queue, 2, 0);
46                 printf("T3 enqueue %d\n", 2);
47                 succ2 = dequeue(queue, &idx2, &reclaimNode);
48                 if (succ2)
49                         printf("T3 dequeue %d\n", idx2);
50                 else
51                         printf("T2 dequeue NULL\n");
52         }
53 }
54
55 int user_main(int argc, char **argv)
56 {
57         int i;
58         int *param;
59         unsigned int in_sum = 0, out_sum = 0;
60
61         /** @Entry */
62         queue = (queue_t*) calloc(1, sizeof(*queue));
63         MODEL_ASSERT(queue);
64
65         num_threads = procs;
66         threads = (thrd_t*) malloc(num_threads * sizeof(thrd_t));
67         param = (int*) malloc(num_threads * sizeof(*param));
68         input = (unsigned int *) calloc(num_threads, sizeof(*input));
69         output = (unsigned int *) calloc(num_threads, sizeof(*output));
70
71         atomic_init(&x[0], 0);
72         atomic_init(&x[1], 0);
73         atomic_init(&x[2], 0);
74         init_queue(queue, num_threads);
75         for (i = 0; i < num_threads; i++) {
76                 param[i] = i;
77                 thrd_create(&threads[i], main_task, &param[i]);
78         }
79         for (i = 0; i < num_threads; i++)
80                 thrd_join(threads[i]);
81 /*
82         for (i = 0; i < num_threads; i++) {
83                 in_sum += input[i];
84                 out_sum += output[i];
85         }
86         for (i = 0; i < num_threads; i++)
87                 printf("input[%d] = %u\n", i, input[i]);
88         for (i = 0; i < num_threads; i++)
89                 printf("output[%d] = %u\n", i, output[i]);
90         if (succ1 && succ2)
91                 MODEL_ASSERT(in_sum == out_sum);
92         else
93                 MODEL_ASSERT (false);
94 */
95         free(param);
96         free(threads);
97         free(queue);
98
99         return 0;
100 }