| | |
| | | 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; |
| | |
| | | |
| | | private final ConcurrentSkipListMap<DN, ServerState> newDomains = |
| | | new ConcurrentSkipListMap<DN, ServerState>(); |
| | | private final ConcurrentSkipListSet<DN> removeDomains = |
| | | new ConcurrentSkipListSet<DN>(); |
| | | |
| | | private final PositionStrategy positionStrategy; |
| | | |
| | |
| | | */ |
| | | public void removeDomain(DN baseDN) |
| | | { |
| | | removeDomains.add(baseDN); |
| | | } |
| | | |
| | | /** {@inheritDoc} */ |
| | | @Override |
| | | protected Iterator<DN> removedCursorsIterator() |
| | | { |
| | | return removeDomains.iterator(); |
| | | removeCursor(baseDN); |
| | | } |
| | | |
| | | /** {@inheritDoc} */ |
| | |
| | | super.close(); |
| | | domainDB.unregisterCursor(this); |
| | | newDomains.clear(); |
| | | removeDomains.clear(); |
| | | } |
| | | |
| | | } |