From 995d54a8963d87335196b86d8d4fc1b252a38ee4 Mon Sep 17 00:00:00 2001
From: Valery Kharseko <vharseko@3a-systems.ru>
Date: Mon, 07 Sep 2026 08:58:19 +0000
Subject: [PATCH] [#900] Time the ReplicaOfflineMsg grace period per replica, and spend it where the message can still be forwarded (#919)
---
opendj-server-legacy/src/main/java/org/opends/server/replication/plugin/PendingChanges.java | 6 +++++-
1 files changed, 5 insertions(+), 1 deletions(-)
diff --git a/opendj-server-legacy/src/main/java/org/opends/server/replication/plugin/PendingChanges.java b/opendj-server-legacy/src/main/java/org/opends/server/replication/plugin/PendingChanges.java
index 5d2f6fd..8ebba8c 100644
--- a/opendj-server-legacy/src/main/java/org/opends/server/replication/plugin/PendingChanges.java
+++ b/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;
}
/**
--
Gitblit v1.10.0