X-Git-Url: http://plrg.eecs.uci.edu/git/?a=blobdiff_plain;f=benchmark%2Fmpmc-queue%2Fmpmc-queue.cc;h=39c2c0a24808a3ce62b05a47b66b11f0445d198e;hb=6d0e5824cfcdd3569f05e8d2a11992e7ac9a344f;hp=b62d8d31f496bce7a686332aad23ef7140e56653;hpb=0a040a5b619952d29338f73db8f685d7367178fc;p=cdsspec-compiler.git

diff --git a/benchmark/mpmc-queue/mpmc-queue.cc b/benchmark/mpmc-queue/mpmc-queue.cc
index b62d8d3..39c2c0a 100644
--- a/benchmark/mpmc-queue/mpmc-queue.cc
+++ b/benchmark/mpmc-queue/mpmc-queue.cc
@@ -11,28 +11,34 @@
 void threadA(struct mpmc_boundq_1_alt<int32_t, sizeof(int32_t)> *queue)
 {
 	int32_t *bin = queue->write_prepare();
-	store_32(bin, 1);
-	queue->write_publish();
+	//store_32(bin, 1);
+	*bin = 1;
+	printf("write_bin %d, val %d\n", bin, 1);
+	queue->write_publish(bin);
 }
 
 void threadB(struct mpmc_boundq_1_alt<int32_t, sizeof(int32_t)> *queue)
 {
 	int32_t *bin;
 	while (bin = queue->read_fetch()) {
-		printf("Read: %d\n", load_32(bin));
-		queue->read_consume();
+		//printf("Read: %d\n", load_32(bin));
+		//printf("read_bin %d, val %d\n", bin, load_32(bin));
+		printf("Read: %d\n", *bin);
+		queue->read_consume(bin);
 	}
 }
 
 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();
+	//store_32(bin, 1);
+	*bin = 1;
+	queue->write_publish(bin);
 
 	while (bin = queue->read_fetch()) {
-		printf("Read: %d\n", load_32(bin));
-		queue->read_consume();
+		//printf("Read: %d\n", load_32(bin));
+		printf("Read: %d\n", *bin);
+		queue->read_consume(bin);
 	}
 }
 
@@ -113,8 +119,10 @@ int user_main(int argc, char **argv)
 #ifndef CONFIG_MPMC_NO_INITIAL_ELEMENT
 	printf("Adding initial element\n");
 	int32_t *bin = queue.write_prepare();
-	store_32(bin, 17);
-	queue.write_publish();
+	//store_32(bin, 17);
+	*bin, 17;
+	printf("init_write_bin %d, val %d\n", bin, 17);
+	queue.write_publish(bin);
 #endif
 
 	printf("Start threads\n");