Handle publication errors properly

jboss-logging · Mar 18, 2022 · bc6c0ab · bc6c0ab
1 parent 37a697c
commit bc6c0ab
Showing 1 changed file with 25 additions and 1 deletion.
diff --git a/core/src/main/java/org/jboss/logmanager/LoggerNode.java b/core/src/main/java/org/jboss/logmanager/LoggerNode.java
@@ -24,13 +24,17 @@
 import org.wildfly.common.ref.Reaper;
 import org.wildfly.common.ref.Reference;
 
+import java.lang.reflect.UndeclaredThrowableException;
+import java.security.AccessController;
+import java.security.PrivilegedAction;
 import java.util.Collection;
 import java.util.Enumeration;
 import java.util.Iterator;
 import java.util.Set;
 import java.util.concurrent.ConcurrentHashMap;
 import java.util.concurrent.ConcurrentMap;
 import java.util.concurrent.atomic.AtomicReferenceFieldUpdater;
+import java.util.logging.ErrorManager;
 import java.util.logging.Filter;
 import java.util.logging.Handler;
 import java.util.logging.Level;
@@ -46,6 +50,7 @@ public void reap(Reference<Logger, LoggerNode> reference) {
             reference.getAttachment().activeLoggers.remove(reference);
         }
     };
+    private static final StackTraceElement[] EMPTY_STACK = new StackTraceElement[0];
 
     /**
      * The log context.
@@ -386,7 +391,26 @@ void publish(final ExtLogRecord record) {
         } catch (VirtualMachineError e) {
             throw e;
         } catch (Throwable t) {
-            // todo - error handler
+            ErrorManager errorManager = AccessController.doPrivileged(new PrivilegedAction<ErrorManager>() {
+                @Override
+                public ErrorManager run() {
+                    return handler.getErrorManager();
+                }
+            });
+            if (errorManager != null) {
+                Exception e;
+                if (t instanceof Exception) {
+                    e = (Exception) t;
+                } else {
+                    e = new UndeclaredThrowableException(t);
+                    e.setStackTrace(EMPTY_STACK);
+                }
+                try {
+                    errorManager.error("Handler publication threw an exception", e, ErrorManager.WRITE_FAILURE);
+                } catch (Throwable t2) {
+                    StandardOutputStreams.printError(t2, "Handler.reportError caught an exception");
+                }
+            }
         }
         if (useParentHandlers) {
             final LoggerNode parent = this.parent;