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

Fix compilation error and warning

Browse Source
This commit is contained in:
Trustin Lee 2012-07-07 14:48:34 +09:00
parent fae3861c3a
commit ec88f6617c
2 changed files with 2 additions and 3 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

@ -760,7 +760,7 @@ public abstract class AbstractChannel extends DefaultAttributeMap implements Cha
} }
} }
private void notifyFlushFutures(Throwable cause) { protected void notifyFlushFutures(Throwable cause) {
notifyFlushFutures(); notifyFlushFutures();
for (;;) { for (;;) {
FlushCheckpoint cp = flushCheckpoints.poll(); FlushCheckpoint cp = flushCheckpoints.poll();

3
transport/src/main/java/io/netty/channel/socket/aio/AioSocketChannelConfig.java
View File

@ -51,7 +51,6 @@ public class AioSocketChannelConfig extends DefaultChannelConfig
SO_RCVBUF, SO_SNDBUF, TCP_NODELAY, SO_KEEPALIVE, SO_REUSEADDR, SO_LINGER, IP_TOS); SO_RCVBUF, SO_SNDBUF, TCP_NODELAY, SO_KEEPALIVE, SO_REUSEADDR, SO_LINGER, IP_TOS);
} }
@SuppressWarnings("unchecked")
@Override @Override
public <T> T getOption(ChannelOption<T> option) { public <T> T getOption(ChannelOption<T> option) {
if (option == SO_RCVBUF) { if (option == SO_RCVBUF) {
@ -107,7 +106,7 @@ public class AioSocketChannelConfig extends DefaultChannelConfig
@Override @Override
public int getReceiveBufferSize() { public int getReceiveBufferSize() {
try { try {
return (int) channel.getOption(StandardSocketOptions.SO_RCVBUF); return channel.getOption(StandardSocketOptions.SO_RCVBUF);
} catch (IOException e) { } catch (IOException e) {
throw new ChannelException(e); throw new ChannelException(e);
} }