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

pgamba
02.08.2007 4cee71bfa980931c4c74f29f8cea8e53b3b96480
opendj-sdk/opends/src/server/org/opends/server/replication/plugin/ReplicationDomain.java
@@ -179,7 +179,9 @@
  private int maxSendQueue = 0;
  private int maxReceiveDelay = 0;
  private int maxSendDelay = 0;
  private long generationId = -1;
  private boolean generationIdSavedStatus = false;
  private long rejectedGenerationId = -1;
  private boolean requestedResetSinceLastStart = false;
@@ -1049,6 +1051,11 @@
          waitingAckMsgs.put(curChangeNumber, msg);
        }
      }
      if (generationIdSavedStatus != true)
      {
        this.saveGenerationId(generationId);
      }
    }
    else if (!op.isSynchronizationOperation())
    {
@@ -2344,15 +2351,23 @@
    op.run();
    ResultCode result = op.getResultCode();
    if ((result != ResultCode.SUCCESS) && (result != ResultCode.NO_SUCH_OBJECT))
    if (result != ResultCode.SUCCESS)
    {
      // The case where the backend is empty (NO_SUCH_OBJECT)
      // is not an error case.
      Message message = ERR_UPDATING_GENERATION_ID.get(
                          op.getResultCode().getResultCodeName() + " " +
                          op.getErrorMessage(),
                          baseDN.toString());
      logError(message);
      generationIdSavedStatus = false;
      if (result != ResultCode.NO_SUCH_OBJECT)
      {
        // The case where the backend is empty (NO_SUCH_OBJECT)
        // is not an error case.
        Message message = ERR_UPDATING_GENERATION_ID.get(
            op.getResultCode().getResultCodeName() + " " +
            op.getErrorMessage(),
            baseDN.toString());
        logError(message);
      }
    }
    else
    {
      generationIdSavedStatus = true;
    }
    return result;
  }
@@ -2463,6 +2478,7 @@
    }
    else
    {
      generationIdSavedStatus = true;
      if (debugEnabled())
        TRACER.debugInfo(
            "Generation ID successfully read from domain base DN=" + baseDN +