From 74054e68eca6d18292e70ac91635be3e8f6bcbae Mon Sep 17 00:00:00 2001
From: ludovicp <ludovicp@localhost>
Date: Wed, 18 Aug 2010 13:20:53 +0000
Subject: [PATCH] Fix an issue during replication initialization when servers have different processing speed.
---
opends/src/server/org/opends/server/replication/service/ReplicationDomain.java | 22 +++++++++++++++++-----
1 files changed, 17 insertions(+), 5 deletions(-)
diff --git a/opends/src/server/org/opends/server/replication/service/ReplicationDomain.java b/opends/src/server/org/opends/server/replication/service/ReplicationDomain.java
index 0f08eca..d549cd7 100644
--- a/opends/src/server/org/opends/server/replication/service/ReplicationDomain.java
+++ b/opends/src/server/org/opends/server/replication/service/ReplicationDomain.java
@@ -1445,16 +1445,28 @@
// - to update the task with the server(s) where this test failed
if (serverToInitialize == RoutableMsg.ALL_SERVERS)
+ {
for (DSInfo dsi : getReplicasList())
ieContext.startList.add(dsi.getDsId());
+
+ // We manage the list of servers with which a flow control can be enabled
+ for (DSInfo dsi : getReplicasList())
+ {
+ if (dsi.getProtocolVersion()>= ProtocolVersion.REPLICATION_PROTOCOL_V4)
+ ieContext.setAckVal(dsi.getDsId(), 0);
+ }
+ }
else
+ {
ieContext.startList.add(serverToInitialize);
- // We manage the list of servers with which a flow control can be enabled
- for (DSInfo dsi : getReplicasList())
- {
- if (dsi.getProtocolVersion()>= ProtocolVersion.REPLICATION_PROTOCOL_V4)
- ieContext.setAckVal(dsi.getDsId(), 0);
+ // We manage the list of servers with which a flow control can be enabled
+ for (DSInfo dsi : getReplicasList())
+ {
+ if (dsi.getDsId() == serverToInitialize)
+ if (dsi.getProtocolVersion()>= ProtocolVersion.REPLICATION_PROTOCOL_V4)
+ ieContext.setAckVal(dsi.getDsId(), 0);
+ }
}
// loop for the case where the exporter is the initiator
--
Gitblit v1.10.0