andreacavalli/netty5
1
0
Fork 0
Code Issues Pull Requests Projects Releases Wiki Activity

Modify HttpContentDecoder to writeInbound and readInbound from its internal decoder

Browse Source
This commit is contained in:
Derek Troy-West 2013-07-16 23:47:46 +10:00 committed by Norman Maurer
parent dcf7896172
commit 8e71186153
1 changed files with 2 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
codec-http/src/main/java/io/netty/handler/codec/http/HttpContentDecoder.java
View File

@ -214,7 +214,7 @@ public abstract class HttpContentDecoder extends MessageToMessageDecoder<HttpObj
private void decode(ByteBuf in, List<Object> out) {
// call retain here as it will call release after its written to the channel
decoder.writeOutbound(in.retain());
decoder.writeInbound(in.retain());
fetchDecoderOutput(out);
}
@ -228,7 +228,7 @@ public abstract class HttpContentDecoder extends MessageToMessageDecoder<HttpObj
private void fetchDecoderOutput(List<Object> out) {
for (;;) {
ByteBuf buf = (ByteBuf) decoder.readOutbound();
ByteBuf buf = (ByteBuf) decoder.readInbound();
if (buf == null) {
break;
}