From a5a83cb8971c5b380b44c8a246f741e59f8d5f49 Mon Sep 17 00:00:00 2001 From: bdemsky Date: Thu, 16 Jul 2009 10:14:11 +0000 Subject: [PATCH] last changes to build --- .../Benchmarks/SingleTM/Vacation/Client.java | 11 ++++----- .../SingleTM/Vacation/Vacation.java | 2 +- .../src/Benchmarks/SingleTM/Vacation/defines | 24 +++++++++++++++++++ 3 files changed, 29 insertions(+), 8 deletions(-) create mode 100644 Robust/src/Benchmarks/SingleTM/Vacation/defines diff --git a/Robust/src/Benchmarks/SingleTM/Vacation/Client.java b/Robust/src/Benchmarks/SingleTM/Vacation/Client.java index 52a27723..f2e03f80 100644 --- a/Robust/src/Benchmarks/SingleTM/Vacation/Client.java +++ b/Robust/src/Benchmarks/SingleTM/Vacation/Client.java @@ -161,8 +161,7 @@ public class Client extends Thread { ids[n] = (randomPtr.random_generate() % queryRange) + 1; } boolean isFound = false; - //atomic - { + atomic { for (n = 0; n < numQuery; n++) { int t = types[n]; int id = ids[n]; @@ -210,8 +209,7 @@ public class Client extends Thread { case ACTION_DELETE_CUSTOMER: { int customerId = randomPtr.posrandom_generate() % queryRange + 1; - //atomic - { + atomic { int bill = managerPtr.manager_queryCustomerBill(customerId); if (bill >= 0) { managerPtr.manager_deleteCustomer(customerId); @@ -231,8 +229,7 @@ public class Client extends Thread { prices[n] = ((randomPtr.posrandom_generate() % 5) * 10) + 50; } } - //atomic - { + atomic { for (n = 0; n < numUpdate; n++) { int t = types[n]; int id = ids[n]; @@ -276,8 +273,8 @@ public class Client extends Thread { //assert(0); } /* switch (action) */ } /* for i */ + Barrier.enterBarrier(); } - Barrier.enterBarrier(); } /* ============================================================================= diff --git a/Robust/src/Benchmarks/SingleTM/Vacation/Vacation.java b/Robust/src/Benchmarks/SingleTM/Vacation/Vacation.java index d3b680fe..30bd2690 100644 --- a/Robust/src/Benchmarks/SingleTM/Vacation/Vacation.java +++ b/Robust/src/Benchmarks/SingleTM/Vacation/Vacation.java @@ -292,7 +292,7 @@ public class Vacation { System.out.println("Running clients... "); start=System.currentTimeMillis(); - // Barrier.setBarrier(numThread); + Barrier.setBarrier(numThread); for(int i=1;i