You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@lucene.apache.org by so...@apache.org on 2026/04/07 16:38:36 UTC
(lucene) 01/02: Synchronize TestInfoStream message capture to avoid losing messages
This is an automated email from the ASF dual-hosted git repository.
sokolov pushed a commit to branch branch_10x
in repository https://gitbox.apache.org/repos/asf/lucene.git
commit 816f3a0ce4dc968ba1073bd0dad6e3eea04f013a
Author: Michael Sokolov <so...@amazon.com>
AuthorDate: Tue Apr 7 12:34:11 2026 -0400
Synchronize TestInfoStream message capture to avoid losing messages
---
lucene/core/src/test/org/apache/lucene/index/TestInfoStream.java | 7 ++++++-
1 file changed, 6 insertions(+), 1 deletion(-)
diff --git a/lucene/core/src/test/org/apache/lucene/index/TestInfoStream.java b/lucene/core/src/test/org/apache/lucene/index/TestInfoStream.java
index 27b426e416e..96e6be37533 100644
--- a/lucene/core/src/test/org/apache/lucene/index/TestInfoStream.java
+++ b/lucene/core/src/test/org/apache/lucene/index/TestInfoStream.java
@@ -102,7 +102,7 @@ public class TestInfoStream extends LuceneTestCase {
public void close() throws IOException {}
@Override
- public void message(String component, String message) {
+ public synchronized void message(String component, String message) {
if (components.contains(component)) {
infoStream.add(String.format(Locale.ROOT, "[%s] %s\n", component, message));
}
@@ -148,6 +148,11 @@ public class TestInfoStream extends LuceneTestCase {
}
assertTrue("init message not found", foundInit);
assertEquals(2, flushedCount);
+ if (mergedCount == 0) {
+ for (String message: infoStream) {
+ System.out.print(message);
+ }
+ }
assertEquals(1, mergedCount);
}
}