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:39 +00:00
parent f93c240a7c
commit 7044f9a586
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/NioWorker.java
View File

@ -132,7 +132,8 @@ class NioWorker implements Runnable {
assert selector != null && selector.isOpen(); assert selector != null && selector.isOpen();
started = true; started = true;
registerTaskQueue.offer(registerTask); boolean offered = registerTaskQueue.offer(registerTask);
assert offered;
} }
if (wakenUp.compareAndSet(false, true)) { if (wakenUp.compareAndSet(false, true)) {
@ -333,7 +334,8 @@ class NioWorker implements Runnable {
Thread workerThread = worker.thread; Thread workerThread = worker.thread;
if (workerThread == null || Thread.currentThread() != workerThread) { if (workerThread == null || Thread.currentThread() != workerThread) {
if (channel.writeTaskInTaskQueue.compareAndSet(false, true)) { if (channel.writeTaskInTaskQueue.compareAndSet(false, true)) {
worker.writeTaskQueue.offer(channel.writeTask); boolean offered = worker.writeTaskQueue.offer(channel.writeTask);
assert offered;
} }
Selector workerSelector = worker.selector; Selector workerSelector = worker.selector;
if (workerSelector != null) { if (workerSelector != null) {