From ae43103d15d327fc449ee96c079c3e85750de33a Mon Sep 17 00:00:00 2001 From: Sami Siren Date: Wed, 29 Aug 2012 12:06:03 +0000 Subject: [PATCH] reuse existing code, baseUrl and coreName can no longer be null git-svn-id: https://svn.apache.org/repos/asf/lucene/dev/trunk@1378512 13f79535-47bb-0310-9956-ffa450edef68 --- solr/core/src/java/org/apache/solr/cloud/Overseer.java | 9 ++------- .../org/apache/solr/common/cloud/ZkCoreNodeProps.java | 6 +----- 2 files changed, 3 insertions(+), 12 deletions(-) diff --git a/solr/core/src/java/org/apache/solr/cloud/Overseer.java b/solr/core/src/java/org/apache/solr/cloud/Overseer.java index 0163af9e2e7..37278e9dd84 100644 --- a/solr/core/src/java/org/apache/solr/cloud/Overseer.java +++ b/solr/core/src/java/org/apache/solr/cloud/Overseer.java @@ -166,17 +166,12 @@ public class Overseer { } else if (DELETECORE.equals(operation)) { clusterState = removeCore(clusterState, message); } else if (ZkStateReader.LEADER_PROP.equals(operation)) { - StringBuilder sb = new StringBuilder(); String baseUrl = message.get(ZkStateReader.BASE_URL_PROP); String coreName = message.get(ZkStateReader.CORE_NAME_PROP); - sb.append(baseUrl); - if (!baseUrl.endsWith("/")) sb.append("/"); - sb.append(coreName == null ? "" : coreName); - if (!(sb.substring(sb.length() - 1).equals("/"))) sb - .append("/"); + final String leaderUrl = ZkCoreNodeProps.getCoreUrl(baseUrl, coreName); clusterState = setShardLeader(clusterState, message.get(ZkStateReader.COLLECTION_PROP), - message.get(ZkStateReader.SHARD_ID_PROP), sb.toString()); + message.get(ZkStateReader.SHARD_ID_PROP), leaderUrl); } else { throw new RuntimeException("unknown operation:" + operation + " contents:" + message.getProperties()); diff --git a/solr/solrj/src/java/org/apache/solr/common/cloud/ZkCoreNodeProps.java b/solr/solrj/src/java/org/apache/solr/common/cloud/ZkCoreNodeProps.java index ee6b9301bce..facb216bcfb 100644 --- a/solr/solrj/src/java/org/apache/solr/common/cloud/ZkCoreNodeProps.java +++ b/solr/solrj/src/java/org/apache/solr/common/cloud/ZkCoreNodeProps.java @@ -24,7 +24,6 @@ public class ZkCoreNodeProps { this.nodeProps = nodeProps; } - // may return null public String getCoreUrl() { return getCoreUrl(nodeProps.get(ZkStateReader.BASE_URL_PROP), nodeProps.get(ZkStateReader.CORE_NAME_PROP)); } @@ -51,13 +50,10 @@ public class ZkCoreNodeProps { public static String getCoreUrl(String baseUrl, String coreName) { StringBuilder sb = new StringBuilder(); - if (baseUrl == null) return null; - if (coreName == null) return null; sb.append(baseUrl); if (!baseUrl.endsWith("/")) sb.append("/"); - sb.append(coreName == null ? "" : coreName); + sb.append(coreName); if (!(sb.substring(sb.length() - 1).equals("/"))) sb.append("/"); - return sb.toString(); }