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

Fix NPE

Browse Source
This commit is contained in:
Trustin Lee 2013-07-18 23:29:13 +09:00
parent 4cd7e62555
commit 5e5df6bd09
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/AbstractChannel.java
View File

@ -618,6 +618,11 @@ public abstract class AbstractChannel extends DefaultAttributeMap implements Cha
@Override @Override
public void flush() { public void flush() {
ChannelOutboundBuffer outboundBuffer = AbstractChannel.this.outboundBuffer;
if (outboundBuffer == null) {
return;
}
outboundBuffer.addFlush(); outboundBuffer.addFlush();
flush0(); flush0();
} }
@ -629,7 +634,7 @@ public abstract class AbstractChannel extends DefaultAttributeMap implements Cha
} }
final ChannelOutboundBuffer outboundBuffer = AbstractChannel.this.outboundBuffer; final ChannelOutboundBuffer outboundBuffer = AbstractChannel.this.outboundBuffer;
if (outboundBuffer.isEmpty()) { if (outboundBuffer == null || outboundBuffer.isEmpty()) {
return; return;
} }