opends/src/server/org/opends/server/replication/server/changelog/je/ChangeNumberIndexer.java
@@ -204,9 +204,9 @@ } final CSN csn = updateMsg.getCSN(); lastAliveCSNs.update(baseDN, csn); // only keep the oldest CSN that will be the new cursor's starting point newCursors.putIfAbsent(Pair.of(baseDN, csn.getServerId()), csn); lastAliveCSNs.update(baseDN, csn); tryNotify(baseDN); } @@ -237,8 +237,8 @@ */ public void replicaOffline(DN baseDN, CSN offlineCSN) { lastAliveCSNs.update(baseDN, offlineCSN); replicasOffline.update(baseDN, offlineCSN); lastAliveCSNs.update(baseDN, offlineCSN); tryNotify(baseDN); }