From 3c062316441f2adb96afb6a6a98c09d91c27bd97 Mon Sep 17 00:00:00 2001
From: Jean-Noel Rouvignac <jean-noel.rouvignac@forgerock.com>
Date: Tue, 08 Oct 2013 15:07:11 +0000
Subject: [PATCH] OPENDJ-1116 Introduce abstraction for the changelog DB
---
opends/src/server/org/opends/server/replication/server/changelog/je/JEChangeNumberIndexDB.java | 15 +++++++++------
1 files changed, 9 insertions(+), 6 deletions(-)
diff --git a/opends/src/server/org/opends/server/replication/server/changelog/je/JEChangeNumberIndexDB.java b/opends/src/server/org/opends/server/replication/server/changelog/je/JEChangeNumberIndexDB.java
index daf3f0a..a6e9d17 100644
--- a/opends/src/server/org/opends/server/replication/server/changelog/je/JEChangeNumberIndexDB.java
+++ b/opends/src/server/org/opends/server/replication/server/changelog/je/JEChangeNumberIndexDB.java
@@ -153,12 +153,17 @@
/** {@inheritDoc} */
@Override
- public void addRecord(CNIndexRecord record) throws ChangelogException
+ public long addRecord(CNIndexRecord record) throws ChangelogException
{
- db.addRecord(record);
+ long changeNumber = nextChangeNumber();
+ final CNIndexRecord newRecord =
+ new CNIndexRecord(changeNumber, record.getPreviousCookie(), record
+ .getBaseDN(), record.getCSN());
+ db.addRecord(newRecord);
if (debugEnabled())
- TRACER.debugInfo("In JEChangeNumberIndexDB.add, added: " + record);
+ TRACER.debugInfo("In JEChangeNumberIndexDB.add, added: " + newRecord);
+ return changeNumber;
}
/** {@inheritDoc} */
@@ -175,9 +180,7 @@
return db.readLastRecord();
}
- /** {@inheritDoc} */
- @Override
- public long nextChangeNumber()
+ private long nextChangeNumber()
{
return lastGeneratedChangeNumber.incrementAndGet();
}
--
Gitblit v1.10.0