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

Implemented chunked encoding support for the HTTP encoder

Browse Source
This commit is contained in:
Trustin Lee 2009-02-12 06:37:22 +00:00
parent 602c99c532
commit 2a555082bb
1 changed files with 29 additions and 11 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

38
src/main/java/org/jboss/netty/handler/codec/http/HttpMessageEncoder.java
View File

@ -21,6 +21,7 @@
*/
package org.jboss.netty.handler.codec.http;
import static org.jboss.netty.buffer.ChannelBuffers.*;
import static org.jboss.netty.handler.codec.http.HttpCodecUtil.*;
import java.util.List;
@ -46,19 +47,36 @@ public abstract class HttpMessageEncoder extends OneToOneEncoder {
@Override
protected Object encode(ChannelHandlerContext ctx, Channel channel, Object msg) throws Exception {
if (!(msg instanceof HttpMessage)) {
return msg;
}
if (msg instanceof HttpMessage) {
HttpMessage request = (HttpMessage) msg;
ChannelBuffer buf = ChannelBuffers.dynamicBuffer(
ChannelBuffer header = ChannelBuffers.dynamicBuffer(
channel.getConfig().getBufferFactory());
encodeInitialLine(buf, request);
encodeHeaders(buf, request);
buf.writeBytes(CRLF);
if (request.getContent() != null) {
buf.writeBytes(request.getContent());
encodeInitialLine(header, request);
encodeHeaders(header, request);
header.writeBytes(CRLF);
ChannelBuffer content = request.getContent();
if (content == null) {
return header; // no content
} else {
return wrappedBuffer(header, content);
}
return buf;
}
if (msg instanceof HttpChunk) {
HttpChunk chunk = (HttpChunk) msg;
ChannelBuffer content = chunk.getContent();
int contentLength = content.readableBytes();
return wrappedBuffer(
copiedBuffer(Integer.toHexString(contentLength), "USASCII"),
wrappedBuffer(CRLF),
content.slice(content.readerIndex(), contentLength),
wrappedBuffer(CRLF));
}
// Unknown message type.
return msg;
}
/**