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

Add testcases to prove HttpResponseEncoder correctly handles empty content

Browse Source 
Motivation:

Issue #6695 states that there is an issue when writing empty content via HttpResponseEncoder.

Modifications:

Add two test-cases.

Result:

Verified that all works as expected.
This commit is contained in:
Norman Maurer 2017-08-06 15:27:52 +02:00
parent a527bdb6c6
commit 0b1b39adb1
1 changed files with 45 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

45
codec-http/src/test/java/io/netty/handler/codec/http/HttpResponseEncoderTest.java
View File

@ -134,4 +134,49 @@ public class HttpResponseEncoderTest {
assertFalse(channel.finish());
}
@Test
public void testEmptyContentChunked() throws Exception {
testEmptyContent(true);
}
@Test
public void testEmptyContentNotChunked() throws Exception {
testEmptyContent(false);
}
private static void testEmptyContent(boolean chunked) throws Exception {
String content = "netty rocks";
ByteBuf contentBuffer = Unpooled.copiedBuffer(content, CharsetUtil.US_ASCII);
int length = contentBuffer.readableBytes();
EmbeddedChannel channel = new EmbeddedChannel(new HttpResponseEncoder());
HttpResponse response = new DefaultHttpResponse(HttpVersion.HTTP_1_1, HttpResponseStatus.OK);
if (!chunked) {
HttpHeaders.setContentLength(response, length);
}
assertTrue(channel.writeOutbound(response));
assertTrue(channel.writeOutbound(new DefaultHttpContent(Unpooled.EMPTY_BUFFER)));
assertTrue(channel.writeOutbound(new DefaultLastHttpContent(contentBuffer)));
ByteBuf buffer = (ByteBuf) channel.readOutbound();
if (!chunked) {
assertEquals("HTTP/1.1 200 OK\r\nContent-Length: " + length + "\r\n\r\n",
buffer.toString(CharsetUtil.US_ASCII));
} else {
assertEquals("HTTP/1.1 200 OK\r\n\r\n", buffer.toString(CharsetUtil.US_ASCII));
}
buffer.release();
// Test writing an empty buffer works when the encoder is not at ST_INIT.
buffer = (ByteBuf) channel.readOutbound();
assertEquals(0, buffer.readableBytes());
buffer.release();
buffer = (ByteBuf) channel.readOutbound();
assertEquals(length, buffer.readableBytes());
buffer.release();
assertFalse(channel.finish());
}
}