From 27489f610cd8e278461e8f823f81a04dacd977d3 Mon Sep 17 00:00:00 2001 From: Kovid Goyal Date: Sun, 9 Nov 2014 12:47:16 +0530 Subject: [PATCH] ... --- src/calibre/utils/ipc/pool.py | 4 ++++ 1 file changed, 4 insertions(+) diff --git a/src/calibre/utils/ipc/pool.py b/src/calibre/utils/ipc/pool.py index 3a8714c120..04c27867fa 100644 --- a/src/calibre/utils/ipc/pool.py +++ b/src/calibre/utils/ipc/pool.py @@ -291,9 +291,13 @@ def test(): for i in range(1000): p(i, 'def x(i):\n return 1/0', 'x', i) p.wait_for_tasks(30) + c = 0 for r in get_results(p).itervalues(): + c += 1 if not r.traceback or 'ZeroDivisionError' not in r.traceback: raise SystemExit('Unexpected result: %s' % r) + if c != 1000: + raise SystemExit('Incorrect number of results') p.shutdown(), p.join() # Test worker crash