mirror of https://github.com/OpenIdentityPlatform/OpenDJ.git

ludovicp
18.20.2010 74054e68eca6d18292e70ac91635be3e8f6bcbae
Fix an issue during replication initialization when servers have different processing speed.
1 files modified
16 ■■■■ changed files
opends/src/server/org/opends/server/replication/service/ReplicationDomain.java 16 ●●●● patch | view | raw | blame | history
opends/src/server/org/opends/server/replication/service/ReplicationDomain.java
@@ -1445,10 +1445,9 @@
    // - 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());
    else
      ieContext.startList.add(serverToInitialize);
    // We manage the list of servers with which a flow control can be enabled
    for (DSInfo dsi : getReplicasList())
@@ -1456,6 +1455,19 @@
      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.getDsId() == serverToInitialize)
         if (dsi.getProtocolVersion()>= ProtocolVersion.REPLICATION_PROTOCOL_V4)
          ieContext.setAckVal(dsi.getDsId(), 0);
      }
    }
    // loop for the case where the exporter is the initiator
    int attempt = 0;