Improved toString() using String.format() and improved logging and comments.

This commit is contained in:
Simone Bordet 2012-02-14 12:52:19 +01:00
parent 1c18cba38a
commit 9abc92145d
14 changed files with 21 additions and 21 deletions

View File

@ -505,7 +505,7 @@ public class StandardSession implements ISession, Parser.Listener, ISession.Cont
{ {
if (frameListener != null) if (frameListener != null)
{ {
logger.debug("Invoking syn callback with frame {} on listener {}", frame, frameListener); logger.debug("Invoking callback with {} on listener {}", frame, frameListener);
SynInfo synInfo = new SynInfo(frame.getHeaders(), frame.isClose(), frame.isUnidirectional(), frame.getAssociatedStreamId(), frame.getPriority()); SynInfo synInfo = new SynInfo(frame.getHeaders(), frame.isClose(), frame.isUnidirectional(), frame.getAssociatedStreamId(), frame.getPriority());
return frameListener.onSyn(stream, synInfo); return frameListener.onSyn(stream, synInfo);
} }
@ -523,7 +523,7 @@ public class StandardSession implements ISession, Parser.Listener, ISession.Cont
{ {
if (frameListener != null) if (frameListener != null)
{ {
logger.debug("Invoking rst callback with frame {} on listener {}", frame, frameListener); logger.debug("Invoking callback with {} on listener {}", frame, frameListener);
RstInfo rstInfo = new RstInfo(frame.getStreamId(), StreamStatus.from(frame.getVersion(), frame.getStatusCode())); RstInfo rstInfo = new RstInfo(frame.getStreamId(), StreamStatus.from(frame.getVersion(), frame.getStatusCode()));
frameListener.onRst(this, rstInfo); frameListener.onRst(this, rstInfo);
} }
@ -540,7 +540,7 @@ public class StandardSession implements ISession, Parser.Listener, ISession.Cont
{ {
if (frameListener != null) if (frameListener != null)
{ {
logger.debug("Invoking settings callback with frame {} on listener {}", frame, frameListener); logger.debug("Invoking callback with {} on listener {}", frame, frameListener);
SettingsInfo settingsInfo = new SettingsInfo(frame.getSettings(), frame.isClearPersisted()); SettingsInfo settingsInfo = new SettingsInfo(frame.getSettings(), frame.isClearPersisted());
frameListener.onSettings(this, settingsInfo); frameListener.onSettings(this, settingsInfo);
} }
@ -557,7 +557,7 @@ public class StandardSession implements ISession, Parser.Listener, ISession.Cont
{ {
if (frameListener != null) if (frameListener != null)
{ {
logger.debug("Invoking ping callback with frame {} on listener {}", frame, frameListener); logger.debug("Invoking callback with {} on listener {}", frame, frameListener);
PingInfo pingInfo = new PingInfo(frame.getPingId()); PingInfo pingInfo = new PingInfo(frame.getPingId());
frameListener.onPing(this, pingInfo); frameListener.onPing(this, pingInfo);
} }
@ -574,7 +574,7 @@ public class StandardSession implements ISession, Parser.Listener, ISession.Cont
{ {
if (frameListener != null) if (frameListener != null)
{ {
logger.debug("Invoking go away callback with frame {} on listener {}", frame, frameListener); logger.debug("Invoking callback with {} on listener {}", frame, frameListener);
GoAwayInfo goAwayInfo = new GoAwayInfo(frame.getLastStreamId(), SessionStatus.from(frame.getStatusCode())); GoAwayInfo goAwayInfo = new GoAwayInfo(frame.getLastStreamId(), SessionStatus.from(frame.getStatusCode()));
frameListener.onGoAway(this, goAwayInfo); frameListener.onGoAway(this, goAwayInfo);
} }
@ -775,7 +775,7 @@ public class StandardSession implements ISession, Parser.Listener, ISession.Cont
@Override @Override
public String toString() public String toString()
{ {
return String.format("data@%x consumed=%b on %s", hashCode(), data.isConsumed(), stream); return String.format("DATA bytes @%x consumed=%b on %s", data.hashCode(), data.isConsumed(), stream);
} }
} }
} }

View File

@ -225,7 +225,7 @@ public class StandardStream implements IStream
{ {
if (frameListener != null) if (frameListener != null)
{ {
logger.debug("Invoking reply callback with frame {} on listener {}", synReply, frameListener); logger.debug("Invoking reply callback with {} on listener {}", synReply, frameListener);
frameListener.onReply(this, new ReplyInfo(synReply.getHeaders(), synReply.isClose())); frameListener.onReply(this, new ReplyInfo(synReply.getHeaders(), synReply.isClose()));
} }
} }
@ -242,7 +242,7 @@ public class StandardStream implements IStream
{ {
if (frameListener != null) if (frameListener != null)
{ {
logger.debug("Invoking headers callback with frame {} on listener {}", frame, frameListener); logger.debug("Invoking headers callback with {} on listener {}", frame, frameListener);
frameListener.onHeaders(this, new HeadersInfo(frame.getHeaders(), frame.isClose(), frame.isResetCompression())); frameListener.onHeaders(this, new HeadersInfo(frame.getHeaders(), frame.isClose(), frame.isResetCompression()));
} }
} }
@ -259,7 +259,7 @@ public class StandardStream implements IStream
{ {
if (frameListener != null) if (frameListener != null)
{ {
logger.debug("Invoking data callback with frame {} on listener {}", frame, frameListener); logger.debug("Invoking data callback with {} on listener {}", frame, frameListener);
frameListener.onData(this, new ByteBufferDataInfo(data, frame.isClose(), frame.isCompress())); frameListener.onData(this, new ByteBufferDataInfo(data, frame.isClose(), frame.isCompress()));
} }
} }

View File

@ -82,6 +82,6 @@ public abstract class DataInfo
@Override @Override
public String toString() public String toString()
{ {
return "DATA length=" + getBytesCount() + " close=" + isClose() + " compress=" + isCompress(); return String.format("DATA @%x length=%d close=%b compress=%b", hashCode(), getBytesCount(), isClose(), isCompress());
} }
} }

View File

@ -49,6 +49,6 @@ public abstract class ControlFrame
@Override @Override
public String toString() public String toString()
{ {
return getType() + " v" + getVersion(); return String.format("%s frame v%s", getType(), getVersion());
} }
} }

View File

@ -61,6 +61,6 @@ public class DataFrame
@Override @Override
public String toString() public String toString()
{ {
return "DATA stream=" + getStreamId() + " length=" + getLength() + " close=" + isClose() + " compress=" + isCompress(); return String.format("DATA frame stream=%d length=%d close=%b compress=%b", getStreamId(), getLength(), isClose(), isCompress());
} }
} }

View File

@ -44,6 +44,6 @@ public class GoAwayFrame extends ControlFrame
public String toString() public String toString()
{ {
SessionStatus sessionStatus = SessionStatus.from(getStatusCode()); SessionStatus sessionStatus = SessionStatus.from(getStatusCode());
return super.toString() + " last_stream=" + getLastStreamId() + " status=" + (sessionStatus == null ? getStatusCode() : sessionStatus); return String.format("%s last_stream=%d status=%s", super.toString(), getLastStreamId(), sessionStatus == null ? getStatusCode() : sessionStatus);
} }
} }

View File

@ -71,6 +71,6 @@ public class HeadersFrame extends ControlFrame
@Override @Override
public String toString() public String toString()
{ {
return super.toString() + " stream=" + getStreamId() + " close=" + isClose() + " reset_compression=" + isResetCompression(); return String.format("%s stream=%d close=%b reset_compression=%b", super.toString(), getStreamId(), isClose(), isResetCompression());
} }
} }

View File

@ -34,6 +34,6 @@ public class PingFrame extends ControlFrame
@Override @Override
public String toString() public String toString()
{ {
return super.toString() + " ping=" + getPingId(); return String.format("%s ping=%d", super.toString(), getPingId());
} }
} }

View File

@ -44,6 +44,6 @@ public class RstStreamFrame extends ControlFrame
public String toString() public String toString()
{ {
StreamStatus streamStatus = StreamStatus.from(getVersion(), getStatusCode()); StreamStatus streamStatus = StreamStatus.from(getVersion(), getStatusCode());
return super.toString() + " stream=" + getStreamId() + " status=" + (streamStatus == null ? getStatusCode() : streamStatus); return String.format("%s stream=%d status=%s", super.toString(), getStreamId(), streamStatus == null ? getStatusCode() : streamStatus);
} }
} }

View File

@ -43,6 +43,6 @@ public class SettingsFrame extends ControlFrame
@Override @Override
public String toString() public String toString()
{ {
return super.toString() + " clear_persisted=" + isClearPersisted() + " settings=" + getSettings(); return String.format("%s clear_persisted=%b settings=%s", super.toString(), isClearPersisted(), getSettings());
} }
} }

View File

@ -49,6 +49,6 @@ public class SynReplyFrame extends ControlFrame
@Override @Override
public String toString() public String toString()
{ {
return super.toString() + " stream=" + getStreamId() + " close=" + isClose(); return String.format("%s stream=%d close=%b", super.toString(), getStreamId(), isClose());
} }
} }

View File

@ -68,6 +68,6 @@ public class SynStreamFrame extends ControlFrame
@Override @Override
public String toString() public String toString()
{ {
return super.toString() + " stream=" + getStreamId() + " close=" + isClose(); return String.format("%s stream=%d close=%b", super.toString(), getStreamId(), isClose());
} }
} }

View File

@ -41,6 +41,6 @@ public class WindowUpdateFrame extends ControlFrame
@Override @Override
public String toString() public String toString()
{ {
return super.toString() + " stream=" + getStreamId() + " delta=" + getWindowDelta(); return String.format("%s stream=%d delta=%d", super.toString(), getStreamId(), getWindowDelta());
} }
} }

View File

@ -27,7 +27,7 @@ public class DataFrameGenerator
{ {
ByteBuffer buffer = ByteBuffer.allocateDirect(DataFrame.HEADER_LENGTH + windowSize); ByteBuffer buffer = ByteBuffer.allocateDirect(DataFrame.HEADER_LENGTH + windowSize);
buffer.position(DataFrame.HEADER_LENGTH); buffer.position(DataFrame.HEADER_LENGTH);
// Guaranteed to always be > 0 // Guaranteed to always be >= 0
int read = dataInfo.getBytes(buffer); int read = dataInfo.getBytes(buffer);
buffer.putInt(0, streamId & 0x7F_FF_FF_FF); buffer.putInt(0, streamId & 0x7F_FF_FF_FF);