close sockets on Mongo.close() - don't wait for gc

Author: erh

src/main/com/mongodb/DBPortPool.java

@@ -169,6 +169,10 @@ void close(){
         clear();
     }
 
+    public void cleanup( DBPort p ){
+        p.close();
+    }
+
     public boolean ok( DBPort t ){
         return _addr.equals( t._addr );
     }

src/main/com/mongodb/util/SimplePool.java

@@ -65,6 +65,11 @@ public boolean ok( T t ){
         return true;
     }
 
+    /**
+     * override this if you need to do any cleanup
+     */
+    public void cleanup( T t ){}
+
     /**
      * @return >= 0 the one to use, -1 don't use any
      */
@@ -107,6 +112,9 @@ void done( T t , boolean ok ){
                     _waiting.release();
                 }
             }
+            else {
+                cleanup( t );
+            }
         }
     }
 
@@ -223,10 +231,14 @@ private void _wherePrint(){
 
     /** Clears the pool of all objects. */
     protected void clear(){
-        _avail.clear();
-        _all.clear();
-        synchronized ( _where ){
-            _where.clear(); // is this correct
+        synchronized( _avail ){
+            for ( T t : _avail )
+                cleanup( t );
+            _avail.clear();
+            _all.clear();
+            synchronized ( _where ){
+                _where.clear(); // is this correct
+            }
         }
     }