Do not use slice() to get the content of HTTP msg

- Fixes #794
This commit is contained in:
Trustin Lee 2012-12-19 18:28:55 +09:00
parent b4fb6a49ee
commit 937c0481e0

View File

@ -496,39 +496,19 @@ public abstract class HttpMessageDecoder extends ReplayingDecoder<Object, HttpMe
if (length < contentRead) { if (length < contentRead) {
if (message.getTransferEncoding() != HttpTransferEncoding.STREAMED) { if (message.getTransferEncoding() != HttpTransferEncoding.STREAMED) {
message.setTransferEncoding(HttpTransferEncoding.STREAMED); message.setTransferEncoding(HttpTransferEncoding.STREAMED);
return new Object[] {message, new DefaultHttpChunk(read(buffer, toRead))}; return new Object[] {message, new DefaultHttpChunk(buffer.readBytes(toRead))};
} else { } else {
return new DefaultHttpChunk(read(buffer, toRead)); return new DefaultHttpChunk(buffer.readBytes(toRead));
} }
} }
if (content == null) { if (content == null) {
content = read(buffer, (int) length); content = buffer.readBytes((int) length);
} else { } else {
content.writeBytes(buffer.readBytes((int) length)); content.writeBytes(buffer.readBytes((int) length));
} }
return reset(); return reset();
} }
/**
* Try to do an optimized "read" of len from the given {@link ByteBuf}.
*
* This is part of #412 to safe byte copies
*
*/
private ByteBuf read(ByteBuf buffer, int len) {
ByteBuf internal = internalBuffer();
if (internal.readableBytes() >= len) {
int index = internal.readerIndex();
ByteBuf buf = internal.slice(index, len);
// update the readerindex so an the next read its on the correct position
buffer.readerIndex(index + len);
return buf;
} else {
return buffer.readBytes(len);
}
}
private State readHeaders(ByteBuf buffer) { private State readHeaders(ByteBuf buffer) {
headerSize = 0; headerSize = 0;
final HttpMessage message = this.message; final HttpMessage message = this.message;