ZhouXY108/fastdfs-client-java
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

fix:active test flag

Browse Source
This commit is contained in:
tanyawen 2019-12-31 15:32:48 +08:00
parent f742f3c6aa
commit bb13294205
1 changed files with 5 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
src/main/java/org/csource/fastdfs/pool/ConnectionManager.java
View File

@ -65,7 +65,11 @@ public class ConnectionManager {
System.err.println("send to server[" + inetSocketAddress.getAddress().getHostAddress() + ":" + inetSocketAddress.getPort() + "] active test error ,emsg:" + e.getMessage()); System.err.println("send to server[" + inetSocketAddress.getAddress().getHostAddress() + ":" + inetSocketAddress.getPort() + "] active test error ,emsg:" + e.getMessage());
isActive = false; isActive = false;
} }
if (!isActive) continue; if (!isActive) {
continue;
} else {
connection.setNeedActiveTest(false);
}
} }
} else if (ClientGlobal.g_connection_pool_max_count_per_entry == 0 || totalCount.get() < ClientGlobal.g_connection_pool_max_count_per_entry) { } else if (ClientGlobal.g_connection_pool_max_count_per_entry == 0 || totalCount.get() < ClientGlobal.g_connection_pool_max_count_per_entry) {
connection = ConnectionFactory.create(this.inetSocketAddress); connection = ConnectionFactory.create(this.inetSocketAddress);