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 2014-06-13 23:03:37 +02:00
parent 2b86d34d5a
commit 363c18a29e
2 changed files with 22 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

16
jetty-http2/http2-common/src/main/java/org/eclipse/jetty/http2/HTTP2Session.java
View File

@ -112,6 +112,8 @@ public abstract class HTTP2Session implements ISession, Parser.Listener
@Override
public boolean onData(final DataFrame frame)
{
if (LOG.isDebugEnabled())
LOG.debug("Received {}", frame);
int streamId = frame.getStreamId();
final IStream stream = getStream(streamId);
if (stream != null)
@ -157,6 +159,8 @@ public abstract class HTTP2Session implements ISession, Parser.Listener
@Override
public boolean onSettings(SettingsFrame frame)
{
if (LOG.isDebugEnabled())
LOG.debug("Received {}", frame);
Map<Integer, Integer> settings = frame.getSettings();
if (settings.containsKey(SettingsFrame.MAX_CONCURRENT_STREAMS))
{
@ -177,6 +181,8 @@ public abstract class HTTP2Session implements ISession, Parser.Listener
@Override
public boolean onPing(PingFrame frame)
{
if (LOG.isDebugEnabled())
LOG.debug("Received {}", frame);
if (frame.isReply())
{
notifyPing(this, frame);
@ -221,6 +227,8 @@ public abstract class HTTP2Session implements ISession, Parser.Listener
@Override
public boolean onWindowUpdate(WindowUpdateFrame frame)
{
if (LOG.isDebugEnabled())
LOG.debug("Received {}", frame);
int streamId = frame.getStreamId();
IStream stream = null;
if (streamId > 0)
@ -616,6 +624,8 @@ public abstract class HTTP2Session implements ISession, Parser.Listener
}
List<ByteBuffer> byteBuffers = lease.getByteBuffers();
if (LOG.isDebugEnabled())
LOG.debug("Writing {} buffers ({} bytes) for {}", byteBuffers.size(), lease.getTotalLength(), active);
endPoint.write(this, byteBuffers.toArray(new ByteBuffer[byteBuffers.size()]));
return Action.SCHEDULED;
}
@ -716,6 +726,12 @@ public abstract class HTTP2Session implements ISession, Parser.Listener
{
callback.failed(x);
}
@Override
public String toString()
{
return frame.toString();
}
}
private class DataFlusherEntry extends FlusherEntry

6
jetty-http2/http2-common/src/main/java/org/eclipse/jetty/http2/frames/WindowUpdateFrame.java
View File

@ -39,4 +39,10 @@ public class WindowUpdateFrame extends Frame
{
return windowDelta;
}
@Override
public String toString()
{
return String.format("%s{delta=%d}", super.toString(), windowDelta);
}
}