ChannelManager.preemptChannel should release global semaphore if tryA…

…cquirePerHost fails, close #805
AsyncHttpClient · Jan 15, 2015 · 8c0ad2a · 8c0ad2a
1 parent 29a76ec
commit 8c0ad2a
Showing 1 changed file with 5 additions and 1 deletion.
diff --git a/src/main/java/com/ning/http/client/providers/netty/channel/ChannelManager.java b/src/main/java/com/ning/http/client/providers/netty/channel/ChannelManager.java
@@ -329,8 +329,12 @@ public void preemptChannel(String poolKey) throws IOException {
             throw poolAlreadyClosed;
         if (!tryAcquireGlobal())
             throw tooManyConnections;
-        if (!tryAcquirePerHost(poolKey))
+        if (!tryAcquirePerHost(poolKey)) {
+            if (maxTotalConnectionsEnabled)
+                freeChannels.release();
+
             throw tooManyConnectionsPerHost;
+        }
     }
 
     public void close() {