From 3eb214ba900a7f3e4550f6a047db26e7f40b82a8 Mon Sep 17 00:00:00 2001
From: pgamba <pgamba@localhost>
Date: Tue, 17 Apr 2007 11:42:38 +0000
Subject: [PATCH] Issue 605 Total Update over protocol
---
opends/src/server/org/opends/server/synchronization/changelog/ServerReader.java | 32 ++++++++++++++++++++++++++++++++
1 files changed, 32 insertions(+), 0 deletions(-)
diff --git a/opends/src/server/org/opends/server/synchronization/changelog/ServerReader.java b/opends/src/server/org/opends/server/synchronization/changelog/ServerReader.java
index 6f2e451..2dc7a75 100644
--- a/opends/src/server/org/opends/server/synchronization/changelog/ServerReader.java
+++ b/opends/src/server/org/opends/server/synchronization/changelog/ServerReader.java
@@ -34,6 +34,11 @@
import org.opends.server.api.DirectoryThread;
import org.opends.server.synchronization.protocol.AckMessage;
+import org.opends.server.synchronization.protocol.ErrorMessage;
+import org.opends.server.synchronization.protocol.DoneMessage;
+import org.opends.server.synchronization.protocol.EntryMessage;
+import org.opends.server.synchronization.protocol.InitializeRequestMessage;
+import org.opends.server.synchronization.protocol.InitializeTargetMessage;
import org.opends.server.synchronization.protocol.ProtocolSession;
import org.opends.server.synchronization.protocol.SynchronizationMessage;
import org.opends.server.synchronization.protocol.UpdateMessage;
@@ -116,6 +121,33 @@
WindowMessage windowMsg = (WindowMessage) msg;
handler.updateWindow(windowMsg);
}
+ else if (msg instanceof InitializeRequestMessage)
+ {
+ InitializeRequestMessage initializeMsg =
+ (InitializeRequestMessage) msg;
+ handler.process(initializeMsg);
+ }
+ else if (msg instanceof InitializeTargetMessage)
+ {
+ InitializeTargetMessage initializeMsg = (InitializeTargetMessage) msg;
+ handler.process(initializeMsg);
+ }
+ else if (msg instanceof EntryMessage)
+ {
+ EntryMessage entryMsg = (EntryMessage) msg;
+ handler.process(entryMsg);
+ }
+ else if (msg instanceof DoneMessage)
+ {
+ DoneMessage doneMsg = (DoneMessage) msg;
+ handler.process(doneMsg);
+ }
+ else if (msg instanceof ErrorMessage)
+ {
+ ErrorMessage errorMsg = (ErrorMessage) msg;
+ handler.process(errorMsg);
+ }
+
}
} catch (IOException e)
{
--
Gitblit v1.10.0