edits

[cdsspec-compiler.git] / benchmark / mpmc-queue / testcase1.cc

diff --git a/benchmark/mpmc-queue/testcase1.cc b/benchmark/mpmc-queue/testcase1.cc
index 594564ff5b0060e0f0f640af0ede3ca74c11f789..6a5e21c081f137473c58aee4e6dcbd92a1d4a693 100644 (file)
--- a/benchmark/mpmc-queue/testcase1.cc
+++ b/benchmark/mpmc-queue/testcase1.cc
@@ -8,7 +8,7 @@
 
 #include "mpmc-queue.h"
 
-void threadA(struct mpmc_boundq_1_alt<int32_t, 2> *queue)
+void threadA(struct mpmc_boundq_1_alt<int32_t, 1> *queue)
 {
        int32_t *bin;
        bin = queue->write_prepare();
@@ -21,7 +21,7 @@ void threadA(struct mpmc_boundq_1_alt<int32_t, 2> *queue)
        }
 }
 
-void threadB(struct mpmc_boundq_1_alt<int32_t, 2> *queue)
+void threadB(struct mpmc_boundq_1_alt<int32_t, 1> *queue)
 {
        int32_t *bin;
        bin = queue->read_fetch();
@@ -35,7 +35,7 @@ void threadB(struct mpmc_boundq_1_alt<int32_t, 2> *queue)
 
 int user_main(int argc, char **argv)
 {
-       struct mpmc_boundq_1_alt<int32_t, 2> queue;
+       struct mpmc_boundq_1_alt<int32_t, 1> queue(0xFFFF);
        thrd_t A, B;
 
        printf("Adding initial element\n");
@@ -45,11 +45,12 @@ int user_main(int argc, char **argv)
        printf("init_write_bin %d, val %d\n", bin, 17);
        queue.write_publish(bin);
 
+/*
        bin = queue.write_prepare();
        *bin = 27;
        printf("init_write_bin %d, val %d\n", bin, 27);
        queue.write_publish(bin);
-
+*/
 
        printf("Start threads\n");