Fix a bug where ChannelFutureProgressListener.operationProgressed() isn't something invoked

- Fixes #1950
- Use writtenBytes instead of localWrittenBytes so that operationProgressed() is triggered even when write operation was split into multiple system calls.
This commit is contained in:
Trustin Lee 2013-11-02 20:37:50 +09:00
parent 0e3ac74889
commit e215f91d8f

View File

@ -38,7 +38,6 @@ import java.util.Queue;
import java.util.Set;
import java.util.concurrent.Executor;
import static org.jboss.netty.channel.Channels.*;
abstract class AbstractNioWorker extends AbstractNioSelector implements Worker {
@ -224,7 +223,7 @@ abstract class AbstractNioWorker extends AbstractNioSelector implements Worker {
addOpWrite = true;
channel.writeSuspended = true;
if (localWrittenBytes > 0) {
if (writtenBytes > 0) {
// Notify progress listeners if necessary.
future.setProgress(
localWrittenBytes,