From 858671987c8e828f338ee7ef8a22480f6ab4e877 Mon Sep 17 00:00:00 2001
From: Nicolas Capponi <nicolas.capponi@forgerock.com>
Date: Fri, 28 Nov 2014 14:11:01 +0000
Subject: [PATCH] OPENDJ-1611 CR-5492 Filter replicaIds when filling late queue in MessageHandler
---
opendj-sdk/opends/src/server/org/opends/server/replication/server/ServerHandler.java | 7 +++++--
1 files changed, 5 insertions(+), 2 deletions(-)
diff --git a/opendj-sdk/opends/src/server/org/opends/server/replication/server/ServerHandler.java b/opendj-sdk/opends/src/server/org/opends/server/replication/server/ServerHandler.java
index 58009ad..5e38204 100644
--- a/opendj-sdk/opends/src/server/org/opends/server/replication/server/ServerHandler.java
+++ b/opendj-sdk/opends/src/server/org/opends/server/replication/server/ServerHandler.java
@@ -29,6 +29,7 @@
import java.io.IOException;
import java.util.List;
import java.util.Random;
+import java.util.Set;
import java.util.concurrent.Semaphore;
import java.util.concurrent.TimeUnit;
import java.util.concurrent.atomic.AtomicInteger;
@@ -960,13 +961,15 @@
* Select the next update that must be sent to the server managed by this
* ServerHandler.
*
+ * @param connectedReplicaIds
+ * Ids of replicas to accept when returning a message.
* @return the next update that must be sent to the server managed by this
* ServerHandler.
*/
- public UpdateMsg take()
+ public UpdateMsg take(Set<Integer> connectedReplicaIds)
{
boolean interrupted = true;
- UpdateMsg msg = getNextMessage(true); // synchronous:block until msg
+ UpdateMsg msg = getNextMessage(connectedReplicaIds, true); // synchronous:block until msg
boolean acquired = false;
do
--
Gitblit v1.10.0