Apache
/
lucene
mirror of https://github.com/apache/lucene.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

tests: cancel Timer 

git-svn-id: https://svn.apache.org/repos/asf/lucene/dev/trunk@1579125 13f79535-47bb-0310-9956-ffa450edef68
This commit is contained in:
Mark Robert Miller 2014-03-19 03:52:09 +00:00
parent daa10a5435
commit ee0eeb2d77
1 changed files with 26 additions and 20 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

42
solr/core/src/test/org/apache/solr/cloud/hdfs/StressHdfsTest.java
View File

@ -100,28 +100,34 @@ public class StressHdfsTest extends BasicDistributedZkTest {
} }
if (testRestartIntoSafeMode) { if (testRestartIntoSafeMode) {
createCollection(DELETE_DATA_DIR_COLLECTION, 1, 1, 1);
waitForRecoveriesToFinish(DELETE_DATA_DIR_COLLECTION, false);
ChaosMonkey.stop(jettys.get(0));
// enter safe mode and restart a node
NameNodeAdapter.enterSafeMode(dfsCluster.getNameNode(), false);
int rnd = LuceneTestCase.random().nextInt(10000);
Timer timer = new Timer(); Timer timer = new Timer();
timer.schedule(new TimerTask() {
@Override try {
public void run() { createCollection(DELETE_DATA_DIR_COLLECTION, 1, 1, 1);
NameNodeAdapter.leaveSafeMode(dfsCluster.getNameNode());
}
}, rnd);
ChaosMonkey.start(jettys.get(0)); waitForRecoveriesToFinish(DELETE_DATA_DIR_COLLECTION, false);
waitForRecoveriesToFinish(DELETE_DATA_DIR_COLLECTION, false); ChaosMonkey.stop(jettys.get(0));
// enter safe mode and restart a node
NameNodeAdapter.enterSafeMode(dfsCluster.getNameNode(), false);
int rnd = LuceneTestCase.random().nextInt(10000);
timer.schedule(new TimerTask() {
@Override
public void run() {
NameNodeAdapter.leaveSafeMode(dfsCluster.getNameNode());
}
}, rnd);
ChaosMonkey.start(jettys.get(0));
waitForRecoveriesToFinish(DELETE_DATA_DIR_COLLECTION, false);
} finally {
timer.cancel();
}
} }
} }