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

Streamline LinkedTransferQueue.isEmpty()

Browse Source
This commit is contained in:
Trustin Lee 2010-05-28 02:59:17 +00:00
parent 11705c9915
commit a2ef43cf3d
1 changed files with 6 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

7
src/main/java/org/jboss/netty/util/internal/LinkedTransferQueue.java
View File

@ -1241,7 +1241,12 @@ public class LinkedTransferQueue<E> extends AbstractQueue<E>
*/ */
@Override @Override
public boolean isEmpty() { public boolean isEmpty() {
return firstOfMode(true) == null; for (Node p = head; p != null; p = succ(p)) {
if (!p.isMatched()) {
return !p.isData;
}
}
return true;
} }
public boolean hasWaitingConsumer() { public boolean hasWaitingConsumer() {