From 355365ea3f95fdfec5cac95588044b91354096c8 Mon Sep 17 00:00:00 2001
From: Jean-Noel Rouvignac <jean-noel.rouvignac@forgerock.com>
Date: Tue, 19 Aug 2014 11:11:46 +0000
Subject: [PATCH] OPENDJ-1441 (CR-4303) Persistent searches on external changelog do not return changes for new replicas and new domains
---
opends/src/server/org/opends/server/replication/server/changelog/je/MultiDomainDBCursor.java | 13 +------------
1 files changed, 1 insertions(+), 12 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 a7f067f..690e551 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
@@ -27,7 +27,6 @@
import java.util.Iterator;
import java.util.Map.Entry;
import java.util.concurrent.ConcurrentSkipListMap;
-import java.util.concurrent.ConcurrentSkipListSet;
import org.opends.server.replication.common.ServerState;
import org.opends.server.replication.protocol.UpdateMsg;
@@ -47,8 +46,6 @@
private final ConcurrentSkipListMap<DN, ServerState> newDomains =
new ConcurrentSkipListMap<DN, ServerState>();
- private final ConcurrentSkipListSet<DN> removeDomains =
- new ConcurrentSkipListSet<DN>();
private final PositionStrategy positionStrategy;
@@ -108,14 +105,7 @@
*/
public void removeDomain(DN baseDN)
{
- removeDomains.add(baseDN);
- }
-
- /** {@inheritDoc} */
- @Override
- protected Iterator<DN> removedCursorsIterator()
- {
- return removeDomains.iterator();
+ removeCursor(baseDN);
}
/** {@inheritDoc} */
@@ -125,7 +115,6 @@
super.close();
domainDB.unregisterCursor(this);
newDomains.clear();
- removeDomains.clear();
}
}
--
Gitblit v1.10.0