You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@lucene.apache.org by yo...@apache.org on 2013/02/05 17:27:09 UTC
svn commit: r1442648 -
/lucene/dev/trunk/solr/core/src/test/org/apache/solr/cloud/ChaosMonkeySafeLeaderTest.java
Author: yonik
Date: Tue Feb 5 16:27:09 2013
New Revision: 1442648
URL: http://svn.apache.org/viewvc?rev=1442648&view=rev
Log:
tests: enable chaos safe leader test
Modified:
lucene/dev/trunk/solr/core/src/test/org/apache/solr/cloud/ChaosMonkeySafeLeaderTest.java
Modified: lucene/dev/trunk/solr/core/src/test/org/apache/solr/cloud/ChaosMonkeySafeLeaderTest.java
URL: http://svn.apache.org/viewvc/lucene/dev/trunk/solr/core/src/test/org/apache/solr/cloud/ChaosMonkeySafeLeaderTest.java?rev=1442648&r1=1442647&r2=1442648&view=diff
==============================================================================
--- lucene/dev/trunk/solr/core/src/test/org/apache/solr/cloud/ChaosMonkeySafeLeaderTest.java (original)
+++ lucene/dev/trunk/solr/core/src/test/org/apache/solr/cloud/ChaosMonkeySafeLeaderTest.java Tue Feb 5 16:27:09 2013
@@ -24,16 +24,17 @@ import org.apache.lucene.util.LuceneTest
import org.apache.lucene.util.LuceneTestCase.Slow;
import org.apache.solr.client.solrj.SolrQuery;
import org.apache.solr.common.SolrInputDocument;
+import org.apache.solr.core.Diagnostics;
import org.apache.solr.core.SolrCore;
import org.apache.solr.servlet.SolrDispatchFilter;
import org.apache.solr.update.DirectUpdateHandler2;
+import org.apache.solr.update.SolrCmdDistributor;
import org.junit.After;
import org.junit.AfterClass;
import org.junit.Before;
import org.junit.BeforeClass;
@Slow
-@BadApple
public class ChaosMonkeySafeLeaderTest extends AbstractFullDistribZkTestBase {
private static final int BASE_RUN_LENGTH = 120000;
@@ -41,12 +42,21 @@ public class ChaosMonkeySafeLeaderTest e
@BeforeClass
public static void beforeSuperClass() {
-
+ SolrCmdDistributor.testing_errorHook = new Diagnostics.Callable() {
+ @Override
+ public void call(Object... data) {
+ SolrCmdDistributor.Request sreq = (SolrCmdDistributor.Request)data[1];
+ if (sreq.exception == null) return;
+ if (sreq.exception.getMessage().contains("Timeout")) {
+ Diagnostics.logThreadDumps("REQUESTING THREAD DUMP DUE TO TIMEOUT: " + sreq.exception.getMessage());
+ }
+ }
+ };
}
@AfterClass
public static void afterSuperClass() {
-
+ SolrCmdDistributor.testing_errorHook = null;
}
@Before