andreacavalli/netty5
1
0
Fork 0
Code Issues Pull Requests Projects Releases Wiki Activity

Fix a bug in AbstractEmbeddedChannel where flush failure is not recorded

Browse Source
This commit is contained in:
Trustin Lee 2013-02-10 00:46:30 +09:00
parent 46a249a26b
commit 61bbb04852
1 changed files with 6 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

7
transport/src/main/java/io/netty/channel/embedded/AbstractEmbeddedChannel.java
View File

@ -23,6 +23,7 @@ import io.netty.channel.AbstractChannel;
import io.netty.channel.Channel;
import io.netty.channel.ChannelConfig;
import io.netty.channel.ChannelException;
import io.netty.channel.ChannelFuture;
import io.netty.channel.ChannelHandler;
import io.netty.channel.ChannelHandlerContext;
import io.netty.channel.ChannelInboundByteHandler;
@ -302,7 +303,11 @@ public abstract class AbstractEmbeddedChannel<O> extends AbstractChannel {
*/
public boolean writeOutbound(Object data) {
ensureOpen();
write(data);
ChannelFuture future = write(data);
assert future.isDone();
if (future.cause() != null) {
recordException(future.cause());
}
runPendingTasks();
checkException();
return hasReadableOutboundBuffer();