Fixes #2536 - Broken ClientConnectTest.testConnectionTimeout_Concurrent.
Using try-with-resources to keep the Socket instance from being GCd before the test finishes. Signed-off-by: Simone Bordet <simone.bordet@gmail.com>
This commit is contained in:
parent
804b770581
commit
7a7aa0f1b1
|
@ -22,6 +22,7 @@ import java.net.ConnectException;
|
||||||
import java.net.InetAddress;
|
import java.net.InetAddress;
|
||||||
import java.net.InetSocketAddress;
|
import java.net.InetSocketAddress;
|
||||||
import java.net.ServerSocket;
|
import java.net.ServerSocket;
|
||||||
|
import java.net.Socket;
|
||||||
import java.net.SocketTimeoutException;
|
import java.net.SocketTimeoutException;
|
||||||
import java.net.URI;
|
import java.net.URI;
|
||||||
import java.util.concurrent.CompletableFuture;
|
import java.util.concurrent.CompletableFuture;
|
||||||
|
@ -476,16 +477,17 @@ public class ClientConnectTest
|
||||||
Future<Session> future = client.connect(wsocket, wsUri);
|
Future<Session> future = client.connect(wsocket, wsUri);
|
||||||
|
|
||||||
// Accept the connection, but do nothing on it (no response, no upgrade, etc)
|
// Accept the connection, but do nothing on it (no response, no upgrade, etc)
|
||||||
serverSocket.accept();
|
try (Socket socket = serverSocket.accept())
|
||||||
|
|
||||||
// The attempt to get upgrade response future should throw error
|
|
||||||
try
|
|
||||||
{
|
|
||||||
future.get(1, TimeUnit.SECONDS);
|
|
||||||
Assert.fail("Expected ExecutionException -> TimeoutException");
|
|
||||||
}
|
|
||||||
catch (TimeoutException expected)
|
|
||||||
{
|
{
|
||||||
|
// The attempt to get upgrade response future should throw error
|
||||||
|
try
|
||||||
|
{
|
||||||
|
future.get(1, TimeUnit.SECONDS);
|
||||||
|
Assert.fail("Expected ExecutionException -> TimeoutException");
|
||||||
|
}
|
||||||
|
catch (TimeoutException expected)
|
||||||
|
{
|
||||||
|
}
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
Loading…
Reference in New Issue