diff options
Diffstat (limited to 'jetty-websocket/websocket-common/src/main/java/org/eclipse/jetty/websocket/common/message/MessageInputStream.java')
-rw-r--r-- | jetty-websocket/websocket-common/src/main/java/org/eclipse/jetty/websocket/common/message/MessageInputStream.java | 12 |
1 files changed, 8 insertions, 4 deletions
diff --git a/jetty-websocket/websocket-common/src/main/java/org/eclipse/jetty/websocket/common/message/MessageInputStream.java b/jetty-websocket/websocket-common/src/main/java/org/eclipse/jetty/websocket/common/message/MessageInputStream.java index 710ae1fc57..944c931fc4 100644 --- a/jetty-websocket/websocket-common/src/main/java/org/eclipse/jetty/websocket/common/message/MessageInputStream.java +++ b/jetty-websocket/websocket-common/src/main/java/org/eclipse/jetty/websocket/common/message/MessageInputStream.java @@ -129,7 +129,8 @@ public class MessageInputStream extends InputStream implements MessageAppender @Override public void messageComplete() { - LOG.debug("Message completed"); + if (LOG.isDebugEnabled()) + LOG.debug("Message completed"); buffers.offer(EOF); } @@ -140,7 +141,8 @@ public class MessageInputStream extends InputStream implements MessageAppender { if (closed.get()) { - LOG.debug("Stream closed"); + if (LOG.isDebugEnabled()) + LOG.debug("Stream closed"); return -1; } @@ -166,7 +168,8 @@ public class MessageInputStream extends InputStream implements MessageAppender if (activeBuffer == EOF) { - LOG.debug("Reached EOF"); + if (LOG.isDebugEnabled()) + LOG.debug("Reached EOF"); // Be sure that this stream cannot be reused. closed.set(true); // Removed buffers that may have remained in the queue. @@ -179,7 +182,8 @@ public class MessageInputStream extends InputStream implements MessageAppender } catch (InterruptedException x) { - LOG.debug("Interrupted while waiting to read", x); + if (LOG.isDebugEnabled()) + LOG.debug("Interrupted while waiting to read", x); closed.set(true); return -1; } |