From 40cef7d36084fbe86d34cfa497628d8972c4c9e7 Mon Sep 17 00:00:00 2001
From: pgamba <pgamba@localhost>
Date: Thu, 29 Mar 2007 17:53:41 +0000
Subject: [PATCH]
---
opends/src/server/org/opends/server/synchronization/protocol/SynchronizationMessage.java | 27 +++++++++++++++++++++++++++
1 files changed, 27 insertions(+), 0 deletions(-)
diff --git a/opends/src/server/org/opends/server/synchronization/protocol/SynchronizationMessage.java b/opends/src/server/org/opends/server/synchronization/protocol/SynchronizationMessage.java
index aab19be..59777e5 100644
--- a/opends/src/server/org/opends/server/synchronization/protocol/SynchronizationMessage.java
+++ b/opends/src/server/org/opends/server/synchronization/protocol/SynchronizationMessage.java
@@ -47,6 +47,13 @@
static final byte MSG_TYPE_CHANGELOG_START = 7;
static final byte MSG_TYPE_WINDOW = 8;
static final byte MSG_TYPE_HEARTBEAT = 9;
+ static final byte MSG_TYPE_INITIALIZE_REQUEST = 10;
+ static final byte MSG_TYPE_INITIALIZE_TARGET = 11;
+ static final byte MSG_TYPE_ENTRY = 12;
+ static final byte MSG_TYPE_DONE = 13;
+ static final byte MSG_TYPE_ERROR = 14;
+ // Adding a new type of message here probably requires to
+ // change accordingly generateMsg method below
/**
* Return the byte[] representation of this message.
@@ -60,6 +67,11 @@
* MSG_TYPE_CHANGELOG_START
* MSG_TYPE_WINDOW
* MSG_TYPE_HEARTBEAT
+ * MSG_TYPE_INITIALIZE
+ * MSG_TYPE_INITIALIZE_TARGET
+ * MSG_TYPE_ENTRY
+ * MSG_TYPE_DONE
+ * MSG_TYPE_ERROR
*
* @return the byte[] representation of this message.
*/
@@ -107,6 +119,21 @@
case MSG_TYPE_HEARTBEAT:
msg = new HeartbeatMessage(buffer);
break;
+ case MSG_TYPE_INITIALIZE_REQUEST:
+ msg = new InitializeRequestMessage(buffer);
+ break;
+ case MSG_TYPE_INITIALIZE_TARGET:
+ msg = new InitializeTargetMessage(buffer);
+ break;
+ case MSG_TYPE_ENTRY:
+ msg = new EntryMessage(buffer);
+ break;
+ case MSG_TYPE_DONE:
+ msg = new DoneMessage(buffer);
+ break;
+ case MSG_TYPE_ERROR:
+ msg = new ErrorMessage(buffer);
+ break;
default:
throw new DataFormatException("received message with unknown type");
}
--
Gitblit v1.10.0