[activemq-artemis] branch main updated: ARTEMIS-4074 Diagnostic involving FileRepository pushOpen not responding fast enough

[cl...@apache.org]

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 9056ac1cc7 ARTEMIS-4074 Diagnostic involving FileRepository pushOpen not responding fast enough
9056ac1cc7 is described below

commit 9056ac1cc7f03b2badaaadf0068d93ed744602aa
Author: Clebert Suconic <cl...@apache.org>
AuthorDate: Wed Oct 26 18:21:40 2022 -0400

    ARTEMIS-4074 Diagnostic involving FileRepository pushOpen not responding fast enough
---
 .../activemq/artemis/core/journal/impl/JournalFilesRepository.java    | 2 ++
 .../org/apache/activemq/artemis/journal/ActiveMQJournalBundle.java    | 4 ++++
 2 files changed, 6 insertions(+)

diff --git a/artemis-journal/src/main/java/org/apache/activemq/artemis/core/journal/impl/JournalFilesRepository.java b/artemis-journal/src/main/java/org/apache/activemq/artemis/core/journal/impl/JournalFilesRepository.java
index dae1fe143d..3767e87cab 100644
--- a/artemis-journal/src/main/java/org/apache/activemq/artemis/core/journal/impl/JournalFilesRepository.java
+++ b/artemis-journal/src/main/java/org/apache/activemq/artemis/core/journal/impl/JournalFilesRepository.java
@@ -41,6 +41,7 @@ import org.apache.activemq.artemis.core.io.SequentialFile;
 import org.apache.activemq.artemis.core.io.SequentialFileFactory;
 import org.apache.activemq.artemis.journal.ActiveMQJournalBundle;
 import org.apache.activemq.artemis.journal.ActiveMQJournalLogger;
+import org.apache.activemq.artemis.utils.ThreadDumpUtil;
 import org.slf4j.LoggerFactory;
 import java.lang.invoke.MethodHandles;
 import org.slf4j.Logger;
@@ -492,6 +493,7 @@ public class JournalFilesRepository {
 
       if (nextFile == null) {
          ActiveMQJournalLogger.LOGGER.cantOpenFileTimeout(journalFileOpenTimeout);
+         logger.warn(ThreadDumpUtil.threadDump(ActiveMQJournalBundle.BUNDLE.threadDumpAfterFileOpenTimeout()));
          try {
             nextFile = takeFile(true, true, true, false);
          } catch (Exception e) {
diff --git a/artemis-journal/src/main/java/org/apache/activemq/artemis/journal/ActiveMQJournalBundle.java b/artemis-journal/src/main/java/org/apache/activemq/artemis/journal/ActiveMQJournalBundle.java
index eb8a8abcf2..92ac8415b9 100644
--- a/artemis-journal/src/main/java/org/apache/activemq/artemis/journal/ActiveMQJournalBundle.java
+++ b/artemis-journal/src/main/java/org/apache/activemq/artemis/journal/ActiveMQJournalBundle.java
@@ -49,4 +49,8 @@ public interface ActiveMQJournalBundle {
 
    @Message(id = 149006, value = "The file system returned a file {} with unexpected file size. The broker requested a file sized as {} but the system returned a file sized as {}")
    ActiveMQIOErrorException unexpectedFileSize(String fileName, long expectedSize, long returnedSize);
+
+   @Message(id = 149007, value = "Thread dump being generated as the asynchronous file.open is not responding fast enough.")
+   String threadDumpAfterFileOpenTimeout();
+
 }