Permalink
Browse files

Configure both physical and logical logging to PMFS

  • Loading branch information...
jarulraj committed Mar 21, 2014
1 parent f7d5eed commit 631d80c3369b181381ed8ff252da26177807d327
@@ -998,14 +998,15 @@ public void waitForAriesRecoveryCompletion() {
// wait for other threads to complete Aries recovery
// ONLY called from main site.
while (!m_ariesLog.isRecoveryCompleted()) {
/*
try {
// don't sleep too long, shouldn't bias
// numbers
Thread.sleep(500);
// don't sleep too long, shouldn't bias numbers
Thread.sleep(1000);
} catch (InterruptedException e) {
// TODO Auto-generated catch block
e.printStackTrace();
//e.printStackTrace();
}
*/
}
}
@@ -62,7 +62,7 @@
*/
public class TestTPCCLogicalRecovery extends RegressionSuite {
private static final String TMPDIR = "./snapshot";
private static final String TMPDIR = "/mnt/pmfs/snapshot";
private static final String TESTNONCE = "testnonce";
private static final int ALLOWEXPORT = 0;
@@ -72,7 +72,7 @@
// TPCC
private static final String PREFIX = "tpcc";
private static int NUM_TRANSACTIONS = 1000;
private static int NUM_TRANSACTIONS = 50000;
private static final String projectJAR = "logical_" + PREFIX + ".jar";
public TestTPCCLogicalRecovery(String name) {
@@ -203,7 +203,13 @@ public void testTPCC() throws IOException, InterruptedException, ProcCallExcepti
} catch (Exception e) {
e.printStackTrace();
}
// Take Snapshot
results = null;
results = saveTables(client);
validateSnapshot(true);
final String MOCK_ARGS[] = { "HOST=localhost", "NUMCLIENTS=1",
// XXX HACK to find catalog jar
"CATALOG=" + "./obj/release/testobjects/" + projectJAR, "" };
@@ -229,13 +235,6 @@ public void testTPCC() throws IOException, InterruptedException, ProcCallExcepti
results = client.callProcedure("@Statistics", "table", 0).getResults();
System.out.println(results[0]);
// Take Snapshot
results = null;
results = saveTables(client);
validateSnapshot(true);
VoltTable[] results_tmp = null;
results_tmp = client.callProcedure("@Statistics", "table", 0).getResults();
@@ -274,7 +273,7 @@ public void testTPCC() throws IOException, InterruptedException, ProcCallExcepti
results = client.callProcedure("@Statistics", "table", 0).getResults();
System.out.println(results[0]);
File logDir = new File("./obj" + File.separator + "cmdlog");
File logDir = new File("/mnt/pmfs" + File.separator + "cmdlog");
// Parse WAL logs for all sites
CatalogMap<Site> sites = cc.sites;
@@ -412,7 +411,7 @@ static public Test suite() {
// COMMAND LOG
builder.setGlobalConfParameter("site.commandlog_enable", true);
builder.setGlobalConfParameter("site.commandlog_timeout", 1000);
//builder.setGlobalConfParameter("site.commandlog_dir", "/mnt/pmfs/cmdlog");
builder.setGlobalConfParameter("site.commandlog_dir", "/mnt/pmfs/cmdlog");
builder.setGlobalConfParameter("site.anticache_enable", false);
@@ -46,14 +46,14 @@
*/
public class TestTPCCPhysicalRecovery extends RegressionSuite {
private static final String ARIESDIR = "./obj/aries";
private static final String ARIESDIR = "/mnt/pmfs/aries";
private static int NUM_SITES = -1;
private static int NUM_PARTITIONS = -1;
// TPCC
private static final String PREFIX = "tpcc";
private static int NUM_TRANSACTIONS = 1000;
private static int NUM_TRANSACTIONS = 50000;
private static final String projectJAR = "physical_" + PREFIX + ".jar";
public TestTPCCPhysicalRecovery(String name) {
@@ -70,7 +70,7 @@ public void tearDown() {
try {
super.tearDown();
} catch (final Exception e) {
e.printStackTrace();
//e.printStackTrace();
}
}
@@ -191,7 +191,7 @@ static public Test suite() {
// PHYSICAL
builder.setGlobalConfParameter("site.aries", true);
builder.setGlobalConfParameter("site.aries_forward_only", false);
//builder.setGlobalConfParameter("site.aries_dir", "/mnt/pmfs/aries");
builder.setGlobalConfParameter("site.aries_dir", "/mnt/pmfs/aries");
builder.setGlobalConfParameter("site.anticache_enable", false);

0 comments on commit 631d80c

Please sign in to comment.