From cb43ea459107cebc8790e7759c7e967254aeea62 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
---
opendj-sdk/opends/src/server/org/opends/server/replication/server/ReplicationServer.java | 16 ++++++++--------
1 files changed, 8 insertions(+), 8 deletions(-)
diff --git a/opendj-sdk/opends/src/server/org/opends/server/replication/server/ReplicationServer.java b/opendj-sdk/opends/src/server/org/opends/server/replication/server/ReplicationServer.java
index 1a4208e..59ce757 100644
--- a/opendj-sdk/opends/src/server/org/opends/server/replication/server/ReplicationServer.java
+++ b/opendj-sdk/opends/src/server/org/opends/server/replication/server/ReplicationServer.java
@@ -157,7 +157,7 @@
* <p>
* Guarded by cnIndexDBLock
**/
- private int lastGeneratedChangeNumber = 0;
+ private long lastGeneratedChangeNumber = 0;
/** Used for protecting {@link ChangeNumberIndexDB} related state. */
private final Object cnIndexDBLock = new Object();
@@ -1658,7 +1658,7 @@
*
* @return the first value.
*/
- public int getFirstChangeNumber()
+ public long getFirstChangeNumber()
{
synchronized (cnIndexDBLock)
{
@@ -1675,7 +1675,7 @@
*
* @return the last value.
*/
- public int getLastChangeNumber()
+ public long getLastChangeNumber()
{
synchronized (cnIndexDBLock)
{
@@ -1692,7 +1692,7 @@
*
* @return The generated change number
*/
- public int getNewChangeNumber()
+ public long getNewChangeNumber()
{
synchronized (cnIndexDBLock)
{
@@ -1712,7 +1712,7 @@
* @throws DirectoryException
* When it happens.
*/
- public int[] getECLChangeNumberLimits(CSN crossDomainEligibleCSN,
+ public long[] getECLChangeNumberLimits(CSN crossDomainEligibleCSN,
Set<String> excludedBaseDNs) throws DirectoryException
{
/* The content of the DraftCNdb depends on the SEARCH operations done before
@@ -1735,11 +1735,11 @@
* (this diff is done domain by domain)
*/
- int lastChangeNumber;
+ long lastChangeNumber;
boolean dbEmpty = false;
final ChangeNumberIndexDB cnIndexDB = getChangeNumberIndexDB();
- int firstChangeNumber = cnIndexDB.getFirstChangeNumber();
+ long firstChangeNumber = cnIndexDB.getFirstChangeNumber();
Map<String, ServerState> domainsServerStateForLastCN = null;
CSN csnForLastCN = null;
String domainForLastCN = null;
@@ -1821,7 +1821,7 @@
firstChangeNumber += lastGeneratedChangeNumber;
lastChangeNumber += lastGeneratedChangeNumber;
}
- return new int[]{firstChangeNumber, lastChangeNumber};
+ return new long[] { firstChangeNumber, lastChangeNumber };
}
/**
--
Gitblit v1.10.0