ByteCounter.java 文件源码

@Override
public void handleUpstream(ChannelHandlerContext ctx, ChannelEvent e)
  throws Exception {
  if (e instanceof MessageEvent &&
      ((MessageEvent) e).getMessage() instanceof ChannelBuffer) {
    ChannelBuffer b = (ChannelBuffer) ((MessageEvent) e).getMessage();
    int receivedBytes = b.readableBytes();
    bytesReceived.addAndGet(receivedBytes);
    receivedBytesHist.update(receivedBytes);
    receivedRequests.incrementAndGet();
    receivedRequestsMeter.mark();
    if (LOG.isDebugEnabled()) {
      LOG.debug("handleUpstream: " + ctx.getName() + " buffer size = " +
          receivedBytes + ", total bytes = " + bytesReceived.get());
    }
  }

  super.handleUpstream(ctx, e);
}