From 67649485a8b644abfc3f0ab7890df02d6e9fe2e8 Mon Sep 17 00:00:00 2001
From: Jean-Noel Rouvignac <jean-noel.rouvignac@forgerock.com>
Date: Thu, 22 Aug 2013 14:13:20 +0000
Subject: [PATCH] ReplicationIterator.java: Renamed releaseCursor() to close(). Now extends Closeable.
---
opends/src/server/org/opends/server/replication/server/ReplicationServerDomain.java | 11 ++---------
1 files changed, 2 insertions(+), 9 deletions(-)
diff --git a/opends/src/server/org/opends/server/replication/server/ReplicationServerDomain.java b/opends/src/server/org/opends/server/replication/server/ReplicationServerDomain.java
index 3b50887..7afb0d0 100644
--- a/opends/src/server/org/opends/server/replication/server/ReplicationServerDomain.java
+++ b/opends/src/server/org/opends/server/replication/server/ReplicationServerDomain.java
@@ -1311,7 +1311,7 @@
if (!it.next())
{
- it.releaseCursor();
+ close(it);
return null;
}
@@ -1867,11 +1867,6 @@
}
}
- private void sleep(int millis)
- {
- try { Thread.sleep(millis); } catch (InterruptedException e) {}
- }
-
/**
* Creates a TopologyMsg filled with information to be sent to a remote RS.
* We send remote RS the info of every DS that are directly connected to us
@@ -2717,9 +2712,7 @@
// there's no change older than eligibleCN (case of s3/cn31)
result.update(new ChangeNumber(0, 0, serverId));
} finally {
- if (ri != null) {
- ri.releaseCursor();
- }
+ close(ri);
}
} else {
// for this serverId, all changes in the ChangelogDb are holder
--
Gitblit v1.10.0