From b48ce50fdf4d73e8be3799e3a7c6c2bf9d1b2965 Mon Sep 17 00:00:00 2001
From: pgamba <pgamba@localhost>
Date: Sun, 02 Sep 2007 17:58:07 +0000
Subject: [PATCH] fix for #1733 & #845 - Initialization of replication
---
opends/src/server/org/opends/server/replication/protocol/ReplicationMessage.java | 6 ++++++
1 files changed, 6 insertions(+), 0 deletions(-)
diff --git a/opends/src/server/org/opends/server/replication/protocol/ReplicationMessage.java b/opends/src/server/org/opends/server/replication/protocol/ReplicationMessage.java
index 4bed982..ba72bf7 100644
--- a/opends/src/server/org/opends/server/replication/protocol/ReplicationMessage.java
+++ b/opends/src/server/org/opends/server/replication/protocol/ReplicationMessage.java
@@ -54,6 +54,8 @@
static final byte MSG_TYPE_ERROR = 14;
static final byte MSG_TYPE_WINDOW_PROBE = 15;
static final byte MSG_TYPE_REPL_SERVER_INFO = 16;
+ static final byte MSG_TYPE_RESET_GENERATION_ID = 17;
+
// Adding a new type of message here probably requires to
// change accordingly generateMsg method below
@@ -76,6 +78,7 @@
* MSG_TYPE_ERROR
* MSG_TYPE_WINDOW_PROBE
* MSG_TYPE_REPL_SERVER_INFO
+ * MSG_TYPE_RESET_GENERATION_ID
*
* @return the byte[] representation of this message.
* @throws UnsupportedEncodingException When the encoding of the message
@@ -140,6 +143,9 @@
case MSG_TYPE_ERROR:
msg = new ErrorMessage(buffer);
break;
+ case MSG_TYPE_RESET_GENERATION_ID:
+ msg = new ResetGenerationId(buffer);
+ break;
case MSG_TYPE_WINDOW_PROBE:
msg = new WindowProbe(buffer);
break;
--
Gitblit v1.10.0