From 1cbdc977757ddaac9f678b5e8fab6013c9356e5d Mon Sep 17 00:00:00 2001
From: mrossign <mrossign@localhost>
Date: Thu, 18 Dec 2008 17:13:46 +0000
Subject: [PATCH] Assured Replication: - support for dynamic reconfiguration (domain and replication server) - performance improvement in domain (less lock time between sending threads) - performance improvement in server (safe data ack before DB push) - more monitoring info for safe read mode Misc: - support for dynamic domain group id reconfiguration

---
 opendj-sdk/opends/src/server/org/opends/server/replication/service/ReplicationBroker.java |    8 ++++++--
 1 files changed, 6 insertions(+), 2 deletions(-)

diff --git a/opendj-sdk/opends/src/server/org/opends/server/replication/service/ReplicationBroker.java b/opendj-sdk/opends/src/server/org/opends/server/replication/service/ReplicationBroker.java
index c0dff69..d70e1f2 100644
--- a/opendj-sdk/opends/src/server/org/opends/server/replication/service/ReplicationBroker.java
+++ b/opendj-sdk/opends/src/server/org/opends/server/replication/service/ReplicationBroker.java
@@ -1548,9 +1548,11 @@
    *
    * @return                    A boolean indicating if the changes
    *                            requires to restart the service.
+   * @param groupId            The new group id to use
    */
   public boolean changeConfig(
-      Collection<String> replicationServers, int window, long heartbeatInterval)
+      Collection<String> replicationServers, int window, long heartbeatInterval,
+      byte groupId)
   {
     // These parameters needs to be renegociated with the ReplicationServer
     // so if they have changed, that requires restarting the session with
@@ -1563,7 +1565,8 @@
         (!(replicationServers.size() == servers.size()
         && replicationServers.containsAll(servers))) ||
         window != this.maxRcvWindow  ||
-        heartbeatInterval != this.heartbeatInterval)
+        heartbeatInterval != this.heartbeatInterval ||
+        (groupId != this.groupId))
     {
       needToRestartSession = true;
     }
@@ -1573,6 +1576,7 @@
     this.maxRcvWindow = window;
     this.halfRcvWindow = window / 2;
     this.heartbeatInterval = heartbeatInterval;
+    this.groupId = groupId;
 
     return needToRestartSession;
   }

--
Gitblit v1.10.0