Fixed a problem where AbstractSocketSslEchoTest doesn't close all channels when a connection attempt fails.
This commit is contained in:
parent
feac0d6a3d
commit
0e3679e919
@ -148,7 +148,12 @@ public abstract class AbstractSocketSslEchoTest {
|
|||||||
int port = ((InetSocketAddress) sc.getLocalAddress()).getPort();
|
int port = ((InetSocketAddress) sc.getLocalAddress()).getPort();
|
||||||
|
|
||||||
ChannelFuture ccf = cb.connect(new InetSocketAddress(InetAddress.getLocalHost(), port));
|
ChannelFuture ccf = cb.connect(new InetSocketAddress(InetAddress.getLocalHost(), port));
|
||||||
assertTrue(ccf.awaitUninterruptibly().isSuccess());
|
ccf.awaitUninterruptibly();
|
||||||
|
if (!ccf.isSuccess()) {
|
||||||
|
logger.error("Connection attempt failed", ccf.getCause());
|
||||||
|
sc.close().awaitUninterruptibly();
|
||||||
|
}
|
||||||
|
assertTrue(ccf.isSuccess());
|
||||||
|
|
||||||
Channel cc = ccf.getChannel();
|
Channel cc = ccf.getChannel();
|
||||||
ChannelFuture hf = cc.getPipeline().get(SslHandler.class).handshake(cc);
|
ChannelFuture hf = cc.getPipeline().get(SslHandler.class).handshake(cc);
|
||||||
|
Loading…
Reference in New Issue
Block a user