You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@lucene.apache.org by sh...@apache.org on 2015/09/10 12:48:19 UTC
svn commit: r1702213 [2/2] - in /lucene/dev/branches/branch_5x: ./ solr/
solr/core/ solr/core/src/java/org/apache/solr/cloud/
solr/core/src/java/org/apache/solr/update/processor/
solr/core/src/test/org/apache/solr/cloud/
Modified: lucene/dev/branches/branch_5x/solr/core/src/test/org/apache/solr/cloud/ZkControllerTest.java
URL: http://svn.apache.org/viewvc/lucene/dev/branches/branch_5x/solr/core/src/test/org/apache/solr/cloud/ZkControllerTest.java?rev=1702213&r1=1702212&r2=1702213&view=diff
==============================================================================
--- lucene/dev/branches/branch_5x/solr/core/src/test/org/apache/solr/cloud/ZkControllerTest.java (original)
+++ lucene/dev/branches/branch_5x/solr/core/src/test/org/apache/solr/cloud/ZkControllerTest.java Thu Sep 10 10:48:18 2015
@@ -49,6 +49,7 @@ import java.util.Map;
import java.util.concurrent.TimeUnit;
@Slow
+@SolrTestCaseJ4.SuppressSSL
public class ZkControllerTest extends SolrTestCaseJ4 {
private static final String COLLECTION_NAME = "collection1";
@@ -243,64 +244,6 @@ public class ZkControllerTest extends So
} finally {
if (zkController != null)
zkController.close();
- }
- } finally {
- if (cc != null) {
- cc.shutdown();
- }
- server.shutdown();
- }
- }
-
- /*
- Test that:
- 1) LIR state to 'down' is not set unless publishing node is a leader
- 1a) Test that leader can publish when LIR node already exists in zk
- 1b) Test that leader can publish when LIR node does not exist - TODO
- 2) LIR state to 'active' or 'recovery' can be set regardless of whether publishing
- node is leader or not - TODO
- */
- public void testEnsureReplicaInLeaderInitiatedRecovery() throws Exception {
- String zkDir = createTempDir("testEnsureReplicaInLeaderInitiatedRecovery").toFile().getAbsolutePath();
- CoreContainer cc = null;
-
- ZkTestServer server = new ZkTestServer(zkDir);
- try {
- server.run();
-
- AbstractZkTestCase.tryCleanSolrZkNode(server.getZkHost());
- AbstractZkTestCase.makeSolrZkNode(server.getZkHost());
-
- cc = getCoreContainer();
- ZkController zkController = null;
-
- try {
- CloudConfig cloudConfig = new CloudConfig.CloudConfigBuilder("127.0.0.1", 8983, "solr").build();
- zkController = new ZkController(cc, server.getZkAddress(), TIMEOUT, cloudConfig, new CurrentCoreDescriptorProvider() {
-
- @Override
- public List<CoreDescriptor> getCurrentDescriptors() {
- // do nothing
- return null;
- }
- });
- HashMap<String, Object> propMap = new HashMap<>();
- propMap.put(ZkStateReader.BASE_URL_PROP, "http://127.0.0.1:8983/solr");
- propMap.put(ZkStateReader.CORE_NAME_PROP, "replica1");
- propMap.put(ZkStateReader.NODE_NAME_PROP, "127.0.0.1:8983_solr");
- Replica replica = new Replica("replica1", propMap);
- try {
- // this method doesn't throw exception when node isn't leader
- zkController.ensureReplicaInLeaderInitiatedRecovery("c1", "shard1",
- new ZkCoreNodeProps(replica), "non_existent_leader", false, false);
- fail("ZkController should not write LIR state for node which is not leader");
- } catch (Exception e) {
- assertNull("ZkController should not write LIR state for node which is not leader",
- zkController.getLeaderInitiatedRecoveryState("c1", "shard1", "replica1"));
- }
- } finally {
- if (zkController != null)
- zkController.close();
}
} finally {
if (cc != null) {