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/DraftCNDbHandler.java | 20 ++++++++++----------
1 files changed, 10 insertions(+), 10 deletions(-)
diff --git a/opends/src/server/org/opends/server/replication/server/changelog/je/DraftCNDbHandler.java b/opends/src/server/org/opends/server/replication/server/changelog/je/DraftCNDbHandler.java
index 8e958c2..3d57e71 100644
--- a/opends/src/server/org/opends/server/replication/server/changelog/je/DraftCNDbHandler.java
+++ b/opends/src/server/org/opends/server/replication/server/changelog/je/DraftCNDbHandler.java
@@ -65,7 +65,7 @@
* This class publishes some monitoring information below <code>
* cn=monitor</code>.
*/
-public class DraftCNDbHandler implements ChangeNumberIndexDB
+public class DraftCNDbHandler implements ChangeNumberIndexDB, Runnable
{
/**
* The tracer object for the debug logger.
@@ -136,7 +136,7 @@
/** {@inheritDoc} */
@Override
- public synchronized void add(int changeNumber, String previousCookie,
+ public synchronized void add(long changeNumber, String previousCookie,
String baseDN, CSN csn)
{
db.addEntry(changeNumber, previousCookie, baseDN, csn);
@@ -152,14 +152,14 @@
/** {@inheritDoc} */
@Override
- public int getFirstChangeNumber()
+ public long getFirstChangeNumber()
{
return db.readFirstChangeNumber();
}
/** {@inheritDoc} */
@Override
- public int getLastChangeNumber()
+ public long getLastChangeNumber()
{
return db.readLastChangeNumber();
}
@@ -207,7 +207,7 @@
* @throws ChangelogException
* if a database problem occurs.
*/
- DraftCNDBCursor getReadCursor(int startChangeNumber)
+ DraftCNDBCursor getReadCursor(long startChangeNumber)
throws ChangelogException
{
return db.openReadCursor(startChangeNumber);
@@ -215,7 +215,7 @@
/** {@inheritDoc} */
@Override
- public ChangeNumberIndexDBCursor getCursorFrom(int startChangeNumber)
+ public ChangeNumberIndexDBCursor getCursorFrom(long startChangeNumber)
throws ChangelogException
{
return new DraftCNDbIterator(db, startChangeNumber);
@@ -516,7 +516,7 @@
/** {@inheritDoc} */
@Override
- public String getPreviousCookie(int changeNumber)
+ public String getPreviousCookie(long changeNumber)
{
DraftCNDBCursor cursor = null;
try
@@ -537,7 +537,7 @@
/** {@inheritDoc} */
@Override
- public CSN getCSN(int changeNumber)
+ public CSN getCSN(long changeNumber)
{
DraftCNDBCursor cursor = null;
try
@@ -558,7 +558,7 @@
/**{@inheritDoc}*/
@Override
- public String getBaseDN(int changeNumber)
+ public String getBaseDN(long changeNumber)
{
DraftCNDBCursor cursor = null;
try
@@ -577,7 +577,7 @@
}
}
- private void debugException(String methodName, int changeNumber, Exception e)
+ private void debugException(String methodName, long changeNumber, Exception e)
{
if (debugEnabled())
TRACER.debugInfo("In DraftCNDbHandler." + methodName + "(), read: "
--
Gitblit v1.10.0