parent: tidy up call_async() logging.
This commit is contained in:
parent
1f6c47554a
commit
8791d40081
|
@ -451,6 +451,9 @@ def _proxy_connect(name, method_name, kwargs, econtext):
|
||||||
|
|
||||||
|
|
||||||
class Argv(object):
|
class Argv(object):
|
||||||
|
"""
|
||||||
|
Wrapper to defer argv formatting when debug logging is disabled.
|
||||||
|
"""
|
||||||
def __init__(self, argv):
|
def __init__(self, argv):
|
||||||
self.argv = argv
|
self.argv = argv
|
||||||
|
|
||||||
|
@ -467,6 +470,38 @@ class Argv(object):
|
||||||
return ' '.join(map(self.escape, self.argv))
|
return ' '.join(map(self.escape, self.argv))
|
||||||
|
|
||||||
|
|
||||||
|
class CallSpec(object):
|
||||||
|
"""
|
||||||
|
Wrapper to defer call argument formatting when debug logging is disabled.
|
||||||
|
"""
|
||||||
|
def __init__(self, func, args, kwargs):
|
||||||
|
self.func = func
|
||||||
|
self.args = args
|
||||||
|
self.kwargs = kwargs
|
||||||
|
|
||||||
|
def _get_name(self):
|
||||||
|
return u'%s.%s' % (self.func.__module__,
|
||||||
|
self.func.__name__)
|
||||||
|
|
||||||
|
def _get_args(self):
|
||||||
|
return u', '.join(repr(a) for a in self.args)
|
||||||
|
|
||||||
|
def _get_kwargs(self):
|
||||||
|
s = u''
|
||||||
|
if self.kwargs:
|
||||||
|
s = u', '.join('%s=%r' % (k, v) for k, v in self.kwargs.items())
|
||||||
|
if self.args:
|
||||||
|
s = u', ' + s
|
||||||
|
return s
|
||||||
|
|
||||||
|
def __repr__(self):
|
||||||
|
return '%s(%s%s)' % (
|
||||||
|
self._get_name(),
|
||||||
|
self._get_args(),
|
||||||
|
self._get_kwargs(),
|
||||||
|
)
|
||||||
|
|
||||||
|
|
||||||
class KqueuePoller(mitogen.core.Poller):
|
class KqueuePoller(mitogen.core.Poller):
|
||||||
_repr = 'KqueuePoller()'
|
_repr = 'KqueuePoller()'
|
||||||
|
|
||||||
|
@ -949,8 +984,7 @@ class Context(mitogen.core.Context):
|
||||||
return hash((self.router, self.context_id))
|
return hash((self.router, self.context_id))
|
||||||
|
|
||||||
def call_async(self, fn, *args, **kwargs):
|
def call_async(self, fn, *args, **kwargs):
|
||||||
LOG.debug('%r.call_async(%r, *%r, **%r)',
|
LOG.debug('%r.call_async(): %r', self, CallSpec(fn, args, kwargs))
|
||||||
self, fn, args, kwargs)
|
|
||||||
return self.send_async(make_call_msg(fn, *args, **kwargs))
|
return self.send_async(make_call_msg(fn, *args, **kwargs))
|
||||||
|
|
||||||
def call(self, fn, *args, **kwargs):
|
def call(self, fn, *args, **kwargs):
|
||||||
|
|
Loading…
Reference in New Issue