From b1ae3d652cc31c837721fd750623cec531b94d93 Mon Sep 17 00:00:00 2001
From: Jean-Noel Rouvignac <jean-noel.rouvignac@forgerock.com>
Date: Wed, 04 Sep 2013 10:57:18 +0000
Subject: [PATCH] OPENDJ-1116 Introduce abstraction for the changelog DB
---
opends/src/server/org/opends/server/replication/protocol/ECLUpdateMsg.java | 11 +++++++----
1 files changed, 7 insertions(+), 4 deletions(-)
diff --git a/opends/src/server/org/opends/server/replication/protocol/ECLUpdateMsg.java b/opends/src/server/org/opends/server/replication/protocol/ECLUpdateMsg.java
index 8736254..c053665 100644
--- a/opends/src/server/org/opends/server/replication/protocol/ECLUpdateMsg.java
+++ b/opends/src/server/org/opends/server/replication/protocol/ECLUpdateMsg.java
@@ -49,7 +49,7 @@
private MultiDomainServerState cookie;
/** The changeNumber as specified by draft-good-ldap-changelog. */
- private int changeNumber;
+ private long changeNumber;
/**
* Creates a new message.
@@ -184,7 +184,10 @@
{
byte[] byteCookie = String.valueOf(cookie).getBytes("UTF-8");
byte[] byteBaseDN = String.valueOf(baseDN).getBytes("UTF-8");
- byte[] byteChangeNumber = Integer.toString(changeNumber).getBytes("UTF-8");
+ // FIXME JNR Changing line below to use long would require a protocol
+ // version change. Leave it like this for now until the need arises.
+ byte[] byteChangeNumber =
+ Integer.toString((int) changeNumber).getBytes("UTF-8");
byte[] byteUpdateMsg = updateMsg.getBytes(protocolVersion);
int length = 1 + byteCookie.length +
@@ -211,7 +214,7 @@
* Setter for the changeNumber of this change.
* @param changeNumber the provided changeNumber for this change.
*/
- public void setChangeNumber(int changeNumber)
+ public void setChangeNumber(long changeNumber)
{
this.changeNumber = changeNumber;
}
@@ -220,7 +223,7 @@
* Getter for the changeNumber of this change.
* @return the changeNumber of this change.
*/
- public int getChangeNumber()
+ public long getChangeNumber()
{
return this.changeNumber;
}
--
Gitblit v1.10.0