From 7314b38168da53863136d1937059fc0ac4883a56 Mon Sep 17 00:00:00 2001 From: Jesse Noller Date: Wed, 21 Jan 2009 02:08:17 +0000 Subject: Issue 5009: multiprocessing: failure in manager._debug_info() --- Lib/multiprocessing/managers.py | 6 +++--- Lib/test/test_multiprocessing.py | 2 ++ 2 files changed, 5 insertions(+), 3 deletions(-) diff --git a/Lib/multiprocessing/managers.py b/Lib/multiprocessing/managers.py index f32dab1..02e96b9 100644 --- a/Lib/multiprocessing/managers.py +++ b/Lib/multiprocessing/managers.py @@ -136,7 +136,7 @@ class Server(object): self.listener = Listener(address=address, backlog=5) self.address = self.listener.address - self.id_to_obj = {0: (None, ())} + self.id_to_obj = {'0': (None, ())} self.id_to_refcount = {} self.mutex = threading.RLock() self.stop = 0 @@ -298,7 +298,7 @@ class Server(object): keys = self.id_to_obj.keys() keys.sort() for ident in keys: - if ident != 0: + if ident != '0': result.append(' %s: refcount=%s\n %s' % (ident, self.id_to_refcount[ident], str(self.id_to_obj[ident][0])[:75])) @@ -310,7 +310,7 @@ class Server(object): ''' Number of shared objects ''' - return len(self.id_to_obj) - 1 # don't count ident=0 + return len(self.id_to_obj) - 1 # don't count ident='0' def shutdown(self, c): ''' diff --git a/Lib/test/test_multiprocessing.py b/Lib/test/test_multiprocessing.py index d4ce4fa..33debfb 100644 --- a/Lib/test/test_multiprocessing.py +++ b/Lib/test/test_multiprocessing.py @@ -1057,8 +1057,10 @@ class _TestZZZNumberOfObjects(BaseTestCase): multiprocessing.active_children() # discard dead process objs gc.collect() # do garbage collection refs = self.manager._number_of_objects() + debug_info = self.manager._debug_info() if refs != EXPECTED_NUMBER: print self.manager._debug_info() + print debug_info self.assertEqual(refs, EXPECTED_NUMBER) -- cgit v0.12