From 11859d9a6e466bab4ab73e1e46d092c6052acf68 Mon Sep 17 00:00:00 2001
From: coulbeck <coulbeck@localhost>
Date: Fri, 02 Feb 2007 21:50:10 +0000
Subject: [PATCH] These changes are for issue 787: LDAP server need to detect failure of changelog servers
---
opendj-sdk/opends/src/server/org/opends/server/synchronization/protocol/SynchronizationMessage.java | 6 ++++++
1 files changed, 6 insertions(+), 0 deletions(-)
diff --git a/opendj-sdk/opends/src/server/org/opends/server/synchronization/protocol/SynchronizationMessage.java b/opendj-sdk/opends/src/server/org/opends/server/synchronization/protocol/SynchronizationMessage.java
index 77dcc1b..8aab0f5 100644
--- a/opendj-sdk/opends/src/server/org/opends/server/synchronization/protocol/SynchronizationMessage.java
+++ b/opendj-sdk/opends/src/server/org/opends/server/synchronization/protocol/SynchronizationMessage.java
@@ -46,6 +46,7 @@
static final byte MSG_TYPE_SERVER_START = 6;
static final byte MSG_TYPE_CHANGELOG_START = 7;
static final byte MSG_TYPE_WINDOW = 8;
+ static final byte MSG_TYPE_HEARTBEAT = 9;
/**
* Return the byte[] representation of this message.
@@ -57,6 +58,8 @@
* MSG_TYPE_ACK
* MSG_TYPE_SERVER_START
* MSG_TYPE_CHANGELOG_START
+ * MSG_TYPE_WINDOW
+ * MSG_TYPE_HEARTBEAT
*
* @return the byte[] representation of this message.
*/
@@ -101,6 +104,9 @@
case MSG_TYPE_WINDOW:
msg = new WindowMessage(buffer);
break;
+ case MSG_TYPE_HEARTBEAT:
+ msg = new HeartbeatMessage(buffer);
+ break;
default:
throw new DataFormatException("received message with unknown type");
}
--
Gitblit v1.10.0