Permalink
Browse files

Updated parameters

  • Loading branch information...
jarulraj committed Mar 20, 2014
1 parent fe657ad commit fe923be4389cd8143acc6a34203cd86e93da9e8f
View
@@ -83,8 +83,6 @@ echo "---------------------------------------------------------"
for PARAM; do
echo $PARAM
done
=======
>>>>>>> 57bdfa5eccbda3311d90d6003702fa65528ec377:ycsb.sh
# ---------------------------------------------------------------------
@@ -426,24 +426,23 @@ static public Test suite() {
setUpSnapshotDir();
// CONFIG #1: 2 Local Site with 4 Partitions running on JNI backend
/*
NUM_SITES = 2;
NUM_PARTITIONS = 2;
m_config = new LocalCluster(projectJAR, NUM_SITES, NUM_PARTITIONS, 1, BackendTarget.NATIVE_EE_JNI);
success = m_config.compile(project);
assert (success);
builder.addServerConfig(m_config);
*/
// CONFIG #2: 1 Local Site with 1 Partitions running on JNI backend
/*
NUM_SITES = 1;
NUM_PARTITIONS = 1;
m_config = new LocalSingleProcessServer(projectJAR, NUM_PARTITIONS, BackendTarget.NATIVE_EE_JNI);
success = m_config.compile(project);
assert (success);
builder.addServerConfig(m_config);
*/
return builder;
}
@@ -53,7 +53,7 @@
// TPCC
private static final String PREFIX = "tpcc";
private static int NUM_TRANSACTIONS = 20000;
private static int NUM_TRANSACTIONS = 1000;
private static final String projectJAR = "physical_" + PREFIX + ".jar";
public TestTPCCPhysicalRecovery(String name) {
@@ -149,15 +149,15 @@ public void testTPCC() throws IOException, InterruptedException, ProcCallExcepti
MOCK_ARGS[MOCK_ARGS.length - 1] = HStoreConstants.BENCHMARK_PARAM_PREFIX;
TPCCClient yscbClient = new TPCCClient(MOCK_ARGS);
TPCCClient tpccClient = new TPCCClient(MOCK_ARGS);
// Run transactions
long k_itr = 0;
long numTransactions = NUM_TRANSACTIONS;
long period = numTransactions / 10;
for (k_itr = 0; k_itr < numTransactions; k_itr++) {
boolean response = yscbClient.runOnce();
boolean response = tpccClient.runOnce();
assertEquals(response, true);
if (k_itr % period == 0)
@@ -222,7 +222,7 @@ static public Test suite() {
// CONFIG #2: 1 Local Site with 2 Partitions running on JNI backend
NUM_SITES = 1;
NUM_PARTITIONS = 2;
NUM_PARTITIONS = 1;
m_config = new LocalSingleProcessServer(projectJAR, NUM_PARTITIONS, BackendTarget.NATIVE_EE_JNI);
success = m_config.compile(project);
assert (success);

0 comments on commit fe923be

Please sign in to comment.