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

Fix build failure

Browse Source
This commit is contained in:
Trustin Lee 2012-02-29 13:26:35 -08:00
parent 1589dadcce
commit c62b47228e
1 changed files with 2 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
transport/src/main/java/io/netty/channel/socket/ChannelRunnableWrapper.java
View File

@ -21,7 +21,7 @@ import io.netty.channel.DefaultChannelFuture;
public class ChannelRunnableWrapper extends DefaultChannelFuture implements Runnable { public class ChannelRunnableWrapper extends DefaultChannelFuture implements Runnable {
private final Runnable task; private final Runnable task;
private boolean started = false; private boolean started;
public ChannelRunnableWrapper(Channel channel, Runnable task) { public ChannelRunnableWrapper(Channel channel, Runnable task) {
super(channel, true); super(channel, true);
@ -30,7 +30,7 @@ public class ChannelRunnableWrapper extends DefaultChannelFuture implements Runn
@Override @Override
public void run() { public void run() {
synchronized(this) { synchronized (this) {
if (!isCancelled()) { if (!isCancelled()) {
started = true; started = true;
} else { } else {