From 06756f3cf833bc2eb39dfbd273b36e2cdf7c6293 Mon Sep 17 00:00:00 2001 From: Jeff Pinner Date: Fri, 3 May 2013 15:14:13 -0400 Subject: [PATCH] SPDY: SpdyHttpDecoder cleanup and set content length on last message --- .../jboss/netty/handler/codec/spdy/SpdyHttpDecoder.java | 7 ++++--- 1 file changed, 4 insertions(+), 3 deletions(-) diff --git a/src/main/java/org/jboss/netty/handler/codec/spdy/SpdyHttpDecoder.java b/src/main/java/org/jboss/netty/handler/codec/spdy/SpdyHttpDecoder.java index 852fae4b7d..223809d03d 100644 --- a/src/main/java/org/jboss/netty/handler/codec/spdy/SpdyHttpDecoder.java +++ b/src/main/java/org/jboss/netty/handler/codec/spdy/SpdyHttpDecoder.java @@ -214,7 +214,7 @@ public class SpdyHttpDecoder extends OneToOneDecoder { } else if (msg instanceof SpdyHeadersFrame) { SpdyHeadersFrame spdyHeadersFrame = (SpdyHeadersFrame) msg; - Integer streamId = spdyHeadersFrame.getStreamId(); + int streamId = spdyHeadersFrame.getStreamId(); HttpMessage httpMessage = getMessage(streamId); // If message is not in map discard HEADERS frame. @@ -227,6 +227,7 @@ public class SpdyHttpDecoder extends OneToOneDecoder { } if (spdyHeadersFrame.isLast()) { + HttpHeaders.setContentLength(httpMessage, httpMessage.getContent().readableBytes()); removeMessage(streamId); return httpMessage; } @@ -234,7 +235,7 @@ public class SpdyHttpDecoder extends OneToOneDecoder { } else if (msg instanceof SpdyDataFrame) { SpdyDataFrame spdyDataFrame = (SpdyDataFrame) msg; - Integer streamId = spdyDataFrame.getStreamId(); + int streamId = spdyDataFrame.getStreamId(); HttpMessage httpMessage = getMessage(streamId); // If message is not in map discard Data Frame. @@ -266,7 +267,7 @@ public class SpdyHttpDecoder extends OneToOneDecoder { } else if (msg instanceof SpdyRstStreamFrame) { SpdyRstStreamFrame spdyRstStreamFrame = (SpdyRstStreamFrame) msg; - Integer streamId = spdyRstStreamFrame.getStreamId(); + int streamId = spdyRstStreamFrame.getStreamId(); removeMessage(streamId); }