[#1885] Correctly close leak detected also on non started HashedWheelTimer

2013-10-02 06:44:55 +02:00 · 2013-10-02 06:44:55 +02:00 · 3739ee90cf
commit 3739ee90cf
parent ee192f0321
1 changed files with 5 additions and 0 deletions
--- a/common/src/main/java/io/netty/util/HashedWheelTimer.java
+++ b/common/src/main/java/io/netty/util/HashedWheelTimer.java
@ -273,6 +273,11 @@ public class HashedWheelTimer implements Timer {
        if (!workerState.compareAndSet(WORKER_STATE_STARTED, WORKER_STATE_SHUTDOWN)) {
            // workerState can be 0 or 2 at this moment - let it always be 2.
            workerState.set(WORKER_STATE_SHUTDOWN);
+
+            if (leak != null) {
+                leak.close();
+            }
+
            return Collections.emptySet();
        }