Allow connection pool to grow

Author: rPraml

ebean-datasource/src/main/java/io/ebean/datasource/pool/ConnectionBuffer.java

@@ -120,6 +120,8 @@
  */
 final class ConnectionBuffer {
 
+  static final Object POP_LAST = new Object();
+
   private final Node free = Node.init();
   private final Node freeEnd = free.next;
   private final Node busy = Node.init();
@@ -218,13 +220,14 @@ PooledConnection popFree(Object affinityId) {
     Node node;
     if (affinityId == null || affinityNodes == null) {
       node = free.next;
+    } else if (affinityId == POP_LAST) {
+      node = freeEnd.prev;
     } else {
       node = affinityNodes[affinityId.hashCode() % hashSize].find(affinityId);
       if (node == null) {
-        // when we did not find a node with that affinity, we take the last (oldest one)
-        // and reuse this with the new affinity. This avoids to "steal" the affinity
-        // from the newest one.
-        node = freeEnd.prev;
+        // when we did not find a node with that affinity, we return null
+        // this allows the pool to grow to its maximum size
+        return null;
       }
     }
     if (node.isBoundaryNode()) {

ebean-datasource/src/main/java/io/ebean/datasource/pool/PooledConnectionQueue.java

@@ -231,13 +231,19 @@ private PooledConnection _obtainConnection(Object affinitiyId) throws Interrupte
         if (connection != null) {
           return connection;
         }
+        if (affinitiyId != null) {
+          connection = extractFromFreeList(ConnectionBuffer.POP_LAST);
+          if (connection != null) {
+            return connection;
+          }
+        }
       }
       try {
         // The pool is at maximum size. We are going to go into
         // a wait loop until connections are returned into the pool.
         waitCount++;
         waitingThreads++;
-        return _obtainConnectionWaitLoop(affinitiyId);
+        return _obtainConnectionWaitLoop(null);
       } finally {
         waitingThreads--;
       }