From c7e523a7391a55c580f07134cd4f659aca35f196 Mon Sep 17 00:00:00 2001 From: weiyu Date: Sat, 12 Dec 2020 21:53:52 -0800 Subject: [PATCH] add sleeps back --- cdschecker_modified_benchmarks/barrier/barrier.cc | 4 ++-- .../dekker-fences/dekker-fences.cc | 4 ++-- cdschecker_modified_benchmarks/linuxrwlocks/linuxrwlocks.cc | 2 +- cdschecker_modified_benchmarks/mcs-lock/mcs-lock.cc | 4 ++-- cdschecker_modified_benchmarks/mpmc-queue/mpmc-queue.cc | 6 +++--- cdschecker_modified_benchmarks/test.sh | 4 ---- 6 files changed, 10 insertions(+), 14 deletions(-) diff --git a/cdschecker_modified_benchmarks/barrier/barrier.cc b/cdschecker_modified_benchmarks/barrier/barrier.cc index 4d3c8ba..28023fc 100644 --- a/cdschecker_modified_benchmarks/barrier/barrier.cc +++ b/cdschecker_modified_benchmarks/barrier/barrier.cc @@ -11,14 +11,14 @@ int var = 0; void threadA(void *arg) { -// std::this_thread::sleep_for(std::chrono::milliseconds(10)); + std::this_thread::sleep_for(std::chrono::milliseconds(10)); store_32(&var, 1); barr->wait(); } void threadB(void *arg) { -// std::this_thread::sleep_for(std::chrono::milliseconds(10)); + std::this_thread::sleep_for(std::chrono::milliseconds(10)); barr->wait(); printf("var = %d\n", load_32(&var)); } diff --git a/cdschecker_modified_benchmarks/dekker-fences/dekker-fences.cc b/cdschecker_modified_benchmarks/dekker-fences/dekker-fences.cc index 30a3633..71ef87b 100644 --- a/cdschecker_modified_benchmarks/dekker-fences/dekker-fences.cc +++ b/cdschecker_modified_benchmarks/dekker-fences/dekker-fences.cc @@ -19,7 +19,7 @@ uint32_t var = 0; void p0() { -// std::this_thread::sleep_for(std::chrono::milliseconds(10)); + std::this_thread::sleep_for(std::chrono::milliseconds(10)); flag0.store(true,std::memory_order_relaxed); //std::atomic_thread_fence(std::memory_order_seq_cst); @@ -50,7 +50,7 @@ void p0() void p1() { -// std::this_thread::sleep_for(std::chrono::milliseconds(10)); + std::this_thread::sleep_for(std::chrono::milliseconds(10)); flag1.store(true,std::memory_order_relaxed); std::atomic_thread_fence(std::memory_order_seq_cst); diff --git a/cdschecker_modified_benchmarks/linuxrwlocks/linuxrwlocks.cc b/cdschecker_modified_benchmarks/linuxrwlocks/linuxrwlocks.cc index 73e3a68..d03d179 100644 --- a/cdschecker_modified_benchmarks/linuxrwlocks/linuxrwlocks.cc +++ b/cdschecker_modified_benchmarks/linuxrwlocks/linuxrwlocks.cc @@ -83,7 +83,7 @@ int shareddata; void a() { -// std::this_thread::sleep_for(std::chrono::milliseconds(10)); + std::this_thread::sleep_for(std::chrono::milliseconds(10)); int i, rs; for(i = 0; i < 2; i++) { if ((i % 2) == 0) { diff --git a/cdschecker_modified_benchmarks/mcs-lock/mcs-lock.cc b/cdschecker_modified_benchmarks/mcs-lock/mcs-lock.cc index 4fc4f0f..5b8bce7 100644 --- a/cdschecker_modified_benchmarks/mcs-lock/mcs-lock.cc +++ b/cdschecker_modified_benchmarks/mcs-lock/mcs-lock.cc @@ -11,7 +11,7 @@ static uint32_t shared; void threadA(void *arg) { -// std::this_thread::sleep_for(std::chrono::milliseconds(10)); + std::this_thread::sleep_for(std::chrono::milliseconds(10)); mcs_mutex::guard g(mutex); printf("store: %d\n", 17); store_32(&shared, 17); @@ -22,7 +22,7 @@ void threadA(void *arg) void threadB(void *arg) { -// std::this_thread::sleep_for(std::chrono::milliseconds(10)); + std::this_thread::sleep_for(std::chrono::milliseconds(10)); mcs_mutex::guard g(mutex); printf("load: %u\n", load_32(&shared)); mutex->unlock(&g); diff --git a/cdschecker_modified_benchmarks/mpmc-queue/mpmc-queue.cc b/cdschecker_modified_benchmarks/mpmc-queue/mpmc-queue.cc index 038fac3..e495f4f 100644 --- a/cdschecker_modified_benchmarks/mpmc-queue/mpmc-queue.cc +++ b/cdschecker_modified_benchmarks/mpmc-queue/mpmc-queue.cc @@ -10,7 +10,7 @@ void threadA(struct mpmc_boundq_1_alt *queue) { -// std::this_thread::sleep_for(std::chrono::milliseconds(10)); + std::this_thread::sleep_for(std::chrono::milliseconds(10)); int32_t *bin = queue->write_prepare(); store_32(bin, 1); queue->write_publish(); @@ -18,7 +18,7 @@ void threadA(struct mpmc_boundq_1_alt *queue) void threadB(struct mpmc_boundq_1_alt *queue) { -// std::this_thread::sleep_for(std::chrono::milliseconds(10)); + std::this_thread::sleep_for(std::chrono::milliseconds(10)); int32_t *bin; while ((bin = queue->read_fetch()) != NULL) { printf("Read: %d\n", load_32(bin)); @@ -28,7 +28,7 @@ void threadB(struct mpmc_boundq_1_alt *queue) void threadC(struct mpmc_boundq_1_alt *queue) { -// std::this_thread::sleep_for(std::chrono::milliseconds(10)); + std::this_thread::sleep_for(std::chrono::milliseconds(10)); int32_t *bin = queue->write_prepare(); store_32(bin, 1); queue->write_publish(); diff --git a/cdschecker_modified_benchmarks/test.sh b/cdschecker_modified_benchmarks/test.sh index 1fd5d1f..d5f92dc 100755 --- a/cdschecker_modified_benchmarks/test.sh +++ b/cdschecker_modified_benchmarks/test.sh @@ -2,10 +2,6 @@ EXE=$1 TOTAL_RUN=500 -CDSLIB="/home/vagrant/c11tester" -export LD_LIBRARY_PATH=${CDSLIB} -export C11TESTER='-x1' - COUNT_DATA_RACE=0 COUNT_TIME=0 -- 2.34.1