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];
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);
prices[n] = ((randomPtr.posrandom_generate() % 5) * 10) + 50;
}
}
- //atomic
- {
+ atomic {
for (n = 0; n < numUpdate; n++) {
int t = types[n];
int id = ids[n];
//assert(0);
} /* switch (action) */
} /* for i */
+ Barrier.enterBarrier();
}
- Barrier.enterBarrier();
}
/* =============================================================================
System.out.println("Running clients... ");
start=System.currentTimeMillis();
- // Barrier.setBarrier(numThread);
+ Barrier.setBarrier(numThread);
for(int i=1;i<numThread;i++) {
clients[i].start();
--- /dev/null
+#define ACTION_MAKE_RESERVATION 0
+#define ACTION_DELETE_CUSTOMER 1
+#define ACTION_UPDATE_TABLES 2
+#define NUM_ACTION 2
+#define PARAM_CLIENTS 'c'
+#define PARAM_NUMBER 'n'
+#define PARAM_QUERIES 'q'
+#define PARAM_RELATIONS 'r'
+#define PARAM_TRANSACTIONS 't'
+#define PARAM_USER 'u'
+#define PARAM_DEFAULT_CLIENTS (1)
+#define PARAM_DEFAULT_NUMBER (10)
+#define PARAM_DEFAULT_QUERIES (90)
+#define PARAM_DEFAULT_RELATIONS (1 << 16)
+#define PARAM_DEFAULT_TRANSACTIONS (1 << 26)
+#define PARAM_DEFAULT_USER (80)
+#define RESERVATION_CAR 0
+#define RESERVATION_FLIGHT 1
+#define RESERVATION_ROOM 2
+#define NUM_RESERVATION_TYPE 3
+#define OPERATION_MAKE_RESERVATION 0L
+#define OPERATION_DELETE_CUSTOMER 1L
+#define OPERATION_UPDATE_TABLE 2L
+#define NUM_OPERATION 3