[Neo-report] r2831 jm - in /trunk/neo: storage/ storage/database/ tests/threaded/

[nobody at svn.erp5.org]

Author: jm
Date: Wed Sep  7 17:13:58 2011
New Revision: 2831

Log:
More resource leak fixes

Modified:
    trunk/neo/storage/app.py
    trunk/neo/storage/database/manager.py
    trunk/neo/tests/threaded/__init__.py

Modified: trunk/neo/storage/app.py
==============================================================================
--- trunk/neo/storage/app.py [iso-8859-1] (original)
+++ trunk/neo/storage/app.py [iso-8859-1] Wed Sep  7 17:13:58 2011
@@ -92,6 +92,8 @@ class Application(object):
         self.listening_conn = None
         self.nm.close()
         self.em.close()
+        if self.dm is not None:
+            self.dm.close()
         del self.__dict__
 
     def _poll(self):

Modified: trunk/neo/storage/database/manager.py
==============================================================================
--- trunk/neo/storage/database/manager.py [iso-8859-1] (original)
+++ trunk/neo/storage/database/manager.py [iso-8859-1] Wed Sep  7 17:13:58 2011
@@ -30,6 +30,9 @@ class DatabaseManager(object):
         """
         self._under_transaction = False
 
+    def close(self):
+        pass
+
     def isUnderTransaction(self):
         return self._under_transaction
 

Modified: trunk/neo/tests/threaded/__init__.py
==============================================================================
--- trunk/neo/tests/threaded/__init__.py [iso-8859-1] (original)
+++ trunk/neo/tests/threaded/__init__.py [iso-8859-1] Wed Sep  7 17:13:58 2011
@@ -418,7 +418,7 @@ class NEOCluster(object):
             for node in getattr(self, node_type + '_list'):
                 node.resetNode(**kw)
         self.client = ClientApplication(self)
-        self.neoctl = NeoCTL(self)
+        self.neoctl = NeoCTL(weakref.proxy(self))
 
     def start(self, storage_list=None, fast_startup=True):
         self._patch()