mirror of https://github.com/OpenIdentityPlatform/OpenDJ.git
blame | history | patch | commit | commitdiff | ignore whitespace
Jean-Noel Rouvignac
05.51.2013 69ebea4017b17653a1b966b7a83372eb9ce0dcdc 
 opends/src/server/org/opends/server/replication/server/ReplicationServerDomain.java


@@ -2595,10 +2595,10 @@


    CSN eligibleCSN = null;




    final ServerState newestCSNs = domainDB.getDomainNewestCSNs(baseDN);


    for (final CSN changelogNewestCSN : newestCSNs)


    for (final CSN replicaNewestCSN : newestCSNs)


    {


      // Should it be considered for eligibility ?


      int serverId = changelogNewestCSN.getServerId();


      int serverId = replicaNewestCSN.getServerId();


      CSN heartbeatLastCSN = getChangeTimeHeartbeatState().getCSN(serverId);




      // If the most recent UpdateMsg or CLHeartbeatMsg received is very old


@@ -2625,11 +2625,11 @@


        continue;


      }




      if (changelogNewestCSN != null


      if (replicaNewestCSN != null


          && (eligibleCSN == null ||


              changelogNewestCSN.isNewerThan(eligibleCSN)))


              replicaNewestCSN.isNewerThan(eligibleCSN)))


      {


        eligibleCSN = changelogNewestCSN;


        eligibleCSN = replicaNewestCSN;


      }


      if (heartbeatLastCSN != null


          && (eligibleCSN == null || heartbeatLastCSN.isNewerThan(eligibleCSN)))