2929# !mitogen: minify_safe
3030
3131import grp
32+ import logging
3233import os
3334import os .path
3435import pprint
4142import mitogen .core
4243import mitogen .select
4344from mitogen .core import b
44- from mitogen .core import LOG
4545from mitogen .core import str_rpartition
4646
4747try :
@@ -54,6 +54,8 @@ def all(it):
5454 return True
5555
5656
57+ LOG = logging .getLogger (__name__ )
58+
5759DEFAULT_POOL_SIZE = 16
5860_pool = None
5961_pool_pid = None
@@ -501,7 +503,7 @@ def __init__(self, router, services=(), size=1, overwrite=False):
501503 self ._py_24_25_compat ()
502504 self ._threads = []
503505 for x in range (size ):
504- name = 'mitogen.service. Pool.%x.worker- %d' % (id (self ), x ,)
506+ name = 'mitogen.Pool.%04x. %d' % (id (self ) & 0xffff , x ,)
505507 thread = threading .Thread (
506508 name = name ,
507509 target = mitogen .core ._profile_hook ,
@@ -608,9 +610,11 @@ def _worker_run(self):
608610 while not self .closed :
609611 try :
610612 event = self ._select .get_event ()
611- except (mitogen .core .ChannelError , mitogen .core .LatchError ):
612- e = sys .exc_info ()[1 ]
613- LOG .debug ('%r: channel or latch closed, exitting: %s' , self , e )
613+ except mitogen .core .LatchError :
614+ LOG .debug ('%r: graceful exit' , self )
615+ return
616+ except mitogen .core .ChannelError :
617+ LOG .debug ('%r: exitting: %s' , self , sys .exc_info ()[1 ])
614618 return
615619
616620 func = self ._func_by_source [event .source ]
@@ -629,8 +633,8 @@ def _worker_main(self):
629633
630634 def __repr__ (self ):
631635 th = threading .currentThread ()
632- return 'mitogen.service. Pool(%#x , size=%d, th=%r)' % (
633- id (self ),
636+ return 'Pool(%04x , size=%d, th=%r)' % (
637+ id (self ) & 0xffff ,
634638 len (self ._threads ),
635639 th .getName (),
636640 )
0 commit comments