From e7e79929a65dd0bbfc31615755acc1a096b07794 Mon Sep 17 00:00:00 2001
From: Valery Kharseko <vharseko@3a-systems.ru>
Date: Wed, 08 Jul 2026 16:14:52 +0000
Subject: [PATCH] Fix and enable the replication StressTest (#698)
---
opendj-server-legacy/src/test/java/org/opends/server/replication/StressTest.java | 10 +++++++++-
1 files changed, 9 insertions(+), 1 deletions(-)
diff --git a/opendj-server-legacy/src/test/java/org/opends/server/replication/StressTest.java b/opendj-server-legacy/src/test/java/org/opends/server/replication/StressTest.java
index a045aa5..f286297 100644
--- a/opendj-server-legacy/src/test/java/org/opends/server/replication/StressTest.java
+++ b/opendj-server-legacy/src/test/java/org/opends/server/replication/StressTest.java
@@ -13,6 +13,7 @@
*
* Copyright 2006-2010 Sun Microsystems, Inc.
* Portions Copyright 2013-2016 ForgeRock AS.
+ * Portions Copyright 2026 3A Systems, LLC
*/
package org.opends.server.replication;
@@ -38,6 +39,7 @@
import org.opends.server.protocols.internal.InternalClientConnection;
import org.opends.server.replication.protocol.AddMsg;
import org.opends.server.replication.protocol.ReplicationMsg;
+import org.opends.server.replication.protocol.UpdateMsg;
import org.opends.server.replication.service.ReplicationBroker;
import org.opends.server.types.Entry;
import org.opends.server.types.InitializationException;
@@ -62,7 +64,7 @@
/** Stress test from LDAP server to client using the ReplicationBroker API. */
- @Test(enabled=false, groups="slow")
+ @Test
public void fromServertoBroker() throws Exception
{
logger.error(LocalizableMessage.raw("Starting replication StressTest : fromServertoBroker"));
@@ -264,6 +266,12 @@
{
break;
}
+ if (msg instanceof UpdateMsg)
+ {
+ // Acknowledge the flow control window, otherwise the replication
+ // server stops sending after windowSize messages.
+ broker.updateWindowAfterReplay();
+ }
count ++;
}
} catch (Exception e)
--
Gitblit v1.10.0