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

tests: remove start the deadpool option when monkey stops 

git-svn-id: https://svn.apache.org/repos/asf/lucene/dev/trunk@1546677 13f79535-47bb-0310-9956-ffa450edef68
This commit is contained in:
Mark Robert Miller 2013-11-30 02:19:12 +00:00
parent cafdce601c
commit 4460efe729
3 changed files with 3 additions and 13 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
solr/core/src/test/org/apache/solr/cloud/ChaosMonkeyNothingIsSafeTest.java
View File

@ -138,7 +138,7 @@ public class ChaosMonkeyNothingIsSafeTest extends AbstractFullDistribZkTestBase
ftIndexThread.start();
}
chaosMonkey.startTheMonkey(true, true, 10000);
chaosMonkey.startTheMonkey(true, 10000);
long runLength;
if (RUN_LENGTH != -1) {

2
solr/core/src/test/org/apache/solr/cloud/ChaosMonkeySafeLeaderTest.java
View File

@ -99,7 +99,7 @@ public class ChaosMonkeySafeLeaderTest extends AbstractFullDistribZkTestBase {
indexThread.start();
}
chaosMonkey.startTheMonkey(false, false, 500);
chaosMonkey.startTheMonkey(false, 500);
long runLength;
if (RUN_LENGTH != -1) {
runLength = RUN_LENGTH;

12
solr/test-framework/src/java/org/apache/solr/cloud/ChaosMonkey.java
View File

@ -435,7 +435,7 @@ public class ChaosMonkey {
// synchronously starts and stops shards randomly, unless there is only one
// active shard up for a slice or if there is one active and others recovering
public void startTheMonkey(boolean killLeaders, final boolean startDeadPool, final int roundPauseUpperLimit) {
public void startTheMonkey(boolean killLeaders, final int roundPauseUpperLimit) {
if (!MONKEY_ENABLED) {
monkeyLog("The Monkey is disabled and will not start");
return;
@ -503,16 +503,6 @@ public class ChaosMonkey {
monkeyLog("I ran for " + (System.currentTimeMillis() - startTime)/1000.0f + "sec. I stopped " + stops + " and I started " + starts
+ ". I also expired " + expires.get() + " and caused " + connloss
+ " connection losses");
if (startDeadPool) {
// starting down nodes
for (CloudJettyRunner jetty : deadPool) {
try {
if (jetty.jetty.isStopped()) ChaosMonkey.start(jetty.jetty);
} catch (Exception e) {
log.error("", e);
}
}
}
}
};
monkeyThread.start();