Lines Matching defs:util
28 from . import util
116 util.debug('worker got EOFError or OSError -- exiting')
120 util.debug('worker got sentinel -- exiting')
134 util.debug("Possible encoding error while sending result: %s" % (
140 util.debug('worker exiting after %d tasks' % completed)
255 self._terminate = util.Finalize(
299 util.debug('cleaning up worker %d' % i)
331 util.debug('added worker')
525 util.debug('worker handler exiting')
537 util.debug('task handler found thread._state != RUN')
549 util.debug('doing set_length()')
557 util.debug('task handler got sentinel')
561 util.debug('task handler sending sentinel to result handler')
565 util.debug('task handler sending sentinel to workers')
569 util.debug('task handler got OSError when sending sentinels')
571 util.debug('task handler exiting')
581 util.debug('result handler got EOFError/OSError -- exiting')
586 util.debug('result handler found thread._state=TERMINATE')
590 util.debug('result handler got sentinel')
604 util.debug('result handler got EOFError/OSError -- exiting')
608 util.debug('result handler ignoring extra sentinel')
618 util.debug('ensuring that outqueue is not full')
630 util.debug('result handler exiting: len(cache)=%s, thread._state=%s',
648 util.debug('closing pool')
655 util.debug('terminating pool')
660 util.debug('joining pool')
674 util.debug('removing tasks from inqueue until task handler finished')
684 util.debug('finalizing pool')
694 util.debug('helping task handler/workers to finish')
707 util.debug('joining worker handler')
713 util.debug('terminating workers')
718 util.debug('joining task handler')
722 util.debug('joining result handler')
727 util.debug('joining pool workers')
731 util.debug('cleaning up worker %d' % p.pid)