From e8dacd6b70e911b5a8ad443443ac317db5748b16 Mon Sep 17 00:00:00 2001
From: Redkale <22250530@qq.com>
Date: Sun, 15 Jul 2018 18:11:30 +0800
Subject: [PATCH]

---
 src/org/redkale/source/PoolTcpSource.java | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)

diff --git a/src/org/redkale/source/PoolTcpSource.java b/src/org/redkale/source/PoolTcpSource.java
index e75ce2033..dc71d21f5 100644
--- a/src/org/redkale/source/PoolTcpSource.java
+++ b/src/org/redkale/source/PoolTcpSource.java
@@ -102,7 +102,7 @@ public abstract class PoolTcpSource extends PoolSource<AsyncConnection> {
     }
 
     protected CompletableFuture<AsyncConnection> pollAsync(final int count) {
-        if (count >= 3) {
+        if (count >= 5) {
             logger.log(Level.WARNING, "create datasource connection error");
             CompletableFuture<AsyncConnection> future = new CompletableFuture<>();
             future.completeExceptionally(new SQLException("create datasource connection error"));
@@ -119,7 +119,7 @@ public abstract class PoolTcpSource extends PoolSource<AsyncConnection> {
         if (!semaphore.tryAcquire()) {
             return CompletableFuture.supplyAsync(() -> {
                 try {
-                    return connQueue.poll(3, TimeUnit.SECONDS);
+                    return connQueue.poll(1, TimeUnit.SECONDS);
                 } catch (Exception t) {
                     return null;
                 }