From 21af6610b07617ecbf1b826310a2f244deb4d348 Mon Sep 17 00:00:00 2001
From: Matthew Swift <matthew.swift@forgerock.com>
Date: Tue, 25 Mar 2014 15:02:51 +0000
Subject: [PATCH] Fix OPENDJ-1354 - replication threads BLOCKED in pendingChanges queue
---
opendj3-server-dev/src/server/org/opends/server/replication/protocol/MonitorMsg.java | 65 +++++++++++++++++++++-----------
1 files changed, 43 insertions(+), 22 deletions(-)
diff --git a/opendj3-server-dev/src/server/org/opends/server/replication/protocol/MonitorMsg.java b/opendj3-server-dev/src/server/org/opends/server/replication/protocol/MonitorMsg.java
index 6d9863f..2e6e101 100644
--- a/opendj3-server-dev/src/server/org/opends/server/replication/protocol/MonitorMsg.java
+++ b/opendj3-server-dev/src/server/org/opends/server/replication/protocol/MonitorMsg.java
@@ -50,12 +50,24 @@
* When RS2 receives a MonitorRequestMessage from RS1, RS2 responds with a
* MonitorMsg.
*/
-public class MonitorMsg extends RoutableMsg
+public class MonitorMsg extends ReplicationMsg
{
/**
- * Data structure to manage the state and the approximation
- * of the data of the first missing change for each LDAP server
- * connected to a Replication Server.
+ * The destination server or servers of this message.
+ */
+ private final int destination;
+
+ /**
+ * The serverID of the server that sends this message.
+ */
+ private final int senderID;
+
+
+
+ /**
+ * Data structure to manage the state and the approximation of the data of the
+ * first missing change for each LDAP server connected to a Replication
+ * Server.
*/
static class ServerData
{
@@ -89,24 +101,7 @@
*/
public MonitorMsg(int sender, int destination)
{
- super(sender, destination);
- }
-
- /**
- * Sets the sender ID.
- * @param senderID The sender ID.
- */
- public void setSenderID(int senderID)
- {
- this.senderID = senderID;
- }
-
- /**
- * Sets the destination.
- * @param destination The destination.
- */
- public void setDestination(int destination)
- {
+ this.senderID = sender;
this.destination = destination;
}
@@ -459,6 +454,32 @@
return data.rsStates.keySet().iterator();
}
+
+
+ /**
+ * Get the destination.
+ *
+ * @return the destination
+ */
+ public int getDestination()
+ {
+ return destination;
+ }
+
+
+
+ /**
+ * Get the server ID of the server that sent this message.
+ *
+ * @return the server id
+ */
+ public int getSenderID()
+ {
+ return senderID;
+ }
+
+
+
/**
* {@inheritDoc}
*/
--
Gitblit v1.10.0