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

[#2086] Fix race which could produce NPE in AbstractNioUnsafe.finishConnect

Browse Source
This commit is contained in:
Norman Maurer 2014-01-09 08:22:34 +01:00
parent 393f7b2306
commit 0bbc3facec
1 changed files with 7 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

9
transport/src/main/java/io/netty/channel/nio/AbstractNioChannel.java
View File

@ -236,10 +236,15 @@ public abstract class AbstractNioChannel extends AbstractChannel {
assert eventLoop().inEventLoop();
assert connectPromise != null;
// Cache connect promise as connectPromise will be set to null once it is notified.
// This is needed to prevent a possible NPE
// See https://github.com/netty/netty/issues/2086
ChannelPromise promise = connectPromise;
try {
boolean wasActive = isActive();
doFinishConnect();
fulfillConnectPromise(connectPromise, wasActive);
fulfillConnectPromise(promise, wasActive);
} catch (Throwable t) {
if (t instanceof ConnectException) {
Throwable newT = new ConnectException(t.getMessage() + ": " + requestedRemoteAddress);
@ -248,7 +253,7 @@ public abstract class AbstractNioChannel extends AbstractChannel {
}
// Use tryFailure() instead of setFailure() to avoid the race against cancel().
connectPromise.tryFailure(t);
promise.tryFailure(t);
closeIfClosed();
} finally {
// Check for null as the connectTimeoutFuture is only created if a connectTimeoutMillis > 0 is used