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

refactoring in routing logic to allow adding allocation explanation that later can be shown

This commit is contained in:
kimchy 2010-09-21 11:39:22 +02:00
parent b5b36215ae
commit a1299a3d4f
1 changed files with 12 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

14
modules/elasticsearch/src/main/java/org/elasticsearch/cluster/routing/allocation/AllocationExplanation.java
View File

@ -86,8 +86,13 @@ public class AllocationExplanation implements Streamable {
int size2 = in.readVInt(); int size2 = in.readVInt();
List<NodeExplanation> ne = Lists.newArrayListWithCapacity(size2); List<NodeExplanation> ne = Lists.newArrayListWithCapacity(size2);
for (int j = 0; j < size2; j++) { for (int j = 0; j < size2; j++) {
ne.add(new NodeExplanation(DiscoveryNode.readNode(in), in.readUTF())); DiscoveryNode node = null;
if (in.readBoolean()) {
node = DiscoveryNode.readNode(in);
}
ne.add(new NodeExplanation(node, in.readUTF()));
} }
explanations.put(shardId, ne);
} }
} }
@ -97,7 +102,12 @@ public class AllocationExplanation implements Streamable {
entry.getKey().writeTo(out); entry.getKey().writeTo(out);
out.writeVInt(entry.getValue().size()); out.writeVInt(entry.getValue().size());
for (NodeExplanation nodeExplanation : entry.getValue()) { for (NodeExplanation nodeExplanation : entry.getValue()) {
nodeExplanation.node().writeTo(out); if (nodeExplanation.node() == null) {
out.writeBoolean(false);
} else {
out.writeBoolean(true);
nodeExplanation.node().writeTo(out);
}
out.writeUTF(nodeExplanation.description()); out.writeUTF(nodeExplanation.description());
} }
} }