From 2fc933d03d5961fa75fc4a8ffef75d3ec3b125d6 Mon Sep 17 00:00:00 2001
From: Matthew Swift <matthew.swift@forgerock.com>
Date: Fri, 04 Oct 2013 12:46:34 +0000
Subject: [PATCH] OPENDJ-1116 Introduce abstraction for the changelog DB
---
opends/src/server/org/opends/server/replication/server/ReplicationDomainMonitor.java | 7 +++----
1 files changed, 3 insertions(+), 4 deletions(-)
diff --git a/opends/src/server/org/opends/server/replication/server/ReplicationDomainMonitor.java b/opends/src/server/org/opends/server/replication/server/ReplicationDomainMonitor.java
index bd1ada6..b78bb90 100644
--- a/opends/src/server/org/opends/server/replication/server/ReplicationDomainMonitor.java
+++ b/opends/src/server/org/opends/server/replication/server/ReplicationDomainMonitor.java
@@ -279,7 +279,7 @@
// This directly connected LS has never produced any change
maxCSN = new CSN(0, 0, serverId);
}
- pendingMonitorData.setMaxCSN(serverId, maxCSN);
+ pendingMonitorData.setMaxCSN(maxCSN);
pendingMonitorData.setLDAPServerState(serverId, dsState);
pendingMonitorData.setFirstMissingDate(serverId,
ds.getApproxFirstMissingDate());
@@ -290,10 +290,9 @@
// - whatever they are directly or indirectly connected
final ServerState dbServerState = domain.getLatestServerState();
pendingMonitorData.setRSState(domain.getLocalRSServerId(), dbServerState);
- for (int serverId : dbServerState)
+ for (CSN storedCSN : dbServerState)
{
- CSN storedCSN = dbServerState.getCSN(serverId);
- pendingMonitorData.setMaxCSN(serverId, storedCSN);
+ pendingMonitorData.setMaxCSN(storedCSN);
}
}
--
Gitblit v1.10.0