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

fix: factory create connection check

dev
tanyawen 2019-12-30 14:58:40 +08:00
parent 9a9e1cf9f0
commit 4387b89026
1 changed files with 1 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -60,9 +60,7 @@ public class ConnectionManager {
} }
} else if (ClientGlobal.getG_connection_pool_max_count_per_entry() == 0 || totalCount.get() < ClientGlobal.getG_connection_pool_max_count_per_entry()) { } else if (ClientGlobal.getG_connection_pool_max_count_per_entry() == 0 || totalCount.get() < ClientGlobal.getG_connection_pool_max_count_per_entry()) {
connection = ConnectionFactory.create(this.inetSocketAddress); connection = ConnectionFactory.create(this.inetSocketAddress);
if (connection != null) { totalCount.incrementAndGet();
totalCount.incrementAndGet();
}
} else { } else {
try { try {
if (condition.await(ClientGlobal.getG_connection_pool_max_wait_time_in_ms(), TimeUnit.MILLISECONDS)) { if (condition.await(ClientGlobal.getG_connection_pool_max_wait_time_in_ms(), TimeUnit.MILLISECONDS)) {