From cce3a8f7e44747eb044e30ba58ca427f9725f875 Mon Sep 17 00:00:00 2001
From: wenshao <szujobs@hotmail.com>
Date: Sun, 25 Sep 2011 02:33:53 +0000
Subject: [PATCH] =?UTF-8?q?=E6=B7=BB=E5=8A=A0=E7=9B=91=E6=8E=A7?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

git-svn-id: http://code.alibabatech.com/svn/druid/trunk@902 b9813039-fb51-4c41-a8b9-e21c2acb5095
---
 .../java/com/alibaba/druid/pool/DruidDataSource.java   | 10 ++++++++++
 .../com/alibaba/druid/pool/DruidDataSourceMBean.java   |  2 +-
 2 files changed, 11 insertions(+), 1 deletion(-)

diff --git a/src/main/java/com/alibaba/druid/pool/DruidDataSource.java b/src/main/java/com/alibaba/druid/pool/DruidDataSource.java
index 05ee7ae385..c6d83aed2b 100644
--- a/src/main/java/com/alibaba/druid/pool/DruidDataSource.java
+++ b/src/main/java/com/alibaba/druid/pool/DruidDataSource.java
@@ -87,6 +87,7 @@ public class DruidDataSource extends DruidAbstractDataSource implements DruidDat
     private int                     poolingCount            = 0;
     private int                     activeCount             = 0;
     private int                     notEmptyWaitThreadCount = 0;
+    private int                     activePeak              = 0;
 
     // threads
     private CreateConnectionThread  createConnectionThread;
@@ -126,6 +127,8 @@ public class DruidDataSource extends DruidAbstractDataSource implements DruidDat
             notEmptyWaitCount = 0;
             notEmptySignalCount = 0L;
             notEmptyWaitNanos = 0;
+            
+            activePeak = 0;
         } finally {
             lock.unlock();
         }
@@ -412,6 +415,9 @@ public class DruidDataSource extends DruidAbstractDataSource implements DruidDat
 
             holder.incrementUseCount();
             activeCount++;
+            if (activeCount > activePeak) {
+                activePeak = activeCount;
+            }
 
             poolalbeConnection = new PoolableConnection(holder);
         } catch (InterruptedException e) {
@@ -1038,6 +1044,10 @@ public class DruidDataSource extends DruidAbstractDataSource implements DruidDat
     public int getLockQueueLength() {
         return lock.getQueueLength();
     }
+    
+    public int getActivePeak() {
+        return activePeak;
+    }
 
     public String dump() {
         lock.lock();
diff --git a/src/main/java/com/alibaba/druid/pool/DruidDataSourceMBean.java b/src/main/java/com/alibaba/druid/pool/DruidDataSourceMBean.java
index 8c2c1a473e..d63c9a6168 100644
--- a/src/main/java/com/alibaba/druid/pool/DruidDataSourceMBean.java
+++ b/src/main/java/com/alibaba/druid/pool/DruidDataSourceMBean.java
@@ -51,5 +51,5 @@ public interface DruidDataSourceMBean extends DruidAbstractDataSourceMBean {
 
     String getVersion();
 
-
+    int getActivePeak();
 }