You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@lucene.apache.org by ma...@apache.org on 2012/11/11 23:29:41 UTC
svn commit: r1408134 -
/lucene/dev/trunk/solr/core/src/java/org/apache/solr/cloud/OverseerCollectionProcessor.java
Author: markrmiller
Date: Sun Nov 11 22:29:41 2012
New Revision: 1408134
URL: http://svn.apache.org/viewvc?rev=1408134&view=rev
Log:
SOLR-4055: Remove tabs and format to Lucene convention
Modified:
lucene/dev/trunk/solr/core/src/java/org/apache/solr/cloud/OverseerCollectionProcessor.java
Modified: lucene/dev/trunk/solr/core/src/java/org/apache/solr/cloud/OverseerCollectionProcessor.java
URL: http://svn.apache.org/viewvc/lucene/dev/trunk/solr/core/src/java/org/apache/solr/cloud/OverseerCollectionProcessor.java?rev=1408134&r1=1408133&r2=1408134&view=diff
==============================================================================
--- lucene/dev/trunk/solr/core/src/java/org/apache/solr/cloud/OverseerCollectionProcessor.java (original)
+++ lucene/dev/trunk/solr/core/src/java/org/apache/solr/cloud/OverseerCollectionProcessor.java Sun Nov 11 22:29:41 2012
@@ -262,24 +262,26 @@ public class OverseerCollectionProcessor
for (Map.Entry<String,Replica> shardEntry : shardEntries) {
final ZkNodeProps node = shardEntry.getValue();
if (clusterState.liveNodesContain(node.getStr(ZkStateReader.NODE_NAME_PROP))) {
- //For thread safety, only simple clone the ModifiableSolrParams
- ModifiableSolrParams cloneParams = new ModifiableSolrParams();
- cloneParams.add(params);
- cloneParams.set(CoreAdminParams.CORE, node.getStr(ZkStateReader.CORE_NAME_PROP));
-
- String replica = node.getStr(ZkStateReader.BASE_URL_PROP);
- ShardRequest sreq = new ShardRequest();
-
- // yes, they must use same admin handler path everywhere...
- cloneParams.set("qt", adminPath);
- sreq.purpose = 1;
- // TODO: this sucks
- if (replica.startsWith("http://")) replica = replica.substring(7);
- sreq.shards = new String[] {replica};
- sreq.actualShards = sreq.shards;
- sreq.params = cloneParams;
- log.info("Collection Admin sending CoreAdmin cmd to " + replica + " params:" + sreq.params);
- shardHandler.submit(sreq, replica, sreq.params);
+ // For thread safety, only simple clone the ModifiableSolrParams
+ ModifiableSolrParams cloneParams = new ModifiableSolrParams();
+ cloneParams.add(params);
+ cloneParams.set(CoreAdminParams.CORE,
+ node.getStr(ZkStateReader.CORE_NAME_PROP));
+
+ String replica = node.getStr(ZkStateReader.BASE_URL_PROP);
+ ShardRequest sreq = new ShardRequest();
+
+ // yes, they must use same admin handler path everywhere...
+ cloneParams.set("qt", adminPath);
+ sreq.purpose = 1;
+ // TODO: this sucks
+ if (replica.startsWith("http://")) replica = replica.substring(7);
+ sreq.shards = new String[] {replica};
+ sreq.actualShards = sreq.shards;
+ sreq.params = cloneParams;
+ log.info("Collection Admin sending CoreAdmin cmd to " + replica
+ + " params:" + sreq.params);
+ shardHandler.submit(sreq, replica, sreq.params);
}
}
}