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

Strict check

Browse Source
This commit is contained in:
Trustin Lee 2008-12-01 07:02:47 +00:00
parent 00c7fe36f4
commit 969effde28
1 changed files with 7 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

12
src/main/java/org/jboss/netty/group/DefaultChannelGroupFuture.java
View File

@ -73,9 +73,11 @@ public class DefaultChannelGroupFuture implements ChannelGroupFuture {
}
}
if (successCount + failureCount >= futures.size()) {
if (successCount + failureCount == futures.size()) {
setDone();
}
assert successCount + failureCount <= futures.size();
}
};
@ -132,19 +134,19 @@ public class DefaultChannelGroupFuture implements ChannelGroupFuture {
}
public synchronized boolean isCompleteSuccess() {
return successCount >= futures.size();
return successCount == futures.size();
}
public synchronized boolean isPartialSuccess() {
return successCount > 0;
return successCount != 0;
}
public synchronized boolean isPartialFailure() {
return failureCount > 0;
return failureCount != 0;
}
public synchronized boolean isCompleteFailure() {
return failureCount >= futures.size();
return failureCount == futures.size();
}
public void addListener(ChannelGroupFutureListener listener) {