issue 508 These changes implement a window mechanism in the sycnhronizatio...

gbellato

10.05.2006 988ec833bcc9d5dcca7ea59611102a39f08b025c

 opendj-sdk/opends/src/server/org/opends/server/changelog/ServerReader.java

@@ -36,6 +36,7 @@
import org.opends.server.synchronization.AckMessage;
import org.opends.server.synchronization.SynchronizationMessage;
import org.opends.server.synchronization.UpdateMessage;
import org.opends.server.synchronization.WindowMessage;
import org.opends.server.types.ErrorLogCategory;
import org.opends.server.types.ErrorLogSeverity;

@@ -105,8 +106,14 @@
        else if (msg instanceof UpdateMessage)
        {
          UpdateMessage update = (UpdateMessage) msg;
          handler.checkWindow();
          changelogCache.put(update, handler);
        }
        else if (msg instanceof WindowMessage)
        {
          WindowMessage windowMsg = (WindowMessage) msg;
          handler.updateWindow(windowMsg);
        }
      }
    } catch (IOException e)
    {