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

Fix more compilation errors

Browse Source
This commit is contained in:
Trustin Lee 2012-07-07 14:44:06 +09:00
parent 0941d617d9
commit c57e903c4d
2 changed files with 2 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
transport/src/main/java/io/netty/channel/AbstractChannel.java
View File

@ -722,7 +722,7 @@ public abstract class AbstractChannel extends DefaultAttributeMap implements Cha
protected abstract boolean isFlushPending(); protected abstract boolean isFlushPending();
private void notifyFlushFutures() { protected void notifyFlushFutures() {
if (flushCheckpoints.isEmpty()) { if (flushCheckpoints.isEmpty()) {
return; return;
} }

4
transport/src/main/java/io/netty/channel/socket/aio/AioSocketChannel.java
View File

@ -172,11 +172,10 @@ public class AioSocketChannel extends AbstractAioChannel implements SocketChanne
} }
@Override @Override
protected boolean doFlushByteBuffer(ByteBuf buf) throws Exception { protected void doFlushByteBuffer(ByteBuf buf) throws Exception {
if (!buf.readable()) { if (!buf.readable()) {
// Reset reader/writerIndex to 0 if the buffer is empty. // Reset reader/writerIndex to 0 if the buffer is empty.
buf.clear(); buf.clear();
return true;
} }
// Only one pending write can be scheduled at one time. Otherwise // Only one pending write can be scheduled at one time. Otherwise
@ -187,7 +186,6 @@ public class AioSocketChannel extends AbstractAioChannel implements SocketChanne
ByteBuffer buffer = buf.nioBuffer(); ByteBuffer buffer = buf.nioBuffer();
javaChannel().write(buffer, this, WRITE_HANDLER); javaChannel().write(buffer, this, WRITE_HANDLER);
} }
return false;
} }