Skip to content

Commit a142b64

Browse files
committed
feat: update sql proxy offline log
1 parent fd6cbc5 commit a142b64

File tree

1 file changed

+4
-2
lines changed

1 file changed

+4
-2
lines changed

lb-driver/src/main/java/com/netease/nim/lbd/ConnectionManager.java

Lines changed: 4 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -545,8 +545,10 @@ private void removeSqlProxy(List<SqlProxy> list) {
545545
continue;
546546
}
547547
//标记下线
548-
pool.setOffline();
549-
logger.info("sql proxy = {} offline", sqlProxy);
548+
if (pool.isOnline()) {
549+
pool.setOffline();
550+
logger.info("sql proxy = {} offline", sqlProxy);
551+
}
550552
//直接关闭空闲连接
551553
while (true) {
552554
RealConnection connection2Close = pool.getConnection2Close();

0 commit comments

Comments
 (0)