bug fixed for poolingPeak

2023-03-04 19:17:16 +00:00 · 2012-08-23 11:36:46 +08:00
parent 66de5f3d3c
commit 415c445a67
1 changed files with 10 additions and 0 deletions
@@ -401,6 +401,11 @@ public class DruidDataSource extends DruidAbstractDataSource implements DruidDat
                    }
                    connections[poolingCount++] = new DruidConnectionHolder(this, conn);
                }
+                
+                if (poolingCount > 0) {
+                    poolingPeak = poolingCount;
+                    poolingPeakTime = System.currentTimeMillis();
+                }
            } catch (SQLException ex) {
                LOG.error("init datasource error", ex);
                connectError = ex;
@@ -931,6 +936,11 @@ public class DruidDataSource extends DruidAbstractDataSource implements DruidDat

        e.setLastActiveTimeMillis(System.currentTimeMillis());
        connections[poolingCount++] = e;
+        
+        if (poolingCount > poolingPeak) {
+            poolingPeak = poolingCount;
+            poolingPeakTime = System.currentTimeMillis();
+        }

        notEmpty.signal();
        notEmptySignalCount++;