You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@lucene.apache.org by cp...@apache.org on 2016/04/27 19:11:11 UTC
[3/4] lucene-solr:jira/solr-9045: * Factor out getReplicateLeaderUrl
protected method in DefaultRecoveryStrategy.
* Factor out getReplicateLeaderUrl protected method in DefaultRecoveryStrategy.
Project: http://git-wip-us.apache.org/repos/asf/lucene-solr/repo
Commit: http://git-wip-us.apache.org/repos/asf/lucene-solr/commit/928763bc
Tree: http://git-wip-us.apache.org/repos/asf/lucene-solr/tree/928763bc
Diff: http://git-wip-us.apache.org/repos/asf/lucene-solr/diff/928763bc
Branch: refs/heads/jira/solr-9045
Commit: 928763bc5cddf3b117f02a9cb8096d2d5799df5c
Parents: 3cd0428
Author: Christine Poerschke <cp...@apache.org>
Authored: Wed Apr 20 17:38:59 2016 +0100
Committer: Christine Poerschke <cp...@apache.org>
Committed: Wed Apr 27 17:18:06 2016 +0100
----------------------------------------------------------------------
.../java/org/apache/solr/cloud/DefaultRecoveryStrategy.java | 7 +++++--
1 file changed, 5 insertions(+), 2 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/lucene-solr/blob/928763bc/solr/core/src/java/org/apache/solr/cloud/DefaultRecoveryStrategy.java
----------------------------------------------------------------------
diff --git a/solr/core/src/java/org/apache/solr/cloud/DefaultRecoveryStrategy.java b/solr/core/src/java/org/apache/solr/cloud/DefaultRecoveryStrategy.java
index a115595..60d2931 100644
--- a/solr/core/src/java/org/apache/solr/cloud/DefaultRecoveryStrategy.java
+++ b/solr/core/src/java/org/apache/solr/cloud/DefaultRecoveryStrategy.java
@@ -124,11 +124,14 @@ public class DefaultRecoveryStrategy extends RecoveryStrategy {
}
}
+ protected String getReplicateLeaderUrl(ZkNodeProps leaderprops) {
+ return new ZkCoreNodeProps(leaderprops).getCoreUrl();
+ }
+
private void replicate(String nodeName, SolrCore core, ZkNodeProps leaderprops)
throws SolrServerException, IOException {
- ZkCoreNodeProps leaderCNodeProps = new ZkCoreNodeProps(leaderprops);
- String leaderUrl = leaderCNodeProps.getCoreUrl();
+ final String leaderUrl = getReplicateLeaderUrl(leaderprops);
LOG.info("Attempting to replicate from [{}].", leaderUrl);