brianc · Jan 11, 2013 · Jan 11, 2013
Showing with 19 additions and 1 deletion.

+1 −0 .gitignore

+18 −1 lib/index.js
diff --git a/.gitignore b/.gitignore
@@ -3,3 +3,4 @@ node_modules/
 *.log
 .lock-wscript
 build/
+.DS_Store
diff --git a/lib/index.js b/lib/index.js
@@ -42,11 +42,15 @@ PG.prototype.connect = function(config, callback) {
   var poolName = typeof(c) === 'string' ? c : c.user+c.host+c.port+c.database;
   var pool = pools[poolName];
 
-  if(pool) return pool.acquire(cb);
+  if(pool) {
+    // console.log("pg: pool:", pool.getName(), pool.getPoolSize(), pool.availableObjectsCount(), pool.waitingClientsCount());
+    return pool.acquire(cb);
+  }
 
   var pool = pools[poolName] = genericPool.Pool({
     name: poolName,
     create: function(callback) {
+      // console.log("pg: create connection");
       var client = new self.Client(c);
       client.connect(function(err) {
         if(err) return callback(err);
@@ -66,6 +70,7 @@ PG.prototype.connect = function(config, callback) {
       });
     },
     destroy: function(client) {
+      // console.log("pg: destroy connection");
       client.end();
     },
     max: defaults.poolSize,
@@ -95,3 +100,15 @@ module.exports.__defineGetter__("native", function() {
 });
 
 module.exports.types = require('./types');
+
+module.exports.stats = function(config) {
+  var pool = pools[config];
+  if (pool) {
+    return {
+      size: pool.getPoolSize(),
+      available: pool.availableObjectsCount(),
+      waiting: pool.waitingClientsCount()
+    }
+  }
+  return null;
+}
-Original file line number
+Diff line change
@@ @@ -3,3 +3,4 @@ node_modules/ @@
     *.log
     .lock-wscript
     build/
+    .DS_Store