mirrors/cpython
1
0
Fork 0
mirror of https://github.com/python/cpython.git synced 2025-10-09 16:34:44 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions 17

Issue #23208, asyncio: Add BaseEventLoop._current_handle

Browse source 
In debug mode, BaseEventLoop._run_once() now sets the
BaseEventLoop._current_handle attribute to the handle currently executed.
In release mode or when no handle is executed, the attribute is None.

BaseEventLoop.default_exception_handler() displays the traceback of the current
handle if available.
This commit is contained in:
Victor Stinner 2015-01-26 11:05:12 +01:00
parent 3d2256f671
commit 9b524d59b0
1 changed files with 19 additions and 6 deletions
Download patch file Download diff file Expand all files Collapse all files

25
Lib/asyncio/base_events.py
View file

@ -179,6 +179,7 @@ class BaseEventLoop(events.AbstractEventLoop):
# In debug mode, if the execution of a callback or a step of a task # In debug mode, if the execution of a callback or a step of a task
# exceed this duration in seconds, the slow callback/task is logged. # exceed this duration in seconds, the slow callback/task is logged.
self.slow_callback_duration = 0.1 self.slow_callback_duration = 0.1
self._current_handle = None
def __repr__(self): def __repr__(self):
return ('<%s running=%s closed=%s debug=%s>' return ('<%s running=%s closed=%s debug=%s>'
@ -955,6 +956,10 @@ class BaseEventLoop(events.AbstractEventLoop):
else: else:
exc_info = False exc_info = False
if (self._current_handle is not None
and self._current_handle._source_traceback):
context['handle_traceback'] = self._current_handle._source_traceback
log_lines = [message] log_lines = [message]
for key in sorted(context): for key in sorted(context):
if key in {'message', 'exception'}: if key in {'message', 'exception'}:
@ -964,6 +969,10 @@ class BaseEventLoop(events.AbstractEventLoop):
tb = ''.join(traceback.format_list(value)) tb = ''.join(traceback.format_list(value))
value = 'Object created at (most recent call last):\n' value = 'Object created at (most recent call last):\n'
value += tb.rstrip() value += tb.rstrip()
elif key == 'handle_traceback':
tb = ''.join(traceback.format_list(value))
value = 'Handle created at (most recent call last):\n'
value += tb.rstrip()
else: else:
value = repr(value) value = repr(value)
log_lines.append('{}: {}'.format(key, value)) log_lines.append('{}: {}'.format(key, value))
@ -1121,12 +1130,16 @@ class BaseEventLoop(events.AbstractEventLoop):
if handle._cancelled: if handle._cancelled:
continue continue
if self._debug: if self._debug:
t0 = self.time() try:
handle._run() self._current_handle = handle
dt = self.time() - t0 t0 = self.time()
if dt >= self.slow_callback_duration: handle._run()
logger.warning('Executing %s took %.3f seconds', dt = self.time() - t0
_format_handle(handle), dt) if dt >= self.slow_callback_duration:
logger.warning('Executing %s took %.3f seconds',
_format_handle(handle), dt)
finally:
self._current_handle = None
else: else:
handle._run() handle._run()
handle = None # Needed to break cycles when an exception occurs. handle = None # Needed to break cycles when an exception occurs.