Commit 63b3a97a authored by Jesse Noller's avatar Jesse Noller

merge r68839 forward to py3k

parent 08838b6a
......@@ -139,7 +139,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
......@@ -301,7 +301,7 @@ class Server(object):
keys = list(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]))
......@@ -313,7 +313,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):
'''
......
......@@ -1058,8 +1058,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)
......
Markdown is supported
0%
or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment