From 88aa12cc1a065f3a82bcc967b9f457639d155c2f Mon Sep 17 00:00:00 2001 From: Xiaoqin Fu <48848615+xiaoqin-fu@users.noreply.github.com> Date: Fri, 30 Aug 2019 01:37:30 -0700 Subject: [PATCH] Remove extra checks to fix #9456 (#9523) Motivation: There are some extra log level checks (logger.isWarnEnabled()). Modification: Remove log level checks (logger.isWarnEnabled()) from io.netty.channel.epoll.AbstractEpollStreamChannel, io.netty.channel.DefaultFileRegion, io.netty.channel.nio.AbstractNioChannel, io.netty.util.HashedWheelTimer, io.netty.handler.stream.ChunkedWriteHandler and io.netty.channel.udt.nio.NioUdtMessageConnectorChannel Result: Fixes #9456 --- common/src/main/java/io/netty/util/HashedWheelTimer.java | 4 +--- .../java/io/netty/handler/stream/ChunkedWriteHandler.java | 4 +--- .../io/netty/channel/epoll/AbstractEpollStreamChannel.java | 4 +--- .../src/main/java/io/netty/channel/DefaultFileRegion.java | 4 +--- .../main/java/io/netty/channel/nio/AbstractNioChannel.java | 4 +--- 5 files changed, 5 insertions(+), 15 deletions(-) diff --git a/common/src/main/java/io/netty/util/HashedWheelTimer.java b/common/src/main/java/io/netty/util/HashedWheelTimer.java index 14ce2cac49..4b2f5459d4 100644 --- a/common/src/main/java/io/netty/util/HashedWheelTimer.java +++ b/common/src/main/java/io/netty/util/HashedWheelTimer.java @@ -266,10 +266,8 @@ public class HashedWheelTimer implements Timer { } if (duration < MILLISECOND_NANOS) { - if (logger.isWarnEnabled()) { - logger.warn("Configured tickDuration {} smaller then {}, using 1ms.", + logger.warn("Configured tickDuration {} smaller then {}, using 1ms.", tickDuration, MILLISECOND_NANOS); - } this.tickDuration = MILLISECOND_NANOS; } else { this.tickDuration = duration; diff --git a/handler/src/main/java/io/netty/handler/stream/ChunkedWriteHandler.java b/handler/src/main/java/io/netty/handler/stream/ChunkedWriteHandler.java index fb155d107c..675b316911 100644 --- a/handler/src/main/java/io/netty/handler/stream/ChunkedWriteHandler.java +++ b/handler/src/main/java/io/netty/handler/stream/ChunkedWriteHandler.java @@ -111,9 +111,7 @@ public class ChunkedWriteHandler implements ChannelHandler { try { doFlush(ctx); } catch (Exception e) { - if (logger.isWarnEnabled()) { - logger.warn("Unexpected exception while sending chunks.", e); - } + logger.warn("Unexpected exception while sending chunks.", e); } } diff --git a/transport-native-epoll/src/main/java/io/netty/channel/epoll/AbstractEpollStreamChannel.java b/transport-native-epoll/src/main/java/io/netty/channel/epoll/AbstractEpollStreamChannel.java index 11a7e9323f..f86f5c49f0 100644 --- a/transport-native-epoll/src/main/java/io/netty/channel/epoll/AbstractEpollStreamChannel.java +++ b/transport-native-epoll/src/main/java/io/netty/channel/epoll/AbstractEpollStreamChannel.java @@ -669,9 +669,7 @@ public abstract class AbstractEpollStreamChannel extends AbstractEpollChannel im try { fd.close(); } catch (IOException e) { - if (logger.isWarnEnabled()) { - logger.warn("Error while closing a pipe", e); - } + logger.warn("Error while closing a pipe", e); } } } diff --git a/transport/src/main/java/io/netty/channel/DefaultFileRegion.java b/transport/src/main/java/io/netty/channel/DefaultFileRegion.java index a072196a8a..08ac5f5c96 100644 --- a/transport/src/main/java/io/netty/channel/DefaultFileRegion.java +++ b/transport/src/main/java/io/netty/channel/DefaultFileRegion.java @@ -158,9 +158,7 @@ public class DefaultFileRegion extends AbstractReferenceCounted implements FileR try { file.close(); } catch (IOException e) { - if (logger.isWarnEnabled()) { - logger.warn("Failed to close a file.", e); - } + logger.warn("Failed to close a file.", e); } } diff --git a/transport/src/main/java/io/netty/channel/nio/AbstractNioChannel.java b/transport/src/main/java/io/netty/channel/nio/AbstractNioChannel.java index 263390f66e..3e1e5fe783 100644 --- a/transport/src/main/java/io/netty/channel/nio/AbstractNioChannel.java +++ b/transport/src/main/java/io/netty/channel/nio/AbstractNioChannel.java @@ -80,10 +80,8 @@ public abstract class AbstractNioChannel extends AbstractChannel { try { ch.close(); } catch (IOException e2) { - if (logger.isWarnEnabled()) { - logger.warn( + logger.warn( "Failed to close a partially initialized socket.", e2); - } } throw new ChannelException("Failed to enter non-blocking mode.", e);