| opends/src/server/org/opends/server/replication/plugin/PendingChanges.java | ●●●●● patch | view | raw | blame | history |
opends/src/server/org/opends/server/replication/plugin/PendingChanges.java
@@ -169,6 +169,7 @@ return numSentUpdates; } // peek the oldest changeNumber ChangeNumber firstChangeNumber = pendingChanges.firstKey(); PendingChange firstChange = pendingChanges.get(firstChangeNumber); @@ -185,6 +186,8 @@ } else { // do not push updates until the RS catches up. // @see #setRecovering(boolean) domain.getServerState().update(updateMsg.getChangeNumber()); } } @@ -196,6 +199,7 @@ } else { // peek the oldest changeNumber firstChangeNumber = pendingChanges.firstKey(); firstChange = pendingChanges.get(firstChangeNumber); }