Lines Matching defs:debug
48 from multiprocessing.util import Finalize, debug
104 debug('worker got EOFError or IOError -- exiting')
108 debug('worker got sentinel -- exiting')
120 debug("Possible encoding error while sending result: %s" % (
124 debug('worker exiting after %d tasks' % completed)
203 debug('cleaning up worker %d' % i)
223 debug('added worker')
329 debug('worker handler exiting')
339 debug('task handler found thread._state != RUN')
344 debug('could not put task on queue')
348 debug('doing set_length()')
353 debug('task handler got sentinel')
358 debug('task handler sending sentinel to result handler')
362 debug('task handler sending sentinel to workers')
366 debug('task handler got IOError when sending sentinels')
368 debug('task handler exiting')
378 debug('result handler got EOFError/IOError -- exiting')
383 debug('result handler found thread._state=TERMINATE')
387 debug('result handler got sentinel')
400 debug('result handler got EOFError/IOError -- exiting')
404 debug('result handler ignoring extra sentinel')
413 debug('ensuring that outqueue is not full')
425 debug('result handler exiting: len(cache)=%s, thread._state=%s',
443 debug('closing pool')
449 debug('terminating pool')
455 debug('joining pool')
466 debug('removing tasks from inqueue until task handler finished')
476 debug('finalizing pool')
481 debug('helping task handler/workers to finish')
491 debug('joining worker handler')
497 debug('terminating workers')
502 debug('joining task handler')
506 debug('joining result handler')
511 debug('joining pool workers')
515 debug('cleaning up worker %d' % p.pid)
