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

Simplify ChannelInboundMessageHandlerAdapter.inboundBufferUpdated() implementation

Browse Source
This commit is contained in:
Trustin Lee 2013-03-05 12:22:57 +09:00
parent 0e3825899a
commit e4aa941bd4
1 changed files with 2 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
transport/src/main/java/io/netty/channel/ChannelInboundMessageHandlerAdapter.java
View File

@ -92,13 +92,12 @@ public abstract class ChannelInboundMessageHandlerAdapter<I>
I imsg = (I) msg;
try {
messageReceived(ctx, imsg);
} catch (Signal abort) {
abort.expect(ABORT);
break;
} finally {
BufUtil.release(imsg);
}
}
} catch (Signal abort) {
abort.expect(ABORT);
} finally {
if (oldOutSize != out.size()) {
ctx.fireInboundBufferUpdated();