From bd3c137fd2e1fa9e13289ab0573e07f9a4212e05 Mon Sep 17 00:00:00 2001
From: Jean-Noel Rouvignac <jean-noel.rouvignac@forgerock.com>
Date: Fri, 30 Aug 2013 09:56:47 +0000
Subject: [PATCH] OPENDJ-1116 Introduce abstraction for the changelog DB
---
opends/src/server/org/opends/server/replication/server/ReplicationBackend.java | 14 +++++++-------
1 files changed, 7 insertions(+), 7 deletions(-)
diff --git a/opends/src/server/org/opends/server/replication/server/ReplicationBackend.java b/opends/src/server/org/opends/server/replication/server/ReplicationBackend.java
index f84ac2f..385a80d 100644
--- a/opends/src/server/org/opends/server/replication/server/ReplicationBackend.java
+++ b/opends/src/server/org/opends/server/replication/server/ReplicationBackend.java
@@ -50,7 +50,7 @@
import org.opends.server.replication.plugin.MultimasterReplication;
import org.opends.server.replication.plugin.ReplicationServerListener;
import org.opends.server.replication.protocol.*;
-import org.opends.server.replication.server.changelog.api.ReplicationIterator;
+import org.opends.server.replication.server.changelog.api.ReplicationDBCursor;
import org.opends.server.types.*;
import org.opends.server.util.*;
@@ -631,15 +631,15 @@
return;
}
- ReplicationIterator ri = rsd.getChangelogIterator(serverId, previousCN);
- if (ri != null)
+ ReplicationDBCursor cursor = rsd.getCursorFrom(serverId, previousCN);
+ if (cursor != null)
{
try
{
int lookthroughCount = 0;
// Walk through the changes
- while (ri.getChange() != null)
+ while (cursor.getChange() != null)
{
if (exportConfig != null && exportConfig.isCancelled())
{ // abort if cancelled
@@ -650,14 +650,14 @@
break;
}
lookthroughCount++;
- writeChange(ri.getChange(), ldifWriter, searchOperation,
+ writeChange(cursor.getChange(), ldifWriter, searchOperation,
rsd.getBaseDn(), exportConfig != null);
- ri.next();
+ cursor.next();
}
}
finally
{
- close(ri);
+ close(cursor);
}
}
}
--
Gitblit v1.10.0