Log the cause of exceptionCaught event when failed to notify
This commit is contained in:
parent
3b562c917d
commit
3393629eed
@ -577,12 +577,19 @@ final class DefaultChannelHandlerContext extends DefaultAttributeMap implements
|
||||
}
|
||||
}
|
||||
} else {
|
||||
executor.execute(new Runnable() {
|
||||
@Override
|
||||
public void run() {
|
||||
fireExceptionCaught(cause);
|
||||
try {
|
||||
executor.execute(new Runnable() {
|
||||
@Override
|
||||
public void run() {
|
||||
fireExceptionCaught(cause);
|
||||
}
|
||||
});
|
||||
} catch (Throwable t) {
|
||||
if (logger.isWarnEnabled()) {
|
||||
logger.warn("Failed to submit an exceptionCaught() event.", t);
|
||||
logger.warn("The exceptionCaught() event that was failed to submit was:", cause);
|
||||
}
|
||||
});
|
||||
}
|
||||
}
|
||||
} else {
|
||||
logger.warn(
|
||||
|
@ -201,7 +201,7 @@ public abstract class MultithreadEventExecutor implements EventExecutor {
|
||||
|
||||
@Override
|
||||
public boolean inEventLoop() {
|
||||
return SingleThreadEventExecutor.currentEventLoop() != null;
|
||||
throw new UnsupportedOperationException();
|
||||
}
|
||||
|
||||
@Override
|
||||
|
Loading…
Reference in New Issue
Block a user