| | |
| | | if (getProtocolVersion() >= ProtocolVersion.REPLICATION_PROTOCOL_V4) |
| | | { |
| | | // List should only contain RS info for sender |
| | | RSInfo rsInfo = inTopoMsg.getRsList().get(0); |
| | | RSInfo rsInfo = inTopoMsg.getRsInfos().get(0); |
| | | weight = rsInfo.getWeight(); |
| | | } |
| | | |
| | |
| | | public void processTopoInfoFromRS(TopologyMsg topoMsg) |
| | | { |
| | | // List should only contain RS info for sender |
| | | final RSInfo rsInfo = topoMsg.getRsList().get(0); |
| | | final RSInfo rsInfo = topoMsg.getRsInfos().get(0); |
| | | generationId = rsInfo.getGenerationId(); |
| | | groupId = rsInfo.getGroupId(); |
| | | weight = rsInfo.getWeight(); |
| | |
| | | clearRemoteLSHandlers(); |
| | | |
| | | // Creates the new structure according to the message received. |
| | | for (DSInfo dsInfo : topoMsg.getDsList()) |
| | | for (DSInfo dsInfo : topoMsg.getReplicaInfos().values()) |
| | | { |
| | | // For each DS connected to the peer RS |
| | | DSInfo clonedDSInfo = dsInfo.cloneWithReplicationServerId(serverId); |