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

Fix resource leakage in example

Browse Source
This commit is contained in:
Norman Maurer 2013-07-11 10:20:38 +02:00
parent 4d94f1d1e1
commit f47fa76b9a
1 changed files with 3 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
example/src/main/java/io/netty/example/http/websocketx/autobahn/AutobahnServerHandler.java
View File

@ -70,12 +70,14 @@ public class AutobahnServerHandler extends ChannelInboundHandlerAdapter {
// Handle a bad request.
if (!req.getDecoderResult().isSuccess()) {
sendHttpResponse(ctx, req, new DefaultFullHttpResponse(HTTP_1_1, BAD_REQUEST));
req.release();
return;
}
// Allow only GET methods.
if (req.getMethod() != GET) {
sendHttpResponse(ctx, req, new DefaultFullHttpResponse(HTTP_1_1, FORBIDDEN));
req.release();
return;
}
@ -88,6 +90,7 @@ public class AutobahnServerHandler extends ChannelInboundHandlerAdapter {
} else {
handshaker.handshake(ctx.channel(), req);
}
req.release();
}
private void handleWebSocketFrame(ChannelHandlerContext ctx, WebSocketFrame frame) {