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

Just fail all futures that are left to not cause out-of-order writes

Browse Source
This commit is contained in:
Norman Maurer 2013-04-19 07:06:22 +02:00
parent ca5554dfe7
commit 1cdb9e0b48
1 changed files with 1 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
handler/src/main/java/io/netty/handler/stream/ChunkedWriteHandler.java
View File

@ -351,9 +351,7 @@ public class ChunkedWriteHandler
// This method should not need any synchronization as the ChunkedWriteHandler will not receive any new events // This method should not need any synchronization as the ChunkedWriteHandler will not receive any new events
@Override @Override
public void handlerRemoved(ChannelHandlerContext ctx) throws Exception { public void handlerRemoved(ChannelHandlerContext ctx) throws Exception {
doFlush(ctx); // Fail all promised that are queued. This is needed because otherwise we would never notify the
// Fail all MessageEvent's that are left. This is needed because otherwise we would never notify the
// ChannelFuture and the registered FutureListener. See #304 // ChannelFuture and the registered FutureListener. See #304
discard(ctx, new ChannelException(ChunkedWriteHandler.class.getSimpleName() + " removed from pipeline.")); discard(ctx, new ChannelException(ChunkedWriteHandler.class.getSimpleName() + " removed from pipeline."));
} }