diff --git a/jetty-client/src/main/java/org/eclipse/jetty/client/AbstractConnectionPool.java b/jetty-client/src/main/java/org/eclipse/jetty/client/AbstractConnectionPool.java index 15470cc0794..ac2b806ffa8 100644 --- a/jetty-client/src/main/java/org/eclipse/jetty/client/AbstractConnectionPool.java +++ b/jetty-client/src/main/java/org/eclipse/jetty/client/AbstractConnectionPool.java @@ -132,10 +132,9 @@ public abstract class AbstractConnectionPool implements ConnectionPool, Dumpable protected Connection acquire(boolean create) { Connection connection = activate(); - if (connection == null) + if (connection == null && create) { - if (create) - tryCreate(destination.getQueuedRequestCount()); + tryCreate(destination.getQueuedRequestCount()); connection = activate(); } return connection; diff --git a/jetty-http2/http2-http-client-transport/src/test/java/org/eclipse/jetty/http2/client/http/MaxConcurrentStreamsTest.java b/jetty-http2/http2-http-client-transport/src/test/java/org/eclipse/jetty/http2/client/http/MaxConcurrentStreamsTest.java index 718a6b08d6e..e294d1c9585 100644 --- a/jetty-http2/http2-http-client-transport/src/test/java/org/eclipse/jetty/http2/client/http/MaxConcurrentStreamsTest.java +++ b/jetty-http2/http2-http-client-transport/src/test/java/org/eclipse/jetty/http2/client/http/MaxConcurrentStreamsTest.java @@ -176,6 +176,7 @@ public class MaxConcurrentStreamsTest extends AbstractTest @Override public void onSettings(Session session, SettingsFrame frame) { + super.onSettings(session, frame); // Send another request to simulate a request being // sent concurrently with connection establishment. // Sending this request will trigger the creation of @@ -200,7 +201,6 @@ public class MaxConcurrentStreamsTest extends AbstractTest } }); } - super.onSettings(session, frame); } }, promise, context); }