From 3c140af6c756b30b325ce3c6ed080e8898e2b7ec Mon Sep 17 00:00:00 2001
From: Fabio Pistolesi <fabio.pistolesi@forgerock.com>
Date: Wed, 24 Feb 2016 13:52:15 +0000
Subject: [PATCH] OPENDJ-2190 Replicas cannot always keep up with sustained high write throughput
---
opendj-server-legacy/src/main/java/org/opends/server/replication/plugin/PendingChange.java | 37 ++-----------------------------------
1 files changed, 2 insertions(+), 35 deletions(-)
diff --git a/opendj-server-legacy/src/main/java/org/opends/server/replication/plugin/PendingChange.java b/opendj-server-legacy/src/main/java/org/opends/server/replication/plugin/PendingChange.java
index 9e7309f..2104731 100644
--- a/opendj-server-legacy/src/main/java/org/opends/server/replication/plugin/PendingChange.java
+++ b/opendj-server-legacy/src/main/java/org/opends/server/replication/plugin/PendingChange.java
@@ -22,12 +22,11 @@
*
*
* Copyright 2006-2008 Sun Microsystems, Inc.
- * Portions copyright 2014 ForgeRock AS
+ * Portions copyright 2014-2016 ForgeRock AS.
*/
package org.opends.server.replication.plugin;
import org.opends.server.replication.common.CSN;
-import org.opends.server.replication.common.ServerState;
import org.opends.server.replication.protocol.LDAPUpdateMsg;
import org.opends.server.replication.protocol.UpdateMsg;
import org.opends.server.types.operation.PluginOperation;
@@ -42,7 +41,6 @@
private boolean committed;
private UpdateMsg msg;
private final PluginOperation op;
- private ServerState dependencyState;
/**
* Construct a new PendingChange.
@@ -128,35 +126,6 @@
return this.op;
}
- /**
- * Add the given CSN to the list of dependencies of this PendingChange.
- *
- * @param csn
- * The CSN to add to the list of dependencies of this PendingChange.
- */
- public void addDependency(CSN csn)
- {
- if (dependencyState == null)
- {
- dependencyState = new ServerState();
- }
- dependencyState.update(csn);
- }
-
- /**
- * Check if the given ServerState covers the dependencies of this
- * PendingChange.
- *
- * @param state The ServerState for which dependencies must be checked,
- *
- * @return A boolean indicating if the given ServerState covers the
- * dependencies of this PendingChange.
- */
- public boolean dependenciesIsCovered(ServerState state)
- {
- return state.cover(dependencyState);
- }
-
/** {@inheritDoc} */
@Override
public int compareTo(PendingChange o)
@@ -173,8 +142,6 @@
+ ", csn=" + csn.toStringUI()
+ ", msg=[" + msg
+ "], isOperationSynchronized="
- + (op != null ? op.isSynchronizationOperation() : "false")
- + ", dependencyState="
- + (dependencyState != null ? dependencyState : "");
+ + (op != null ? op.isSynchronizationOperation() : "false");
}
}
--
Gitblit v1.10.0