You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@iotdb.apache.org by hx...@apache.org on 2020/03/03 17:54:42 UTC
[incubator-iotdb] 02/02: add a simple connection pool for session
api
This is an automated email from the ASF dual-hosted git repository.
hxd pushed a commit to branch simple_pool
in repository https://gitbox.apache.org/repos/asf/incubator-iotdb.git
commit 779dd275acd330bcc9cbf4393109cb77b5ee23a0
Author: xiangdong huang <sa...@gmail.com>
AuthorDate: Wed Mar 4 01:54:09 2020 +0800
add a simple connection pool for session api
---
session/src/main/java/org/apache/iotdb/session/pool/SessionPool.java | 1 +
1 file changed, 1 insertion(+)
diff --git a/session/src/main/java/org/apache/iotdb/session/pool/SessionPool.java b/session/src/main/java/org/apache/iotdb/session/pool/SessionPool.java
index 5956dfe..c2218fc 100644
--- a/session/src/main/java/org/apache/iotdb/session/pool/SessionPool.java
+++ b/session/src/main/java/org/apache/iotdb/session/pool/SessionPool.java
@@ -93,6 +93,7 @@ public class SessionPool {
private int fetchSize;
//if this method throws an exception, either the server is broken, or the ip/port/user/password is incorrect.
+ //TODO: we can add a mechanism that if the user waits too long time, throw exception.
private Session getSession() throws IoTDBSessionException {
Session session = queue.poll();
if (session != null) {