| | |
| | | for (FakeOperation op : updates) |
| | | { |
| | | CSN csn = op.getCSN(); |
| | | if (csn.newer(startCSN) && csn.older(endCSN)) |
| | | if (csn.isNewerThan(startCSN) && csn.isOlderThan(endCSN)) |
| | | { |
| | | synchronized (replayOperations) |
| | | { |
| | |
| | | if (replServerMaxCSN != null && replServerMaxCSN.getSeqnum() != 0) |
| | | { |
| | | CSN ourMaxCSN = state.getMaxCSN(getServerId()); |
| | | if (ourMaxCSN != null && !ourMaxCSN.olderOrEqual(replServerMaxCSN)) |
| | | if (ourMaxCSN != null |
| | | && !ourMaxCSN.isOlderThanOrEqualTo(replServerMaxCSN)) |
| | | { |
| | | pendingChanges.setRecovering(true); |
| | | broker.setRecoveryRequired(true); |
| | |
| | | Iterator<CSN> it = replayOperations.keySet().iterator(); |
| | | while (it.hasNext()) |
| | | { |
| | | if (it.next().newer(startCSN)) |
| | | if (it.next().isNewerThan(startCSN)) |
| | | { |
| | | break; |
| | | } |
| | |
| | | while (itOp.hasNext()) |
| | | { |
| | | FakeOperation fakeOp = itOp.next(); |
| | | if (fakeOp.getCSN().newer(endCSN) // sanity check |
| | | if (fakeOp.getCSN().isNewerThan(endCSN) // sanity check |
| | | || !state.cover(fakeOp.getCSN())) |
| | | { |
| | | break; |