Fixed a bug where discardReadBytes is called in a wrong place

2012-07-10 14:25:46 +09:00 · 2012-07-10 14:25:46 +09:00 · d66a187b5d
commit d66a187b5d
parent 917ed5173e
1 changed files with 1 additions and 1 deletions
--- a/transport/src/main/java/io/netty/channel/socket/aio/AioSocketChannel.java
+++ b/transport/src/main/java/io/netty/channel/socket/aio/AioSocketChannel.java
@ -163,9 +163,9 @@ public class AioSocketChannel extends AbstractAioChannel implements SocketChanne

        flushing = true;
        if (buf.readable()) {
-            buf.discardReadBytes();
            javaChannel().write(buf.nioBuffer(), this, WRITE_HANDLER);
        } else {
+            buf.discardReadBytes();
            notifyFlushFutures();
            flushing = false;
        }