From: bdemsky Date: Thu, 16 Jul 2009 10:14:11 +0000 (+0000) Subject: last changes to build X-Git-Url: http://demsky.eecs.uci.edu/git/?a=commitdiff_plain;h=a5a83cb8971c5b380b44c8a246f741e59f8d5f49;p=IRC.git last changes to build --- 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