|
|
|
@ -346,11 +346,21 @@ class LogForwarder(object):
|
|
|
|
|
self._cache[msg.src_id] = logger = logging.getLogger(name)
|
|
|
|
|
|
|
|
|
|
name, level_s, s = msg.data.decode('latin1').split('\x00', 2)
|
|
|
|
|
logger.log(int(level_s), '%s: %s', name, s, extra={
|
|
|
|
|
'mitogen_message': s,
|
|
|
|
|
'mitogen_context': self._router.context_by_id(msg.src_id),
|
|
|
|
|
'mitogen_name': name,
|
|
|
|
|
})
|
|
|
|
|
|
|
|
|
|
# See logging.Handler.makeRecord()
|
|
|
|
|
record = logging.LogRecord(
|
|
|
|
|
name=logger.name,
|
|
|
|
|
level=int(level_s),
|
|
|
|
|
pathname='(unknown file)',
|
|
|
|
|
lineno=0,
|
|
|
|
|
msg=('%s: %s' % (name, s)),
|
|
|
|
|
args=(),
|
|
|
|
|
exc_info=None,
|
|
|
|
|
)
|
|
|
|
|
record.mitogen_message = s
|
|
|
|
|
record.mitogen_context = self._router.context_by_id(msg.src_id)
|
|
|
|
|
record.mitogen_name = name
|
|
|
|
|
logger.handle(record)
|
|
|
|
|
|
|
|
|
|
def __repr__(self):
|
|
|
|
|
return 'LogForwarder(%r)' % (self._router,)
|
|
|
|
|