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

fix: pool throw exceptipn

dev
tanyawen 2019-12-29 09:18:23 +08:00
parent 32167310dd
commit 31ad07bae8
2 changed files with 5 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -55,7 +55,7 @@ public class ConnectionManager {
} }
public Connection getConnection() throws MyException { public Connection getConnection() throws MyException, IOException {
lock.lock(); lock.lock();
try { try {
Connection connection = null; Connection connection = null;
@ -81,13 +81,14 @@ public class ConnectionManager {
throw new MyException("get connection fail, wait_time greater than " + ClientGlobal.g_connection_pool_max_wait_time_in_ms + "ms"); throw new MyException("get connection fail, wait_time greater than " + ClientGlobal.g_connection_pool_max_wait_time_in_ms + "ms");
} catch (InterruptedException e) { } catch (InterruptedException e) {
e.printStackTrace(); e.printStackTrace();
throw new MyException("get connection fail, emsg > " + e.getMessage()); throw new MyException("get connection fail, emsg:" + e.getMessage());
} }
} }
return connection; return connection;
} }
} catch (IOException e) { } catch (IOException e) {
return null; System.err.println("get connection ERROR , emsg:" + e.getMessage());
throw e;
} finally { } finally {
lock.unlock(); lock.unlock();
} }

2
src/main/java/org/csource/fastdfs/pool/ConnectionPool.java
View File

@ -13,7 +13,7 @@ public class ConnectionPool {
*/ */
private final static ConcurrentHashMap<String, ConnectionManager> CP = new ConcurrentHashMap<String, ConnectionManager>(); private final static ConcurrentHashMap<String, ConnectionManager> CP = new ConcurrentHashMap<String, ConnectionManager>();
public static Connection getConnection(InetSocketAddress socketAddress) throws MyException { public static Connection getConnection(InetSocketAddress socketAddress) throws MyException, IOException {
if (socketAddress == null) { if (socketAddress == null) {
return null; return null;
} }