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

Fixed find bugs warnings

Browse Source
This commit is contained in:
Trustin Lee 2009-03-04 14:15:59 +00:00
parent 6ce3eebc55
commit 1781e0e1dd
5 changed files with 8 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
src/main/java/org/jboss/netty/channel/local/LocalClientChannelSink.java
View File

@ -88,7 +88,8 @@ final class LocalClientChannelSink extends AbstractChannelSink {
else if (e instanceof MessageEvent) { else if (e instanceof MessageEvent) {
MessageEvent event = (MessageEvent) e; MessageEvent event = (MessageEvent) e;
DefaultLocalChannel channel = (DefaultLocalChannel) event.getChannel(); DefaultLocalChannel channel = (DefaultLocalChannel) event.getChannel();
channel.writeBuffer.offer(event); boolean offered = channel.writeBuffer.offer(event);
assert offered;
channel.flushWriteBuffer(); channel.flushWriteBuffer();
} }
} }

3
src/main/java/org/jboss/netty/channel/local/LocalServerChannelSink.java
View File

@ -109,7 +109,8 @@ final class LocalServerChannelSink extends AbstractChannelSink {
} else if (e instanceof MessageEvent) { } else if (e instanceof MessageEvent) {
MessageEvent event = (MessageEvent) e; MessageEvent event = (MessageEvent) e;
DefaultLocalChannel channel = (DefaultLocalChannel) event.getChannel(); DefaultLocalChannel channel = (DefaultLocalChannel) event.getChannel();
channel.writeBuffer.offer(event); boolean offered = channel.writeBuffer.offer(event);
assert offered;
channel.flushWriteBuffer(); channel.flushWriteBuffer();
} }
} }

3
src/main/java/org/jboss/netty/channel/socket/nio/NioServerSocketPipelineSink.java
View File

@ -134,7 +134,8 @@ class NioServerSocketPipelineSink extends AbstractChannelSink {
} else if (e instanceof MessageEvent) { } else if (e instanceof MessageEvent) {
MessageEvent event = (MessageEvent) e; MessageEvent event = (MessageEvent) e;
NioSocketChannel channel = (NioSocketChannel) event.getChannel(); NioSocketChannel channel = (NioSocketChannel) event.getChannel();
channel.writeBuffer.offer(event); boolean offered = channel.writeBuffer.offer(event);
assert offered;
NioWorker.write(channel, true); NioWorker.write(channel, true);
} }
} }

3
src/main/java/org/jboss/netty/channel/xnio/XnioClientChannelSink.java
View File

@ -141,7 +141,8 @@ final class XnioClientChannelSink extends AbstractChannelSink {
if (xnioChannel instanceof GatheringByteChannel || if (xnioChannel instanceof GatheringByteChannel ||
xnioChannel instanceof MultipointWritableMessageChannel || xnioChannel instanceof MultipointWritableMessageChannel ||
xnioChannel instanceof WritableMessageChannel) { xnioChannel instanceof WritableMessageChannel) {
channel.writeBuffer.offer(event); boolean offered = channel.writeBuffer.offer(event);
assert offered;
if (xnioChannel instanceof SuspendableWriteChannel) { if (xnioChannel instanceof SuspendableWriteChannel) {
((SuspendableWriteChannel) xnioChannel).resumeWrites(); ((SuspendableWriteChannel) xnioChannel).resumeWrites();
} }

1
src/main/java/org/jboss/netty/handler/codec/http/HttpMessageDecoder.java
View File

@ -53,7 +53,6 @@ public abstract class HttpMessageDecoder extends ReplayingDecoder<HttpMessageDec
private volatile ChannelBuffer content; private volatile ChannelBuffer content;
private volatile int chunkSize; private volatile int chunkSize;
/** /**
* @author The Netty Project (netty-dev@lists.jboss.org) * @author The Netty Project (netty-dev@lists.jboss.org)
* @author Trustin Lee (tlee@redhat.com) * @author Trustin Lee (tlee@redhat.com)