honeymoose
/
OpenSearch
mirror of https://github.com/honeymoose/OpenSearch.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

renamve var to better reflect its state (started, not active)

This commit is contained in:
kimchy 2010-08-21 17:50:08 +03:00
parent 3117341f44
commit 11dbbebb7a
1 changed files with 8 additions and 8 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

16
modules/elasticsearch/src/main/java/org/elasticsearch/cluster/routing/strategy/ShardsRoutingStrategy.java
View File

@ -156,10 +156,10 @@ public class ShardsRoutingStrategy extends AbstractComponent {
} }
boolean relocated = false; boolean relocated = false;
List<MutableShardRouting> activeShards = highRoutingNode.shardsWithState(STARTED); List<MutableShardRouting> startedShards = highRoutingNode.shardsWithState(STARTED);
for (MutableShardRouting activeShard : activeShards) { for (MutableShardRouting startedShard : startedShards) {
// we only relocate shards that all other shards within the replication group are active // we only relocate shards that all other shards within the replication group are active
List<MutableShardRouting> allShards = routingNodes.shardsRoutingFor(activeShard); List<MutableShardRouting> allShards = routingNodes.shardsRoutingFor(startedShard);
boolean ignoreShard = false; boolean ignoreShard = false;
for (MutableShardRouting allShard : allShards) { for (MutableShardRouting allShard : allShards) {
if (!allShard.active()) { if (!allShard.active()) {
@ -171,13 +171,13 @@ public class ShardsRoutingStrategy extends AbstractComponent {
continue; continue;
} }
if (lowRoutingNode.canAllocate(routingNodes.metaData(), routingNodes.routingTable()) && lowRoutingNode.canAllocate(activeShard)) { if (lowRoutingNode.canAllocate(routingNodes.metaData(), routingNodes.routingTable()) && lowRoutingNode.canAllocate(startedShard)) {
changed = true; changed = true;
lowRoutingNode.add(new MutableShardRouting(activeShard.index(), activeShard.id(), lowRoutingNode.add(new MutableShardRouting(startedShard.index(), startedShard.id(),
lowRoutingNode.nodeId(), activeShard.currentNodeId(), lowRoutingNode.nodeId(), startedShard.currentNodeId(),
activeShard.primary(), INITIALIZING)); startedShard.primary(), INITIALIZING));
activeShard.relocate(lowRoutingNode.nodeId()); startedShard.relocate(lowRoutingNode.nodeId());
relocated = true; relocated = true;
relocationPerformed = true; relocationPerformed = true;
break; break;