This is an automated email from the ASF dual-hosted git repository.
clebertsuconic pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/activemq-artemis.git
The following commit(s) were added to refs/heads/main by this push:
new 40e29c7649 ARTEMIS-5387 Adjust values on HorizontalPagingTest
40e29c7649 is described below
commit 40e29c76491a6fc9b4f772411527b7ac6b391c73
Author: Clebert Suconic <[email protected]>
AuthorDate: Tue Apr 15 16:51:43 2025 -0400
ARTEMIS-5387 Adjust values on HorizontalPagingTest
There's also an issue with the CountDownLatch updated in the wrong
place.
This test was sometimes failing with OME on the client due to the number
of messages received for each thread.
---
.../apache/activemq/artemis/utils/RealServerTestBase.java | 6 +++++-
.../artemis/tests/soak/paging/HorizontalPagingTest.java | 4 ++--
tests/soak-tests/src/test/scripts/longrun-parameters.sh | 12 ++++++------
tests/soak-tests/src/test/scripts/parameters.sh | 12 ++++++------
4 files changed, 19 insertions(+), 15 deletions(-)
diff --git
a/tests/artemis-test-support/src/main/java/org/apache/activemq/artemis/utils/RealServerTestBase.java
b/tests/artemis-test-support/src/main/java/org/apache/activemq/artemis/utils/RealServerTestBase.java
index e8aea1aa99..f3fdbdf17e 100644
---
a/tests/artemis-test-support/src/main/java/org/apache/activemq/artemis/utils/RealServerTestBase.java
+++
b/tests/artemis-test-support/src/main/java/org/apache/activemq/artemis/utils/RealServerTestBase.java
@@ -88,9 +88,13 @@ public class RealServerTestBase extends ActiveMQTestBase {
}
public void killServer(Process process) {
+ killServer(process, false);
+ }
+
+ public void killServer(Process process, boolean forcibly) {
processes.remove(process);
try {
- ServerUtil.killServer(process);
+ ServerUtil.killServer(process, forcibly);
} catch (Throwable e) {
e.printStackTrace();
}
diff --git
a/tests/soak-tests/src/test/java/org/apache/activemq/artemis/tests/soak/paging/HorizontalPagingTest.java
b/tests/soak-tests/src/test/java/org/apache/activemq/artemis/tests/soak/paging/HorizontalPagingTest.java
index 1e4081fc87..bd09d9b59e 100644
---
a/tests/soak-tests/src/test/java/org/apache/activemq/artemis/tests/soak/paging/HorizontalPagingTest.java
+++
b/tests/soak-tests/src/test/java/org/apache/activemq/artemis/tests/soak/paging/HorizontalPagingTest.java
@@ -176,14 +176,13 @@ public class HorizontalPagingTest extends SoakTestBase {
assertTrue(latchDone.await(TIMEOUT_MINUTES, TimeUnit.MINUTES));
- killServer(serverProcess);
+ killServer(serverProcess, true);
serverProcess = startServer(SERVER_NAME_0, 0, SERVER_START_TIMEOUT);
AtomicInteger completedFine = new AtomicInteger(0);
for (String protocol : protocolList) {
- latchDone.countUp();
String protocolUsed = protocol;
ConnectionFactory factory = CFUtil.createConnectionFactory(protocol,
"tcp://localhost:61616");
@@ -191,6 +190,7 @@ public class HorizontalPagingTest extends SoakTestBase {
runAfter(connectionConsumer::close);
for (int i = 0; i < DESTINATIONS; i++) {
+ latchDone.countUp();
int destination = i;
service.execute(() -> {
try {
diff --git a/tests/soak-tests/src/test/scripts/longrun-parameters.sh
b/tests/soak-tests/src/test/scripts/longrun-parameters.sh
index c8b9aea785..14d3d2154d 100755
--- a/tests/soak-tests/src/test/scripts/longrun-parameters.sh
+++ b/tests/soak-tests/src/test/scripts/longrun-parameters.sh
@@ -30,12 +30,12 @@ export TEST_HORIZONTAL_SERVER_START_TIMEOUT=300000
export TEST_HORIZONTAL_TIMEOUT_MINUTES=120
export TEST_HORIZONTAL_PROTOCOL_LIST=OPENWIRE,CORE,AMQP
-export TEST_HORIZONTAL_DESTINATIONS=20
-export TEST_HORIZONTAL_MESSAGES=5000
-export TEST_HORIZONTAL_COMMIT_INTERVAL=1000
-export TEST_HORIZONTAL_RECEIVE_COMMIT_INTERVAL=0
-export TEST_HORIZONTAL_MESSAGE_SIZE=20000
-export TEST_HORIZONTAL_PARALLEL_SENDS=20
+export TEST_HORIZONTAL_DESTINATIONS=5
+export TEST_HORIZONTAL_MESSAGES=1000
+export TEST_HORIZONTAL_COMMIT_INTERVAL=100
+export TEST_HORIZONTAL_RECEIVE_COMMIT_INTERVAL=100
+export TEST_HORIZONTAL_MESSAGE_SIZE=10000
+export TEST_HORIZONTAL_PARALLEL_SENDS=5
export TEST_FLOW_SERVER_START_TIMEOUT=300000
export TEST_FLOW_TIMEOUT_MINUTES=120
diff --git a/tests/soak-tests/src/test/scripts/parameters.sh
b/tests/soak-tests/src/test/scripts/parameters.sh
index bc1a6afa8c..57a8be7d9a 100755
--- a/tests/soak-tests/src/test/scripts/parameters.sh
+++ b/tests/soak-tests/src/test/scripts/parameters.sh
@@ -29,12 +29,12 @@ export TEST_HORIZONTAL_SERVER_START_TIMEOUT=300000
export TEST_HORIZONTAL_TIMEOUT_MINUTES=120
export TEST_HORIZONTAL_PROTOCOL_LIST=OPENWIRE,CORE,AMQP
-export TEST_HORIZONTAL_DESTINATIONS=20
-export TEST_HORIZONTAL_MESSAGES=5000
-export TEST_HORIZONTAL_COMMIT_INTERVAL=1000
-export TEST_HORIZONTAL_RECEIVE_COMMIT_INTERVAL=0
-export TEST_HORIZONTAL_MESSAGE_SIZE=20000
-export TEST_HORIZONTAL_PARALLEL_SENDS=20
+export TEST_HORIZONTAL_DESTINATIONS=5
+export TEST_HORIZONTAL_MESSAGES=1000
+export TEST_HORIZONTAL_COMMIT_INTERVAL=100
+export TEST_HORIZONTAL_RECEIVE_COMMIT_INTERVAL=100
+export TEST_HORIZONTAL_MESSAGE_SIZE=10000
+export TEST_HORIZONTAL_PARALLEL_SENDS=5
export TEST_FLOW_SERVER_START_TIMEOUT=300000
export TEST_FLOW_TIMEOUT_MINUTES=120
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
For further information, visit: https://activemq.apache.org/contact
