save

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

diff --git a/benchmark/mpmc-queue/mpmc-queue.cc b/benchmark/mpmc-queue/mpmc-queue.cc
index cfa82f2a13ca95a741608fb55d09db61dacd8bc5..0785711ff6c86dd34335132f1f16b8747ae43bf3 100644 (file)
--- a/benchmark/mpmc-queue/mpmc-queue.cc
+++ b/benchmark/mpmc-queue/mpmc-queue.cc
@@ -13,7 +13,7 @@ void threadA(struct mpmc_boundq_1_alt<int32_t, sizeof(int32_t)> *queue)
        int32_t *bin = queue->write_prepare();
        store_32(bin, 1);
        printf("write_bin %d, val %d\n", bin, 1);
-       queue->write_publish();
+       queue->write_publish(bin);
 }
 
 void threadB(struct mpmc_boundq_1_alt<int32_t, sizeof(int32_t)> *queue)
@@ -30,7 +30,7 @@ void threadC(struct mpmc_boundq_1_alt<int32_t, sizeof(int32_t)> *queue)
 {
        int32_t *bin = queue->write_prepare();
        store_32(bin, 1);
-       queue->write_publish();
+       queue->write_publish(bin);
 
        while (bin = queue->read_fetch()) {
                printf("Read: %d\n", load_32(bin));
@@ -117,7 +117,7 @@ int user_main(int argc, char **argv)
        int32_t *bin = queue.write_prepare();
        store_32(bin, 17);
        printf("init_write_bin %d, val %d\n", bin, 17);
-       queue.write_publish();
+       queue.write_publish(bin);
 #endif
 
        printf("Start threads\n");