From 46fd9423ab622d7f9531aa1564846ec52fe09534 Mon Sep 17 00:00:00 2001
From: Ludovic Poitou <ludovic.poitou@forgerock.com>
Date: Wed, 24 Apr 2013 12:44:51 +0000
Subject: [PATCH] Replication Cleanup.
---
opends/src/server/org/opends/server/replication/server/ReplicationServerDomain.java | 24 +++++++++---------------
1 files changed, 9 insertions(+), 15 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 3505af8..88c9487 100644
--- a/opends/src/server/org/opends/server/replication/server/ReplicationServerDomain.java
+++ b/opends/src/server/org/opends/server/replication/server/ReplicationServerDomain.java
@@ -677,20 +677,14 @@
sourceHandler.sendAck(ack);
} else
{
- if (safeDataLevel != (byte) 0)
- {
- /**
- * level > 1 : We need further acks
- * The message will be posted in assured mode to eligible
- * servers. The embedded safe data level is not changed, and his
- * value will be used by a remote RS to determine if he must send
- * an ack (level > 1) or not (level = 1)
- */
- interestedInAcks = true;
- } else
- {
- // Should never happen
- }
+ /**
+ * level > 1 : We need further acks
+ * The message will be posted in assured mode to eligible
+ * servers. The embedded safe data level is not changed, and his
+ * value will be used by a remote RS to determine if he must send
+ * an ack (level > 1) or not (level = 1)
+ */
+ interestedInAcks = true;
}
} else
{ // A RS sent us the safe data message, for sure no further ack to wait
@@ -1752,7 +1746,7 @@
monitorData.getApproxFirstMissingDate(replicaId), true);
}
- // Add the informations about the Replication Servers
+ // Add the information about the Replication Servers
// currently in the topology.
it = monitorData.rsIterator();
while (it.hasNext())
--
Gitblit v1.10.0