| | |
| | | ChangeNumber replServerMaxChangeNumber = |
| | | replicationServerState.getMaxChangeNumber(serverId); |
| | | |
| | | if (replServerMaxChangeNumber == null) |
| | | // we don't want to update from here (a DS) an empty RS because |
| | | // normally the RS should have been updated by other RSes except for |
| | | // very last changes lost if the local connection was broken |
| | | // ... hence the RS we are connected to should not be empty |
| | | // ... or if it is empty, it is due to a volontary reset |
| | | // and we don't want to update it with our changes that could be huge. |
| | | if ((replServerMaxChangeNumber != null) && |
| | | (replServerMaxChangeNumber.getSeqnum()!=0)) |
| | | { |
| | | replServerMaxChangeNumber = new ChangeNumber(0, 0, serverId); |
| | | } |
| | | ChangeNumber ourMaxChangeNumber = |
| | | state.getMaxChangeNumber(serverId); |
| | | |
| | |
| | | } |
| | | replayOperations.clear(); |
| | | } |
| | | } |
| | | } catch (Exception e) |
| | | { |
| | | Message message = ERR_PUBLISHING_FAKE_OPS.get( |