Fix small race which can lead to resumeTransfer() to not kick in. See #300
This commit is contained in:
parent
97069027a8
commit
308afcaa40
@ -77,7 +77,7 @@ public class ChunkedWriteHandler implements ChannelUpstreamHandler, ChannelDowns
|
|||||||
|
|
||||||
private final Queue<MessageEvent> queue = QueueFactory.createQueue(MessageEvent.class);
|
private final Queue<MessageEvent> queue = QueueFactory.createQueue(MessageEvent.class);
|
||||||
|
|
||||||
private ChannelHandlerContext ctx;
|
private volatile ChannelHandlerContext ctx;
|
||||||
private MessageEvent currentEvent;
|
private MessageEvent currentEvent;
|
||||||
|
|
||||||
/**
|
/**
|
||||||
|
Loading…
Reference in New Issue
Block a user