From 9569dcea7f21d0ecf76da6b73636df74f501ca15 Mon Sep 17 00:00:00 2001
From: mrossign <mrossign@localhost>
Date: Thu, 15 Jan 2009 13:45:52 +0000
Subject: [PATCH] - Added assured replication monitoring in replication server - Assured replication monitoring attributes in directory server have consistent names - Some existing monitoring attributes renamed in replication server to be consistent with directory server existing ones
---
opends/src/server/org/opends/server/replication/server/ExpectedAcksInfo.java | 22 +++++++++++++++++++++-
1 files changed, 21 insertions(+), 1 deletions(-)
diff --git a/opends/src/server/org/opends/server/replication/server/ExpectedAcksInfo.java b/opends/src/server/org/opends/server/replication/server/ExpectedAcksInfo.java
index f81adda..1ab0d36 100644
--- a/opends/src/server/org/opends/server/replication/server/ExpectedAcksInfo.java
+++ b/opends/src/server/org/opends/server/replication/server/ExpectedAcksInfo.java
@@ -22,7 +22,7 @@
* CDDL HEADER END
*
*
- * Copyright 2008 Sun Microsystems, Inc.
+ * Copyright 2008-2009 Sun Microsystems, Inc.
*/
package org.opends.server.replication.server;
@@ -79,6 +79,17 @@
new HashMap<Short,Boolean>();
/**
+ * Facility for monitoring:
+ * If the timeout occurs for the original update, we call createAck(true)
+ * in the timeout code for sending back an error ack to the original server.
+ * We use this call to also save the list of server ids for server we did not
+ * have time to receive an ack from. For updating its counters, the timeout
+ * code can then call getTimeoutServers() method to now which servers did not
+ * respond in time.
+ */
+ protected List<Short> serversInTimeout = null;
+
+ /**
* Creates a new ExpectedAcksInfo.
* @param changeNumber The change number of the assured update message
* @param requesterServerHandler The server handler of the server that sent
@@ -112,6 +123,15 @@
}
/**
+ * Gets the list of expected servers that did not respond in time.
+ * @return The list of expected servers that did not respond in time.
+ */
+ public List<Short> getTimeoutServers()
+ {
+ return serversInTimeout;
+ }
+
+ /**
* Gets the requested assured mode for the matching update message.
* @return The requested assured mode for the matching update message.
*/
--
Gitblit v1.10.0