diff --git a/src/main/java/org/csource/fastdfs/pool/ConnectionManager.java b/src/main/java/org/csource/fastdfs/pool/ConnectionManager.java index fd2c894..fa76798 100644 --- a/src/main/java/org/csource/fastdfs/pool/ConnectionManager.java +++ b/src/main/java/org/csource/fastdfs/pool/ConnectionManager.java @@ -66,6 +66,7 @@ public class ConnectionManager { isActive = false; } if (!isActive) { + closeConnection(connection); continue; } else { connection.setNeedActiveTest(false);