Apache
/
activemq-artemis
mirror of https://github.com/apache/activemq-artemis.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

ARTEMIS-4925 Making assertion to also consider journal and other files from the broker 

Small change but say there's ever a leak on the journal. Removing the clause from paging would allow to also capture other leaks.

This is currently not an issue and the test should still pass.
This commit is contained in:
Clebert Suconic 2024-07-18 09:44:57 -04:00 committed by clebertsuconic
parent 79708749e8
commit da7dccae87
1 changed files with 2 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
tests/soak-tests/src/test/java/org/apache/activemq/artemis/tests/soak/brokerConnection/mirror/ReplicatedBothNodesMirrorTest.java
View File

@ -377,7 +377,7 @@ public class ReplicatedBothNodesMirrorTest extends SoakTestBase {
// lsof is showing a file descriptor associated with multiple threads. So it is expected to have quite a few repetitions
// when the issue is happening we would have around 40k, 50k entries or a lot more if you add more messages.
Assertions.assertTrue(openFiles < 2500, () -> "There was " + openFiles + " open files");
Assertions.assertTrue(openFiles < 4000, () -> "There was " + openFiles + " open files");
Assertions.assertEquals(0, errors.get(), "There are errors on the senders");
}
@ -393,7 +393,7 @@ public class ReplicatedBothNodesMirrorTest extends SoakTestBase {
BufferedReader reader = new BufferedReader(new InputStreamReader(inputStream));
AtomicInteger filesCounter = new AtomicInteger();
try (Stream<String> lines = reader.lines()) {
lines.filter(line -> line.contains("paging") && line.contains(basedir)).forEach(l -> {
lines.filter(line -> line.contains(basedir)).forEach(l -> {
logger.info("file {}", l);
filesCounter.incrementAndGet();
});