parsing cluster nodes info fixed

pull/282/head
Nikita 9 years ago
parent 0e1ee8f6d0
commit b12f49b416

@ -282,13 +282,18 @@ public class ClusterConnectionManager extends MasterSlaveConnectionManager {
}
if (params.length > 8) {
String slots = params[8];
String[] parts = slots.split("-");
node.setStartSlot(Integer.valueOf(parts[0]));
node.setEndSlot(Integer.valueOf(parts[1]));
for (int i = 0; i < params.length - 8; i++) {
String slots = params[i + 8];
String[] parts = slots.split("-");
node = new ClusterNodeInfo(node);
node.setStartSlot(Integer.valueOf(parts[0]));
node.setEndSlot(Integer.valueOf(parts[1]));
nodes.add(node);
}
} else {
nodes.add(node);
}
nodes.add(node);
}
return nodes;
}

@ -33,6 +33,17 @@ public class ClusterNodeInfo {
private int startSlot;
private int endSlot;
public ClusterNodeInfo() {
}
public ClusterNodeInfo(ClusterNodeInfo info) {
this.nodeId = info.nodeId;
this.address = info.address;
this.flags = info.flags;
this.slaveOf = info.slaveOf;
this.startSlot = info.startSlot;
this.endSlot = info.endSlot;
}
public String getNodeId() {
return nodeId;
}
@ -74,5 +85,12 @@ public class ClusterNodeInfo {
public void setEndSlot(int endSlot) {
this.endSlot = endSlot;
}
@Override
public String toString() {
return "ClusterNodeInfo [nodeId=" + nodeId + ", address=" + address + ", flags=" + flags
+ ", slaveOf=" + slaveOf + ", startSlot=" + startSlot + ", endSlot=" + endSlot + "]";
}
}

Loading…
Cancel
Save