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/plugin/PendingChanges.java | 18 ++----------------
1 files changed, 2 insertions(+), 16 deletions(-)
diff --git a/opendj-sdk/opends/src/server/org/opends/server/replication/plugin/PendingChanges.java b/opendj-sdk/opends/src/server/org/opends/server/replication/plugin/PendingChanges.java
index a284aae..b9b512f 100644
--- a/opendj-sdk/opends/src/server/org/opends/server/replication/plugin/PendingChanges.java
+++ b/opendj-sdk/opends/src/server/org/opends/server/replication/plugin/PendingChanges.java
@@ -26,15 +26,11 @@
*/
package org.opends.server.replication.plugin;
-import static org.opends.messages.ReplicationMessages.*;
-import static org.opends.server.loggers.ErrorLogger.logError;
import java.util.NoSuchElementException;
import java.util.SortedMap;
import java.util.TreeMap;
-import java.util.concurrent.TimeoutException;
-import org.opends.messages.Message;
import org.opends.server.replication.service.ReplicationDomain;
import org.opends.server.replication.common.ChangeNumber;
import org.opends.server.replication.common.ChangeNumberGenerator;
@@ -183,18 +179,8 @@
{
numSentUpdates++;
LDAPUpdateMsg updateMsg = firstChange.getMsg();
- try
- {
- domain.publish(updateMsg);
- } catch (TimeoutException ex) {
- // This exception may only be raised if assured replication is
- // enabled
- Message errorMsg = ERR_DS_ACK_TIMEOUT.get(
- domain.getServiceID(), Long.toString(domain.getAssuredTimeout()),
- updateMsg.toString());
- logError(errorMsg);
- }
- }
+ domain.publish(updateMsg);
+ }
pendingChanges.remove(firstChangeNumber);
if (pendingChanges.isEmpty())
--
Gitblit v1.10.0