Fix OPENDJ-1190: Under rare circumstances the DS replication recovery threa...

Chris Ridd

19.57.2014 79f9a08fb746917e3a502a3effe89c0bef079f9c

 opends/src/server/org/opends/server/replication/plugin/LDAPReplicationDomain.java

@@ -4264,13 +4264,25 @@

      if (lastRetrievedChange != null)
      {
        if (debugEnabled())
          TRACER.debugInfo("publish loop"
                  + " >=" + currentStartCSN + " <=" + endCSN
                  + " nentries=" + op.getEntriesSent()
                  + " result=" + op.getResultCode()
                  + " lastRetrievedChange=" + lastRetrievedChange);
        currentStartCSN = lastRetrievedChange;
      }
      else
      {
        if (debugEnabled())
          TRACER.debugInfo("publish loop"
                  + " >=" + currentStartCSN + " <=" + endCSN
                  + " nentries=" + op.getEntriesSent()
                  + " result=" + op.getResultCode()
                  + " no changes");
        currentStartCSN = endCSN;
      }
    } while (pendingChanges.recoveryUntil(lastRetrievedChange)
    } while (pendingChanges.recoveryUntil(currentStartCSN)
          && op.getResultCode().equals(ResultCode.SUCCESS));

    return op.getResultCode().equals(ResultCode.SUCCESS);