Fix for issue 2805 : purge delay parameter not taken into account online.

gbellato

15.55.2008 b41f8df6ea90f377c125d918c85bea922bc654a7

 opends/src/server/org/opends/server/replication/server/ReplicationServer.java

@@ -119,8 +119,11 @@
  private int rcvWindow;
  private int queueSize;
  private String dbDirname = null;
  private long trimAge; // the time (in sec) after which the  changes must
                        // be deleted from the persistent storage.

  // The delay (in sec) after which the  changes must
  // be deleted from the persistent storage.
  private long purgeDelay;

  private int replicationPort;
  private boolean stopListen = false;
  private ReplSessionSecurity replSessionSecurity;
@@ -158,7 +161,7 @@
    if (replicationServers == null)
      replicationServers = new ArrayList<String>();
    queueSize = configuration.getQueueSize();
    trimAge = configuration.getReplicationPurgeDelay();
    purgeDelay = configuration.getReplicationPurgeDelay();
    dbDirname = configuration.getReplicationDBDirectory();
    rcvWindow = configuration.getWindowSize();
    if (dbDirname == null)
@@ -582,7 +585,7 @@
   */
  long getTrimage()
  {
    return trimAge * 1000;
    return purgeDelay * 1000;
  }

  /**
@@ -628,7 +631,17 @@
    if (replicationServers == null)
      replicationServers = new ArrayList<String>();
    queueSize = configuration.getQueueSize();
    trimAge = configuration.getReplicationPurgeDelay();
    long newPurgeDelay = configuration.getReplicationPurgeDelay();
    if (newPurgeDelay != purgeDelay)
    {
      purgeDelay = newPurgeDelay;
      // propagate
      for (ReplicationServerDomain domain : baseDNs.values())
      {
        domain.setPurgeDelay(purgeDelay);
      }
    }

    rcvWindow = configuration.getWindowSize();

    // changing the listen port requires to stop the listen thread