Eclipse
/
jetty.project
mirror of https://github.com/jetty/jetty.project.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Improved logging.

This commit is contained in:
Simone Bordet 2016-06-20 17:23:12 +02:00
parent 62effb73d3
commit 442a7ce8cc
2 changed files with 7 additions and 7 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
jetty-http2/http2-common/src/main/java/org/eclipse/jetty/http2/AbstractFlowControlStrategy.java
View File

@ -139,13 +139,13 @@ public abstract class AbstractFlowControlStrategy implements FlowControlStrategy
{ {
int oldSize = session.updateRecvWindow(-length); int oldSize = session.updateRecvWindow(-length);
if (LOG.isDebugEnabled()) if (LOG.isDebugEnabled())
LOG.debug("Data received, updated session recv window {} -> {} for {}", oldSize, oldSize - length, session); LOG.debug("Data received, {} bytes, updated session recv window {} -> {} for {}", length, oldSize, oldSize - length, session);
if (stream != null) if (stream != null)
{ {
oldSize = stream.updateRecvWindow(-length); oldSize = stream.updateRecvWindow(-length);
if (LOG.isDebugEnabled()) if (LOG.isDebugEnabled())
LOG.debug("Data received, updated stream recv window {} -> {} for {}", oldSize, oldSize - length, stream); LOG.debug("Data received, {} bytes, updated stream recv window {} -> {} for {}", length, oldSize, oldSize - length, stream);
} }
} }

10
jetty-http2/http2-common/src/main/java/org/eclipse/jetty/http2/BufferingFlowControlStrategy.java
View File

@ -111,13 +111,13 @@ public class BufferingFlowControlStrategy extends AbstractFlowControlStrategy
level = sessionLevel.getAndSet(0); level = sessionLevel.getAndSet(0);
session.updateRecvWindow(level); session.updateRecvWindow(level);
if (LOG.isDebugEnabled()) if (LOG.isDebugEnabled())
LOG.debug("Data consumed, updated session recv window by {}/{} for {}", level, maxLevel, session); LOG.debug("Data consumed, {} bytes, updated session recv window by {}/{} for {}", length, level, maxLevel, session);
windowFrame = new WindowUpdateFrame(0, level); windowFrame = new WindowUpdateFrame(0, level);
} }
else else
{ {
if (LOG.isDebugEnabled()) if (LOG.isDebugEnabled())
LOG.debug("Data consumed, session recv window level {}/{} for {}", level, maxLevel, session); LOG.debug("Data consumed, {} bytes, session recv window level {}/{} for {}", length, level, maxLevel, session);
} }
Frame[] windowFrames = Frame.EMPTY_ARRAY; Frame[] windowFrames = Frame.EMPTY_ARRAY;
@ -126,7 +126,7 @@ public class BufferingFlowControlStrategy extends AbstractFlowControlStrategy
if (stream.isClosed()) if (stream.isClosed())
{ {
if (LOG.isDebugEnabled()) if (LOG.isDebugEnabled())
LOG.debug("Data consumed, ignoring update stream recv window by {} for closed {}", length, stream); LOG.debug("Data consumed, {} bytes, ignoring update stream recv window for closed {}", length, stream);
} }
else else
{ {
@ -140,7 +140,7 @@ public class BufferingFlowControlStrategy extends AbstractFlowControlStrategy
level = streamLevel.getAndSet(0); level = streamLevel.getAndSet(0);
stream.updateRecvWindow(level); stream.updateRecvWindow(level);
if (LOG.isDebugEnabled()) if (LOG.isDebugEnabled())
LOG.debug("Data consumed, updated stream recv window by {}/{} for {}", level, maxLevel, stream); LOG.debug("Data consumed, {} bytes, updated stream recv window by {}/{} for {}", length, level, maxLevel, stream);
WindowUpdateFrame frame = new WindowUpdateFrame(stream.getId(), level); WindowUpdateFrame frame = new WindowUpdateFrame(stream.getId(), level);
if (windowFrame == null) if (windowFrame == null)
windowFrame = frame; windowFrame = frame;
@ -150,7 +150,7 @@ public class BufferingFlowControlStrategy extends AbstractFlowControlStrategy
else else
{ {
if (LOG.isDebugEnabled()) if (LOG.isDebugEnabled())
LOG.debug("Data consumed, stream recv window level {}/{} for {}", level, maxLevel, stream); LOG.debug("Data consumed, {} bytes, stream recv window level {}/{} for {}", length, level, maxLevel, stream);
} }
} }
} }