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/changelog/je/DraftCNDB.java | 8 ++++----
1 files changed, 4 insertions(+), 4 deletions(-)
diff --git a/opends/src/server/org/opends/server/replication/server/changelog/je/DraftCNDB.java b/opends/src/server/org/opends/server/replication/server/changelog/je/DraftCNDB.java
index 440c6ad..e95fa04 100644
--- a/opends/src/server/org/opends/server/replication/server/changelog/je/DraftCNDB.java
+++ b/opends/src/server/org/opends/server/replication/server/changelog/je/DraftCNDB.java
@@ -92,7 +92,7 @@
* @param csn the provided replication CSN to be
* stored associated with this change number.
*/
- public void addEntry(int changeNumber, String value, String domainBaseDN,
+ public void addEntry(long changeNumber, String value, String domainBaseDN,
CSN csn)
{
try
@@ -187,7 +187,7 @@
* creation.
* @return The ReplServerDBCursor.
*/
- public DraftCNDBCursor openReadCursor(int changeNumber)
+ public DraftCNDBCursor openReadCursor(long changeNumber)
throws ChangelogException
{
return new DraftCNDBCursor(changeNumber);
@@ -362,7 +362,7 @@
* @throws ChangelogException
* when the startChangeNumber does not exist.
*/
- private DraftCNDBCursor(int startChangeNumber) throws ChangelogException
+ private DraftCNDBCursor(long startChangeNumber) throws ChangelogException
{
this.key = new ReplicationDraftCNKey(startChangeNumber);
this.entry = new DatabaseEntry();
@@ -392,7 +392,7 @@
// We could not move the cursor to the expected startChangeNumber
if (localCursor.getSearchKeyRange(key, entry, DEFAULT) != SUCCESS)
{
- // We could not even move the cursor closed to it => failure
+ // We could not even move the cursor close to it => failure
throw new ChangelogException(
Message.raw("ChangeLog Change Number " + startChangeNumber
+ " is not available"));
--
Gitblit v1.10.0