From c02dd7f87e9ba574f06e5cc1eb36ebeb76b9f446 Mon Sep 17 00:00:00 2001
From: mrossign <mrossign@localhost>
Date: Thu, 08 Oct 2009 16:02:17 +0000
Subject: [PATCH] - Addition of ReplServerStartDSMsg now sent to a DS connecting to a RS in handshake phase instead of a ReplServerStartMsg. ReplServerStartDSMsg contains same thing as ReplServerStartMsg but also contains
---
opendj-sdk/opends/src/server/org/opends/server/replication/protocol/ReplicationMsg.java | 12 +++++++++++-
1 files changed, 11 insertions(+), 1 deletions(-)
diff --git a/opendj-sdk/opends/src/server/org/opends/server/replication/protocol/ReplicationMsg.java b/opendj-sdk/opends/src/server/org/opends/server/replication/protocol/ReplicationMsg.java
index 466d884..e2ba2e3 100644
--- a/opendj-sdk/opends/src/server/org/opends/server/replication/protocol/ReplicationMsg.java
+++ b/opendj-sdk/opends/src/server/org/opends/server/replication/protocol/ReplicationMsg.java
@@ -71,12 +71,16 @@
static final byte MSG_TYPE_CHANGE_STATUS = 28;
static final byte MSG_TYPE_GENERIC_UPDATE = 29;
- // Protocol version : 3
+ // Added for protocol version 3
static final byte MSG_TYPE_START_ECL = 30;
static final byte MSG_TYPE_START_ECL_SESSION = 31;
static final byte MSG_TYPE_ECL_UPDATE = 32;
static final byte MSG_TYPE_CT_HEARTBEAT = 33;
+ // Added for protocol version 4
+ static final byte MSG_TYPE_REPL_SERVER_START_DS = 34;
+ static final byte MSG_TYPE_STOP = 35;
+
// Adding a new type of message here probably requires to
// change accordingly generateMsg method below
@@ -238,6 +242,12 @@
case MSG_TYPE_CT_HEARTBEAT:
msg = new ChangeTimeHeartbeatMsg(buffer);
break;
+ case MSG_TYPE_REPL_SERVER_START_DS:
+ msg = new ReplServerStartDSMsg(buffer);
+ break;
+ case MSG_TYPE_STOP:
+ msg = new StopMsg(buffer);
+ break;
default:
throw new DataFormatException("received message with unknown type");
}
--
Gitblit v1.10.0