From 87b6a9294f437fd6312c2fbe2292ee64babd8d7e Mon Sep 17 00:00:00 2001
From: Jean-Noel Rouvignac <jean-noel.rouvignac@forgerock.com>
Date: Thu, 10 Oct 2013 14:45:51 +0000
Subject: [PATCH] OPENDJ-1116 Introduce abstraction for the changelog DB
---
opends/src/server/org/opends/server/replication/server/changelog/je/DraftCNData.java | 18 +++++++++---------
1 files changed, 9 insertions(+), 9 deletions(-)
diff --git a/opends/src/server/org/opends/server/replication/server/changelog/je/DraftCNData.java b/opends/src/server/org/opends/server/replication/server/changelog/je/DraftCNData.java
index c6faad5..fc4b194 100644
--- a/opends/src/server/org/opends/server/replication/server/changelog/je/DraftCNData.java
+++ b/opends/src/server/org/opends/server/replication/server/changelog/je/DraftCNData.java
@@ -31,8 +31,7 @@
import org.opends.messages.Message;
import org.opends.server.replication.common.CSN;
-import org.opends.server.replication.server.changelog.api.CNIndexRecord;
-import org.opends.server.replication.server.changelog.api.ChangelogException;
+import org.opends.server.replication.server.changelog.api.*;
import org.opends.server.types.DN;
import org.opends.server.types.DirectoryException;
@@ -50,7 +49,7 @@
private static final long serialVersionUID = 1L;
private long changeNumber;
- private CNIndexRecord record;
+ private ChangeNumberIndexRecord record;
/**
* Creates a record to be stored in the DraftCNDB.
@@ -90,16 +89,16 @@
}
/**
- * Decode and returns a {@link CNIndexRecord}.
+ * Decode and returns a {@link ChangeNumberIndexRecord}.
*
* @param changeNumber
* @param data
* the provided byte array.
- * @return the decoded {@link CNIndexRecord}
+ * @return the decoded {@link ChangeNumberIndexRecord}
* @throws ChangelogException
* when a problem occurs.
*/
- private CNIndexRecord decodeData(long changeNumber, byte[] data)
+ private ChangeNumberIndexRecord decodeData(long changeNumber, byte[] data)
throws ChangelogException
{
try
@@ -107,7 +106,8 @@
String stringData = new String(data, "UTF-8");
String[] str = stringData.split(FIELD_SEPARATOR, 3);
final DN baseDN = DN.decode(str[1]);
- return new CNIndexRecord(changeNumber, str[0], baseDN, new CSN(str[2]));
+ final CSN csn = new CSN(str[2]);
+ return new ChangeNumberIndexRecord(changeNumber, str[0], baseDN, csn);
}
catch (UnsupportedEncodingException e)
{
@@ -124,11 +124,11 @@
/**
* Getter for the decoded record.
*
- * @return the {@link CNIndexRecord} record.
+ * @return the {@link ChangeNumberIndexRecord} record.
* @throws ChangelogException
* when a problem occurs.
*/
- public CNIndexRecord getRecord() throws ChangelogException
+ public ChangeNumberIndexRecord getRecord() throws ChangelogException
{
if (record == null)
record = decodeData(changeNumber, getData());
--
Gitblit v1.10.0