Merge pull request #618 from stefanmk/patch-2
Bug in BufferedWriteHandler fixed
This commit is contained in:
commit
a7d205075b
@ -254,6 +254,7 @@ public class BufferedWriteHandler extends SimpleChannelHandler implements LifeCy
|
||||
final Queue<MessageEvent> queue = getQueue();
|
||||
if (consolidateOnFlush) {
|
||||
if (queue.isEmpty()) {
|
||||
flush.set(false);
|
||||
return;
|
||||
}
|
||||
|
||||
@ -283,7 +284,8 @@ public class BufferedWriteHandler extends SimpleChannelHandler implements LifeCy
|
||||
ctx.sendDownstream(e);
|
||||
}
|
||||
}
|
||||
}
|
||||
flush.set(false);
|
||||
}
|
||||
|
||||
if (acquired && (!channel.isConnected() || channel.isWritable() && !queue.isEmpty())) {
|
||||
flush(consolidateOnFlush);
|
||||
|
Loading…
Reference in New Issue
Block a user