tests: fix potential resource leak in PortAllocator

git-svn-id: https://svn.erp5.org/repos/neo/trunk@2666 71dcc9de-d417-0410-9af5-da40c76e7ee4

neo/tests/functional/__init__.py

@@ -57,7 +57,7 @@ class NotFound(Exception):
 class PortAllocator(object):
 
     lock = SocketLock('neo.PortAllocator')
-    allocator_set = set()
+    allocator_set = weakref.WeakKeyDictionary() # BBB: use WeakSet instead
 
     def __init__(self):
         self.socket_list = []
@@ -67,7 +67,7 @@ class PortAllocator(object):
         s.setsockopt(socket.SOL_SOCKET, socket.SO_REUSEADDR, 1)
         if not self.lock.locked():
             self.lock.acquire()
-        self.allocator_set.add(self)
+        self.allocator_set[self] = None
         self.socket_list.append(s)
         s.bind((local_ip, 0))
         return s.getsockname()[1]
@@ -79,7 +79,7 @@ class PortAllocator(object):
 
     def reset(self):
         if self.lock.locked():
-            self.allocator_set.discard(self)
+            self.allocator_set.pop(self, None)
             if not self.allocator_set:
                 self.lock.release()
             if self.socket_list:
@@ -87,6 +87,8 @@ class PortAllocator(object):
                     s.close()
             self.__init__()
 
+    __del__ = reset
+
 class NEOProcess(object):
     pid = 0
 
@@ -605,10 +607,6 @@ class NEOCluster(object):
     def __del__(self):
         if self.cleanup_on_delete:
             os.removedirs(self.temp_dir)
-        try:
-            self.port_allocator.reset()
-        except AttributeError:
-            pass
 
 
 class NEOFunctionalTest(NeoTestBase):