From dc20037ee9959ab05d841422015d7e4358162cbb Mon Sep 17 00:00:00 2001
From: Valery Kharseko <vharseko@3a-systems.ru>
Date: Wed, 08 Jul 2026 16:16:40 +0000
Subject: [PATCH] Remove the unfixable testStateMachineFull and fix the dead replay pool (#700)
---
opendj-server-legacy/src/main/java/org/opends/server/replication/plugin/MultimasterReplication.java | 6 +++++-
1 files changed, 5 insertions(+), 1 deletions(-)
diff --git a/opendj-server-legacy/src/main/java/org/opends/server/replication/plugin/MultimasterReplication.java b/opendj-server-legacy/src/main/java/org/opends/server/replication/plugin/MultimasterReplication.java
index a692fa9..0e86580 100644
--- a/opendj-server-legacy/src/main/java/org/opends/server/replication/plugin/MultimasterReplication.java
+++ b/opendj-server-legacy/src/main/java/org/opends/server/replication/plugin/MultimasterReplication.java
@@ -13,6 +13,7 @@
*
* Copyright 2006-2010 Sun Microsystems, Inc.
* Portions Copyright 2011-2016 ForgeRock AS.
+ * Portions Copyright 2026 3A Systems, LLC
*/
package org.opends.server.replication.plugin;
@@ -293,7 +294,10 @@
private int getNumberOfReplayThreadsOrDefault(ReplicationSynchronizationProviderCfg cfg)
{
Integer value = cfg.getNumUpdateReplayThreads();
- return value == null ? Platform.computeNumberOfThreads(16, 2.0f) : value;
+ // A non-positive value would silently kill the replay thread pool: fall
+ // back to the default in that case (the configuration schema enforces a
+ // minimum of 1, so this can only come from a broken caller).
+ return value == null || value <= 0 ? Platform.computeNumberOfThreads(16, 2.0f) : value;
}
/** Create the threads that will wait for incoming update messages. */
--
Gitblit v1.10.0