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

Jean-Noel Rouvignac
16.57.2015 a41662c1136b2bb4a4198df89e0e87d2be3ef099
opendj-server-legacy/src/main/java/org/opends/server/replication/service/ReplicationDomain.java
@@ -2005,7 +2005,7 @@
    int count = 0;
    while (count<=length-2)
    {
      if ((entryBytes[pos+count] == '\n') && (entryBytes[pos+count+1] == '\n'))
      if (entryBytes[pos+count] == '\n' && entryBytes[pos+count+1] == '\n')
      {
        entryCount++;
        count++;
@@ -2070,7 +2070,7 @@
            " our=" + ourLastExportedCnt + " slowest=" + slowestCnt);
      }
      if ((ourLastExportedCnt - slowestCnt) > ieCtx.initWindow)
      if (ourLastExportedCnt - slowestCnt > ieCtx.initWindow)
      {
        if (logger.isTraceEnabled())
        {
@@ -3327,7 +3327,7 @@
          break;
        }
        // Timeout ?
        if ((System.currentTimeMillis() - startTime) >= getAssuredTimeout())
        if (System.currentTimeMillis() - startTime >= getAssuredTimeout())
        {
          /*
          Timeout occurred, be sure that ack is not being received and if so,