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

SOLR-13577: spin until slave got a replication failure while master is down.

This commit is contained in:
Mikhail Khludnev 2019-06-28 17:28:21 +03:00
parent 46cc24d77e
commit d54555c757
1 changed files with 25 additions and 10 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

35
solr/core/src/test/org/apache/solr/handler/TestReplicationHandler.java
View File

@ -675,28 +675,34 @@ public class TestReplicationHandler extends SolrTestCaseJ4 {
masterJetty.stop(); masterJetty.stop();
// poll interval on slave is 1 second, so we just sleep for a few seconds
Thread.sleep(2000);
masterJetty.start();
// poll interval on slave is 1 second, so we just sleep for a few seconds
for(int retries=0; ;retries++) { for(int retries=0; ;retries++) {
Thread.yield(); // might not be necessary at all
// poll interval on slave is 1 second, so we just sleep for a few seconds
Thread.sleep(2000); Thread.sleep(2000);
NamedList<Object> slaveDetails=null;
try { try {
int failed = Integer.parseInt(getSlaveDetails("timesFailed")); slaveDetails = getSlaveDetails();
int failed = Integer.parseInt(getStringOrNull(slaveDetails,"timesFailed"));
if (previousTimesFailed != null) { if (previousTimesFailed != null) {
assertTrue(failed > previousTimesFailed); assertTrue(failed > previousTimesFailed);
} }
assertEquals(1, Integer.parseInt(getSlaveDetails("timesIndexReplicated")) - failed); assertEquals(1, Integer.parseInt(getStringOrNull(slaveDetails,"timesIndexReplicated")) - failed);
break; break;
} catch (NumberFormatException | AssertionError notYet) { } catch (NumberFormatException | AssertionError notYet) {
log.info((retries+1)+"th attempt failure on " + notYet+" details are "+slaveDetails);
if (retries>9) { if (retries>9) {
log.error("giving up: ", notYet);
throw notYet; throw notYet;
} }
} }
} }
masterJetty.start();
// poll interval on slave is 1 second, so we just sleep for a few seconds
Thread.sleep(2000);
//get docs from slave and assert that they are still the same as before //get docs from slave and assert that they are still the same as before
slaveQueryRsp = rQuery(nDocs, "*:*", slaveClient); slaveQueryRsp = rQuery(nDocs, "*:*", slaveClient);
slaveQueryResult = (SolrDocumentList) slaveQueryRsp.get("response"); slaveQueryResult = (SolrDocumentList) slaveQueryRsp.get("response");
@ -708,6 +714,16 @@ public class TestReplicationHandler extends SolrTestCaseJ4 {
} }
private String getSlaveDetails(String keyName) throws SolrServerException, IOException { private String getSlaveDetails(String keyName) throws SolrServerException, IOException {
NamedList<Object> details = getSlaveDetails();
return getStringOrNull(details, keyName);
}
private String getStringOrNull(NamedList<Object> details, String keyName) {
Object o = details.get(keyName);
return o != null ? o.toString() : null;
}
private NamedList<Object> getSlaveDetails() throws SolrServerException, IOException {
ModifiableSolrParams params = new ModifiableSolrParams(); ModifiableSolrParams params = new ModifiableSolrParams();
params.set(CommonParams.QT, "/replication"); params.set(CommonParams.QT, "/replication");
params.set("command", "details"); params.set("command", "details");
@ -716,8 +732,7 @@ public class TestReplicationHandler extends SolrTestCaseJ4 {
// details/slave/timesIndexReplicated // details/slave/timesIndexReplicated
NamedList<Object> details = (NamedList<Object>) response.getResponse().get("details"); NamedList<Object> details = (NamedList<Object>) response.getResponse().get("details");
NamedList<Object> slave = (NamedList<Object>) details.get("slave"); NamedList<Object> slave = (NamedList<Object>) details.get("slave");
Object o = slave.get(keyName); return slave;
return o != null ? o.toString() : null;
} }
@Test @Test