issue #477: 2.4.x compat fixes for mitogen.service.

issue510
David Wilson 7 years ago
parent 58d8813c03
commit d8490bc90a

@ -40,6 +40,7 @@ import mitogen.core
import mitogen.select import mitogen.select
from mitogen.core import b from mitogen.core import b
from mitogen.core import LOG from mitogen.core import LOG
from mitogen.core import unicode__rpartition
try: try:
all all
@ -201,7 +202,7 @@ class Activator(object):
) )
def activate(self, pool, service_name, msg): def activate(self, pool, service_name, msg):
mod_name, _, class_name = service_name.rpartition('.') mod_name, _, class_name = unicode__rpartition(service_name, '.')
if msg and not self.is_permitted(mod_name, class_name, msg): if msg and not self.is_permitted(mod_name, class_name, msg):
raise mitogen.core.CallError(self.not_active_msg, service_name) raise mitogen.core.CallError(self.not_active_msg, service_name)
@ -565,7 +566,7 @@ class Pool(object):
self._worker_run() self._worker_run()
except Exception: except Exception:
th = threading.currentThread() th = threading.currentThread()
LOG.exception('%r: worker %r crashed', self, th.name) LOG.exception('%r: worker %r crashed', self, th.getName())
raise raise
def __repr__(self): def __repr__(self):
@ -573,7 +574,7 @@ class Pool(object):
return 'mitogen.service.Pool(%#x, size=%d, th=%r)' % ( return 'mitogen.service.Pool(%#x, size=%d, th=%r)' % (
id(self), id(self),
len(self._threads), len(self._threads),
th.name, th.getName(),
) )

Loading…
Cancel
Save