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/server/ECLServerHandler.java | 10 +++++-----
1 files changed, 5 insertions(+), 5 deletions(-)
diff --git a/opends/src/server/org/opends/server/replication/server/ECLServerHandler.java b/opends/src/server/org/opends/server/replication/server/ECLServerHandler.java
index ff7da17..168a69d 100644
--- a/opends/src/server/org/opends/server/replication/server/ECLServerHandler.java
+++ b/opends/src/server/org/opends/server/replication/server/ECLServerHandler.java
@@ -581,7 +581,7 @@
return null;
}
- final int firstChangeNumber = cnIndexDB.getFirstChangeNumber();
+ final long firstChangeNumber = cnIndexDB.getFirstChangeNumber();
final String crossDomainStartState =
cnIndexDB.getPreviousCookie(firstChangeNumber);
cnIndexDBCursor = cnIndexDB.getCursorFrom(firstChangeNumber);
@@ -606,10 +606,10 @@
* Get the draftLimits (from the eligibleCSN got at the beginning of the
* operation) in order to have the first and possible last change number.
*/
- final int[] limits = replicationServer.getECLChangeNumberLimits(
+ final long[] limits = replicationServer.getECLChangeNumberLimits(
eligibleCSN, excludedBaseDNs);
- final int firstChangeNumber = limits[0];
- final int lastChangeNumber = limits[1];
+ final long firstChangeNumber = limits[0];
+ final long lastChangeNumber = limits[1];
// If the startChangeNumber provided is lower than the firstChangeNumber in
// the DB, let's use the lower limit.
@@ -636,7 +636,7 @@
return null;
}
- final int lastKey = cnIndexDB.getLastChangeNumber();
+ final long lastKey = cnIndexDB.getLastChangeNumber();
crossDomainStartState = cnIndexDB.getPreviousCookie(lastKey);
cnIndexDBCursor = cnIndexDB.getCursorFrom(lastKey);
return crossDomainStartState;
--
Gitblit v1.10.0