mirror of https://github.com/OpenIdentityPlatform/OpenDJ.git

gbellato
31.21.2007 b0acea5e1ca30af24c2f976ee0dd8dc43d31ea58
opendj-sdk/opends/src/server/org/opends/server/synchronization/changelog/ServerReader.java
@@ -102,12 +102,13 @@
        if (msg instanceof AckMessage)
        {
          AckMessage ack = (AckMessage) msg;
          handler.checkWindow();
          changelogCache.ack(ack, serverId);
        }
        else if (msg instanceof UpdateMessage)
        {
          UpdateMessage update = (UpdateMessage) msg;
          handler.checkWindow();
          handler.decAndCheckWindow();
          changelogCache.put(update, handler);
        }
        else if (msg instanceof WindowMessage)