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:13:02 +00:00
parent 392900e4b6
commit f93c240a7c
1 changed files with 4 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
src/main/java/org/jboss/netty/channel/socket/nio/NioClientSocketPipelineSink.java
View File

@ -117,7 +117,8 @@ class NioClientSocketPipelineSink extends AbstractChannelSink {
} else if (e instanceof MessageEvent) {
MessageEvent event = (MessageEvent) e;
NioSocketChannel channel = (NioSocketChannel) event.getChannel();
channel.writeBuffer.offer(event);
boolean offered = channel.writeBuffer.offer(event);
assert offered;
NioWorker.write(channel, true);
}
}
@ -217,7 +218,8 @@ class NioClientSocketPipelineSink extends AbstractChannelSink {
assert selector != null && selector.isOpen();
started = true;
registerTaskQueue.offer(registerTask);
boolean offered = registerTaskQueue.offer(registerTask);
assert offered;
}
if (wakenUp.compareAndSet(false, true)) {