[#900] Time the ReplicaOfflineMsg grace period per replica, and spend it wh...

Valery Kharseko

12 hours ago 995d54a8963d87335196b86d8d4fc1b252a38ee4

 opendj-server-legacy/src/main/java/org/opends/server/replication/plugin/PendingChanges.java

@@ -13,6 +13,7 @@
 *
 * Copyright 2009 Sun Microsystems, Inc.
 * Portions Copyright 2011-2015 ForgeRock AS.
 * Portions Copyright 2026 3A Systems, LLC.
 */
package org.opends.server.replication.plugin;

@@ -123,8 +124,10 @@

  /**
   * Add a replica offline message to the pending list.
   *
   * @return the CSN of the message which was added
   */
  public synchronized void putReplicaOfflineMsg()
  public synchronized CSN putReplicaOfflineMsg()
  {
    final CSN offlineCSN = csnGenerator.newCSN();
    final PendingChange pendingChange =
@@ -133,6 +136,7 @@

    pendingChanges.put(offlineCSN, pendingChange);
    pushCommittedChanges();
    return offlineCSN;
  }

  /**