From 3de2d0697132285557961a2b89c93a569ce998f5 Mon Sep 17 00:00:00 2001
From: stefanmk <info@shredderchess.com>
Date: Wed, 19 Sep 2012 17:50:25 +0300
Subject: [PATCH] Update
 src/main/java/org/jboss/netty/handler/queue/BufferedWriteHandler.java

fix bug, flush variable was never reset
---
 .../org/jboss/netty/handler/queue/BufferedWriteHandler.java   | 4 +++-
 1 file changed, 3 insertions(+), 1 deletion(-)

diff --git a/src/main/java/org/jboss/netty/handler/queue/BufferedWriteHandler.java b/src/main/java/org/jboss/netty/handler/queue/BufferedWriteHandler.java
index 2d5ae5f974..54940e8cbf 100644
--- a/src/main/java/org/jboss/netty/handler/queue/BufferedWriteHandler.java
+++ b/src/main/java/org/jboss/netty/handler/queue/BufferedWriteHandler.java
@@ -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);