| | |
| | | |
| | | // Extract the change number of the latest change generated by the local |
| | | // server |
| | | ChangeNumber myChangeNumber = localState.getMaxChangeNumber(localServerId); |
| | | ChangeNumber myChangeNumber = localState.getChangeNumber(localServerId); |
| | | if (myChangeNumber == null) |
| | | { |
| | | myChangeNumber = new ChangeNumber(0, 0, localServerId); |
| | |
| | | { |
| | | ReplicationServerInfo replicationServerInfo = bestServers.get(rsId); |
| | | ServerState rsState = replicationServerInfo.getServerState(); |
| | | ChangeNumber rsChangeNumber = rsState.getMaxChangeNumber(localServerId); |
| | | ChangeNumber rsChangeNumber = rsState.getChangeNumber(localServerId); |
| | | if (rsChangeNumber == null) |
| | | { |
| | | rsChangeNumber = new ChangeNumber(0, 0, localServerId); |