From 99480fcbcb68be6a357f6218668feab697e1a93d Mon Sep 17 00:00:00 2001
From: gbellato <gbellato@localhost>
Date: Tue, 07 Jul 2009 14:55:26 +0000
Subject: [PATCH] Fix for 4096 MonitorMsg is not compatible with replication version
---
opends/src/server/org/opends/server/replication/server/ReplicationServer.java | 4 ++++
1 files changed, 4 insertions(+), 0 deletions(-)
diff --git a/opends/src/server/org/opends/server/replication/server/ReplicationServer.java b/opends/src/server/org/opends/server/replication/server/ReplicationServer.java
index e72f3f7..77d068f 100644
--- a/opends/src/server/org/opends/server/replication/server/ReplicationServer.java
+++ b/opends/src/server/org/opends/server/replication/server/ReplicationServer.java
@@ -75,6 +75,7 @@
import org.opends.server.replication.protocol.ServerStartECLMsg;
import org.opends.server.replication.protocol.ServerStartMsg;
import org.opends.server.replication.protocol.StartECLSessionMsg;
+import org.opends.server.replication.protocol.StartMsg;
import org.opends.server.types.BackupConfig;
import org.opends.server.types.ConfigChangeResult;
import org.opends.server.types.DN;
@@ -299,18 +300,21 @@
if (msg instanceof ServerStartMsg)
{
+ session.setProtocolVersion(((StartMsg)msg).getVersion());
DataServerHandler handler = new DataServerHandler(session,
queueSize,serverURL,serverId,this,rcvWindow);
handler.startFromRemoteDS((ServerStartMsg)msg);
}
else if (msg instanceof ReplServerStartMsg)
{
+ session.setProtocolVersion(((StartMsg)msg).getVersion());
ReplicationServerHandler handler = new ReplicationServerHandler(
session,queueSize,serverURL,serverId,this,rcvWindow);
handler.startFromRemoteRS((ReplServerStartMsg)msg);
}
else if (msg instanceof ServerStartECLMsg)
{
+ session.setProtocolVersion(((StartMsg)msg).getVersion());
ECLServerHandler handler = new ECLServerHandler(
session,queueSize,serverURL,serverId,this,rcvWindow);
handler.startFromRemoteServer((ServerStartECLMsg)msg);
--
Gitblit v1.10.0