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/protocol/SocketSession.java | 11 ++++++++++-
1 files changed, 10 insertions(+), 1 deletions(-)
diff --git a/opends/src/server/org/opends/server/replication/protocol/SocketSession.java b/opends/src/server/org/opends/server/replication/protocol/SocketSession.java
index e20bffa..0631618 100644
--- a/opends/src/server/org/opends/server/replication/protocol/SocketSession.java
+++ b/opends/src/server/org/opends/server/replication/protocol/SocketSession.java
@@ -69,6 +69,7 @@
private boolean closeInitiated = false;
+ private short protocolVersion = ProtocolVersion.getCurrentVersion();
/**
* Creates a new SocketSession based on the provided socket.
@@ -175,7 +176,7 @@
/* We do not want the heartbeat to close the session when */
/* we are processing a message even a time consuming one. */
lastReceiveTime=0;
- return ReplicationMsg.generateMsg(buffer);
+ return ReplicationMsg.generateMsg(buffer, protocolVersion);
}
catch (OutOfMemoryError e)
{
@@ -243,4 +244,12 @@
{
return closeInitiated;
}
+
+ /**
+ * {@inheritDoc}
+ */
+ public void setProtocolVersion(short version)
+ {
+ protocolVersion = version;
+ }
}
--
Gitblit v1.10.0