From b6bb47ce7a62396f08e212e442e5936d64415cd7 Mon Sep 17 00:00:00 2001 From: dcy10000 Date: Thu, 23 Mar 2023 10:12:38 +0800 Subject: [PATCH] inner-2158:add connection create log info Signed-off-by: dcy10000 (cherry picked from commit 443f8550a36f5b5eec86db4d41ea58108e6f5c03) Signed-off-by: dcy10000 --- .../com/actiontech/dble/backend/pool/ConnectionPool.java | 5 ++++- 1 file changed, 4 insertions(+), 1 deletion(-) diff --git a/src/main/java/com/actiontech/dble/backend/pool/ConnectionPool.java b/src/main/java/com/actiontech/dble/backend/pool/ConnectionPool.java index 587f8e239..2dea67aa7 100644 --- a/src/main/java/com/actiontech/dble/backend/pool/ConnectionPool.java +++ b/src/main/java/com/actiontech/dble/backend/pool/ConnectionPool.java @@ -215,13 +215,13 @@ public class ConnectionPool extends PoolBase implements PooledConnectionListener public void onCreateSuccess(PooledConnection conn) { conn.setPoolRelated(this); allConnections.add(conn); + LOGGER.info("connection create success: createByWaiter:{},new connection:{}", conn.getCreateByWaiter().get(), conn); if (poolConfig.getTestOnCreate()) { ConnectionHeartBeatHandler heartBeatHandler = new ConnectionHeartBeatHandler((BackendConnection) conn, false, this); heartBeatHandler.ping(poolConfig.getConnectionHeartbeatTimeout()); return; } - LOGGER.debug("connection create success: createByWaiter:{},new connection:{}", conn.getCreateByWaiter().get(), conn); conn.lazySet(STATE_NOT_IN_USE); // spin until a thread takes it or none are waiting @@ -256,6 +256,9 @@ public class ConnectionPool extends PoolBase implements PooledConnectionListener @Override public void onHeartbeatSuccess(PooledConnection conn) { + if (LOGGER.isDebugEnabled()) { + LOGGER.debug("connection testOnCreate success: createByWaiter:{},connection:{}", conn.getCreateByWaiter().get(), conn); + } conn.lazySet(STATE_NOT_IN_USE); // spin until a thread takes it or none are waiting while (waiters.get() > 0 && conn.getState() == STATE_NOT_IN_USE && !handoffQueue.offer(conn)) {