From 57cd4228444c9dfa5abdfba9183f42c898a05675 Mon Sep 17 00:00:00 2001
From: Jean-Noel Rouvignac <jean-noel.rouvignac@forgerock.com>
Date: Thu, 10 Oct 2013 11:32:10 +0000
Subject: [PATCH] OPENDJ-1116 Introduce abstraction for the changelog DB
---
opendj-sdk/opends/src/server/org/opends/server/replication/server/changelog/je/JEReplicaDB.java | 21 +++++++++++----------
1 files changed, 11 insertions(+), 10 deletions(-)
diff --git a/opendj-sdk/opends/src/server/org/opends/server/replication/server/changelog/je/JEReplicaDB.java b/opendj-sdk/opends/src/server/org/opends/server/replication/server/changelog/je/JEReplicaDB.java
index 2424239..032dcad 100644
--- a/opendj-sdk/opends/src/server/org/opends/server/replication/server/changelog/je/JEReplicaDB.java
+++ b/opendj-sdk/opends/src/server/org/opends/server/replication/server/changelog/je/JEReplicaDB.java
@@ -43,7 +43,7 @@
import org.opends.server.replication.server.ReplicationServer;
import org.opends.server.replication.server.ReplicationServerDomain;
import org.opends.server.replication.server.changelog.api.ChangelogException;
-import org.opends.server.replication.server.changelog.api.ReplicaDBCursor;
+import org.opends.server.replication.server.changelog.api.DBCursor;
import org.opends.server.replication.server.changelog.je.ReplicationDB.*;
import org.opends.server.types.Attribute;
import org.opends.server.types.Attributes;
@@ -58,11 +58,13 @@
/**
* This class is used for managing the replicationServer database for each
* server in the topology.
+ * <p>
* It is responsible for efficiently saving the updates that is received from
* each master server into stable storage.
- * This class is also able to generate a {@link ReplicaDBCursor} that can be
- * used to read all changes from a given {@link CSN}.
- *
+ * <p>
+ * This class is also able to generate a {@link DBCursor} that can be used to
+ * read all changes from a given {@link CSN}.
+ * <p>
* This class publish some monitoring information below cn=monitor.
*/
public class JEReplicaDB implements Runnable
@@ -259,19 +261,18 @@
}
/**
- * Generate a new {@link ReplicaDBCursor} that allows to browse the db managed
- * by this ReplicaDB and starting at the position defined by a given CSN.
+ * Generate a new {@link DBCursor} that allows to browse the db managed by
+ * this ReplicaDB and starting at the position defined by a given CSN.
*
* @param startAfterCSN
* The position where the cursor must start. If null, start from the
* oldest CSN
- * @return a new {@link ReplicaDBCursor} that allows to browse the db managed
- * by this ReplicaDB and starting at the position defined by a given
- * CSN.
+ * @return a new {@link DBCursor} that allows to browse the db managed by this
+ * ReplicaDB and starting at the position defined by a given CSN.
* @throws ChangelogException
* if a database problem happened.
*/
- public ReplicaDBCursor generateCursorFrom(CSN startAfterCSN)
+ public DBCursor<UpdateMsg> generateCursorFrom(CSN startAfterCSN)
throws ChangelogException
{
if (startAfterCSN == null)
--
Gitblit v1.10.0