From 01eb7d07467b57c61868c73e9a94bff1d0b2dcd1 Mon Sep 17 00:00:00 2001
From: Nicolas Capponi <nicolas.capponi@forgerock.com>
Date: Wed, 21 May 2014 15:56:41 +0000
Subject: [PATCH] OPENDJ-1389 – Add support for replication changelog DB rotation
---
opends/src/server/org/opends/server/replication/server/changelog/file/FileReplicaDBCursor.java | 7 +++----
1 files changed, 3 insertions(+), 4 deletions(-)
diff --git a/opends/src/server/org/opends/server/replication/server/changelog/file/FileReplicaDBCursor.java b/opends/src/server/org/opends/server/replication/server/changelog/file/FileReplicaDBCursor.java
index 3f3a2fa..e067b6a 100644
--- a/opends/src/server/org/opends/server/replication/server/changelog/file/FileReplicaDBCursor.java
+++ b/opends/src/server/org/opends/server/replication/server/changelog/file/FileReplicaDBCursor.java
@@ -29,7 +29,7 @@
import org.opends.server.replication.protocol.UpdateMsg;
import org.opends.server.replication.server.changelog.api.ChangelogException;
import org.opends.server.replication.server.changelog.api.DBCursor;
-import org.opends.server.replication.server.changelog.file.LogFile.LogCursor;
+import org.opends.server.replication.server.changelog.file.Log.RepositionableCursor;
/**
* A cursor on ReplicaDB.
@@ -49,7 +49,7 @@
{
/** The underlying cursor. */
- private final LogCursor<CSN, UpdateMsg> cursor;
+ private final RepositionableCursor<CSN, UpdateMsg> cursor;
/** The next record to return. */
private Record<CSN, UpdateMsg> nextRecord;
@@ -66,7 +66,7 @@
* The CSN to use as a start point (excluded from cursor, the lowest
* CSN higher than this CSN is used as the real start point).
*/
- FileReplicaDBCursor(LogCursor<CSN, UpdateMsg> cursor, CSN startAfterCSN) {
+ FileReplicaDBCursor(RepositionableCursor<CSN, UpdateMsg> cursor, CSN startAfterCSN) {
this.cursor = cursor;
this.lastNonNullCurrentCSN = startAfterCSN;
}
@@ -90,7 +90,6 @@
else
{
// Exhausted cursor must be able to reinitialize itself
- cursor.rewind();
cursor.positionTo(lastNonNullCurrentCSN, true);
nextRecord = cursor.getRecord();
--
Gitblit v1.10.0