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

ludovicp
31.06.2010 dfee862f2637845769ee7c9ed594985920c4c6aa
opends/src/server/org/opends/server/replication/plugin/LDAPReplicationDomain.java
@@ -405,6 +405,9 @@
  // The operation should become a no-op
  private static final int FRACTIONAL_BECOME_NO_OP = 3;
  // This configuration boolean indicates if this ReplicationDomain should log
  // ChangeNumbers.
  private boolean logChangeNumber = false;
  /**
   * The thread that periodically saves the ServerState of this
@@ -551,6 +554,7 @@
    heartbeatInterval = configuration.getHeartbeatInterval();
    isolationpolicy = configuration.getIsolationPolicy();
    configDn = configuration.dn();
    logChangeNumber = configuration.isLogChangenumber();
    this.updateToReplayQueue = updateToReplayQueue;
    // Get assured configuration
@@ -2297,6 +2301,12 @@
    // Note that a failed non-replication operation might not have a change
    // number.
    ChangeNumber curChangeNumber = OperationContext.getChangeNumber(op);
    if ((curChangeNumber != null) && (logChangeNumber))
    {
      Message message =
        Message.raw("replicationCN:%s", curChangeNumber.toString());
      op.appendAdditionalLogMessage(message);
    }
    if ((result == ResultCode.SUCCESS) && (!op.isSynchronizationOperation()))
    {
@@ -4234,6 +4244,7 @@
         ReplicationDomainCfg configuration)
  {
    isolationpolicy = configuration.getIsolationPolicy();
    logChangeNumber = configuration.isLogChangenumber();
    changeConfig(
        configuration.getReplicationServer(),