From ab3cac04319c920ba14be59ea874e6e35f730655 Mon Sep 17 00:00:00 2001
From: Nicolas Capponi <nicolas.capponi@forgerock.com>
Date: Mon, 21 Jul 2014 17:06:28 +0000
Subject: [PATCH] Checkpoint commit for OPENDJ-1206 : Create a new ReplicationBackend/ChangelogBackend to support cn=changelog CR-4053
---
opends/src/server/org/opends/server/replication/server/changelog/je/MultiDomainDBCursor.java | 10 ++++++++--
1 files changed, 8 insertions(+), 2 deletions(-)
diff --git a/opends/src/server/org/opends/server/replication/server/changelog/je/MultiDomainDBCursor.java b/opends/src/server/org/opends/server/replication/server/changelog/je/MultiDomainDBCursor.java
index cf88679..a7f067f 100644
--- a/opends/src/server/org/opends/server/replication/server/changelog/je/MultiDomainDBCursor.java
+++ b/opends/src/server/org/opends/server/replication/server/changelog/je/MultiDomainDBCursor.java
@@ -50,15 +50,21 @@
private final ConcurrentSkipListSet<DN> removeDomains =
new ConcurrentSkipListSet<DN>();
+ private final PositionStrategy positionStrategy;
+
/**
* Builds a MultiDomainDBCursor instance.
*
* @param domainDB
* the replication domain management DB
+ * @param positionStrategy
+ * Cursor position strategy, which allow to indicates at which
+ * exact position the cursor must start
*/
- public MultiDomainDBCursor(ReplicationDomainDB domainDB)
+ public MultiDomainDBCursor(ReplicationDomainDB domainDB, PositionStrategy positionStrategy)
{
this.domainDB = domainDB;
+ this.positionStrategy = positionStrategy;
}
/**
@@ -86,7 +92,7 @@
final Entry<DN, ServerState> entry = iter.next();
final DN baseDN = entry.getKey();
final ServerState serverState = entry.getValue();
- final DBCursor<UpdateMsg> domainDBCursor = domainDB.getCursorFrom(baseDN, serverState);
+ final DBCursor<UpdateMsg> domainDBCursor = domainDB.getCursorFrom(baseDN, serverState, positionStrategy);
addCursor(domainDBCursor, baseDN);
iter.remove();
}
--
Gitblit v1.10.0