mirror of https://github.com/apache/lucene.git
SOLR-3080: add couple more asserts
git-svn-id: https://svn.apache.org/repos/asf/lucene/dev/trunk@1292753 13f79535-47bb-0310-9956-ffa450edef68
This commit is contained in:
parent
19b2423ced
commit
c618516338
|
@ -22,6 +22,8 @@ import java.util.HashMap;
|
|||
import java.util.List;
|
||||
import java.util.Map;
|
||||
|
||||
import junit.framework.Assert;
|
||||
|
||||
import org.apache.solr.SolrTestCaseJ4;
|
||||
import org.apache.solr.common.cloud.SolrZkClient;
|
||||
import org.apache.solr.common.cloud.ZkNodeProps;
|
||||
|
@ -197,6 +199,8 @@ public class ZkControllerTest extends SolrTestCaseJ4 {
|
|||
|
||||
assertNotNull(reader.getLeaderUrl("collection1", "shard1", 15000));
|
||||
|
||||
assertEquals("Shard(s) missing from cloudstate", 2, zkController.getZkStateReader().getCloudState().getSlice("collection1", "shard1").getShards().size());
|
||||
|
||||
// unregister current leader
|
||||
final ZkNodeProps shard1LeaderProps = reader.getLeaderProps(
|
||||
"collection1", "shard1");
|
||||
|
@ -215,6 +219,9 @@ public class ZkControllerTest extends SolrTestCaseJ4 {
|
|||
leaderUrl, reader.getLeaderUrl("collection1", "shard1", 15000));
|
||||
assertNotNull("New leader was null.",
|
||||
reader.getLeaderUrl("collection1", "shard1", 15000));
|
||||
|
||||
Thread.sleep(1000);
|
||||
assertEquals("shard was not unregistered", 1, zkController.getZkStateReader().getCloudState().getSlice("collection1", "shard1").getShards().size());
|
||||
} finally {
|
||||
if (DEBUG) {
|
||||
if (zkController != null) {
|
||||
|
|
Loading…
Reference in New Issue