From 3d164449a8e00bfd0472a6ac08764259a7be6cb3 Mon Sep 17 00:00:00 2001
From: Jean-Noel Rouvignac <jean-noel.rouvignac@forgerock.com>
Date: Mon, 07 Oct 2013 15:25:44 +0000
Subject: [PATCH] Fix after r9673.
---
opendj-sdk/opends/src/server/org/opends/server/replication/server/ECLServerHandler.java | 8 ++++----
1 files changed, 4 insertions(+), 4 deletions(-)
diff --git a/opendj-sdk/opends/src/server/org/opends/server/replication/server/ECLServerHandler.java b/opendj-sdk/opends/src/server/org/opends/server/replication/server/ECLServerHandler.java
index cd9d4a1..0e52d9a 100644
--- a/opendj-sdk/opends/src/server/org/opends/server/replication/server/ECLServerHandler.java
+++ b/opendj-sdk/opends/src/server/org/opends/server/replication/server/ECLServerHandler.java
@@ -116,7 +116,7 @@
/**
* The global list of contexts by domain for the search currently processed.
*/
- private DomainContext[] domainCtxts = new DomainContext[0];
+ private Set<DomainContext> domainCtxts = Collections.emptySet();
/**
* Provides a string representation of this object.
@@ -276,7 +276,7 @@
{ // in non blocking mode, null means no more messages
return null;
}
- else if (newMsg.getCSN().getTime() < domainLatestTrimDate)
+ else if (newMsg.getCSN().getTime() >= domainLatestTrimDate)
{
// when the replication changelog is trimmed, the last (latest) chg
// is left in the db (whatever its age), and we don't want this chg
@@ -699,7 +699,7 @@
{
// Creates the table that will contain the real-time info for each
// and every domain.
- Set<DomainContext> tmpSet = new HashSet<DomainContext>();
+ final Set<DomainContext> tmpSet = new HashSet<DomainContext>();
final StringBuilder missingDomains = new StringBuilder();
for (ReplicationServerDomain rsd : toIterable(rs.getDomainIterator()))
{
@@ -803,7 +803,7 @@
"<" + providedCookie + missingDomains + ">"));
}
- domainCtxts = tmpSet.toArray(new DomainContext[tmpSet.size()]);
+ domainCtxts = tmpSet;
/*
When it is valid to have the provided cookie containing unknown domains
--
Gitblit v1.10.0