From 4772c4aec3a23175ad9ac33b4cd843062168d335 Mon Sep 17 00:00:00 2001
From: Jean-Noel Rouvignac <jean-noel.rouvignac@forgerock.com>
Date: Fri, 30 Aug 2013 12:29:54 +0000
Subject: [PATCH] OPENDJ-1116 Introduce abstraction for the changelog DB
---
opends/src/server/org/opends/server/replication/server/ReplicationServerDomain.java | 12 ++++++------
1 files changed, 6 insertions(+), 6 deletions(-)
diff --git a/opends/src/server/org/opends/server/replication/server/ReplicationServerDomain.java b/opends/src/server/org/opends/server/replication/server/ReplicationServerDomain.java
index 3b0b472..6723f21 100644
--- a/opends/src/server/org/opends/server/replication/server/ReplicationServerDomain.java
+++ b/opends/src/server/org/opends/server/replication/server/ReplicationServerDomain.java
@@ -47,7 +47,7 @@
import org.opends.server.replication.common.*;
import org.opends.server.replication.protocol.*;
import org.opends.server.replication.server.changelog.api.ChangelogException;
-import org.opends.server.replication.server.changelog.api.ReplicationDBCursor;
+import org.opends.server.replication.server.changelog.api.ReplicaDBCursor;
import org.opends.server.replication.server.changelog.je.DbHandler;
import org.opends.server.types.*;
@@ -1263,17 +1263,17 @@
/**
* Creates and returns a cursor. When the cursor is not used anymore, the
- * caller MUST call the {@link ReplicationDBCursor#close()} method to free the
+ * caller MUST call the {@link ReplicaDBCursor#close()} method to free the
* resources and locks used by the cursor.
*
* @param serverId
* Identifier of the server for which the cursor is created.
* @param startAfterCN
* Starting point for the cursor.
- * @return the created {@link ReplicationDBCursor}. Null when no DB is
+ * @return the created {@link ReplicaDBCursor}. Null when no DB is
* available or the DB is empty for the provided serverId .
*/
- public ReplicationDBCursor getCursorFrom(int serverId,
+ public ReplicaDBCursor getCursorFrom(int serverId,
ChangeNumber startAfterCN)
{
DbHandler dbHandler = sourceDbHandlers.get(serverId);
@@ -1282,7 +1282,7 @@
return null;
}
- ReplicationDBCursor cursor;
+ ReplicaDBCursor cursor;
try
{
cursor = dbHandler.generateCursorFrom(startAfterCN);
@@ -2680,7 +2680,7 @@
// to the Db and look for the change older than eligible CN (cn14)
if (eligibleCN.olderOrEqual(mostRecentDbCN)) {
// let's try to seek the first change <= eligibleCN
- ReplicationDBCursor cursor = null;
+ ReplicaDBCursor cursor = null;
try {
cursor = h.generateCursorFrom(eligibleCN);
if (cursor != null && cursor.getChange() != null) {
--
Gitblit v1.10.0