From a1c95544cbb63b9dea60ff2eefea272d8c456735 Mon Sep 17 00:00:00 2001
From: Redkale <8730487+redkale@users.noreply.github.com>
Date: Fri, 15 Nov 2019 15:19:16 +0800
Subject: [PATCH]

---
 src/org/redkale/source/PoolTcpSource.java | 12 +++++++++---
 1 file changed, 9 insertions(+), 3 deletions(-)

diff --git a/src/org/redkale/source/PoolTcpSource.java b/src/org/redkale/source/PoolTcpSource.java
index e54a0c01c..bbbe92464 100644
--- a/src/org/redkale/source/PoolTcpSource.java
+++ b/src/org/redkale/source/PoolTcpSource.java
@@ -68,11 +68,17 @@ public abstract class PoolTcpSource extends PoolSource<AsyncConnection> {
             long time = System.currentTimeMillis() - 30 * 1000;
             pollAsync().whenComplete((conn, e) -> {
                 if (e != null) return;
-                if (conn.getLastReadTime() >= time || conn.getLastWriteTime() >= time) return; //半分钟内已经用过
+                if (conn.getLastReadTime() >= time || conn.getLastWriteTime() >= time) {//半分钟内已经用过
+                    offerConnection(conn);
+                    return;
+                }
                 CompletableFuture<AsyncConnection> future = sendPingCommand(conn);
-                if (future == null) return; //不支持ping
+                if (future == null) {     //不支持ping                
+                    offerConnection(conn);
+                    return;
+                }
                 future.whenComplete((conn2, e2) -> {
-                    if (e != null) return;
+                    if (e2 != null) return;
                     offerConnection(conn2);
                     runPingTask();
                 });