From 26ff1f0755680cbce7b5bdb136750b2b1bc9e4ed Mon Sep 17 00:00:00 2001
From: gbellato <gbellato@localhost>
Date: Fri, 10 Nov 2006 08:05:56 +0000
Subject: [PATCH] issue 508 These changes implement a window mechanism in the sycnhronization protocol.
---
opends/src/server/org/opends/server/changelog/ServerReader.java | 7 +++++++
1 files changed, 7 insertions(+), 0 deletions(-)
diff --git a/opends/src/server/org/opends/server/changelog/ServerReader.java b/opends/src/server/org/opends/server/changelog/ServerReader.java
index ab8a68e..d0f1126 100644
--- a/opends/src/server/org/opends/server/changelog/ServerReader.java
+++ b/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)
{
--
Gitblit v1.10.0