import linecache import traceback from . import base_futures from . import coroutines def _task_repr_info(task): info = base_futures._future_repr_info(task) if task._must_cancel: # replace status info[0] = 'cancelling' info.insert(1, 'name=%r' % task.get_name()) coro = coroutines._format_coroutine(task._coro) info.insert(2, f'coro=<{coro}>') if task._fut_waiter is not None: info.insert(3, f'wait_for={task._fut_waiter!r}') return info def _task_get_stack(task, limit): frames = [] if hasattr(task._coro, 'cr_frame'): # case 1: 'async def' coroutines f = task._coro.cr_frame elif hasattr(task._coro, 'gi_frame'): # case 2: legacy coroutines f = task._coro.gi_frame elif hasattr(task._coro, 'ag_frame'): # case 3: async generators f = task._coro.ag_frame else: # case 4: unknown objects f = None if f is not None: while f is not None: if limit is not None: if limit <= 0: break limit -= 1 frames.append(f) f = f.f_back frames.reverse() elif task._exception is not None: tb = task._exception.__traceback__ while tb is not None: if limit is not None: if limit <= 0: break limit -= 1 frames.append(tb.tb_frame) tb = tb.tb_next return frames def _task_print_stack(task, limit, file): extracted_list = [] checked = set() for f in task.get_stack(limit=limit): lineno = f.f_lineno co = f.f_code filename = co.co_filename name = co.co_name if filename not in checked: checked.add(filename) linecache.checkcache(filename) line = linecache.getline(filename, lineno, f.f_globals) extracted_list.append((filename, lineno, name, line)) exc = task._exception if not extracted_list: print(f'No stack for {task!r}', file=file) elif exc is not None: print(f'Traceback for {task!r} (most recent call last):', file=file) else: print(f'Stack for {task!r} (most recent call last):', file=file) traceback.print_list(extracted_list, file=file) if exc is not None: for line in traceback.format_exception_only(exc.__class__, exc): print(line, file=file, end='')
Name | Type | Size | Permission | Actions |
---|---|---|---|---|
__pycache__ | Folder | 0755 |
|
|
__init__.py | File | 1.2 KB | 0644 |
|
__main__.py | File | 3.26 KB | 0644 |
|
base_events.py | File | 70.92 KB | 0644 |
|
base_futures.py | File | 2.51 KB | 0644 |
|
base_subprocess.py | File | 8.64 KB | 0644 |
|
base_tasks.py | File | 2.41 KB | 0644 |
|
constants.py | File | 888 B | 0644 |
|
coroutines.py | File | 8.59 KB | 0644 |
|
events.py | File | 25.55 KB | 0644 |
|
exceptions.py | File | 1.59 KB | 0644 |
|
format_helpers.py | File | 2.35 KB | 0644 |
|
futures.py | File | 12.85 KB | 0644 |
|
locks.py | File | 16.87 KB | 0644 |
|
log.py | File | 124 B | 0644 |
|
proactor_events.py | File | 31.31 KB | 0644 |
|
protocols.py | File | 6.97 KB | 0644 |
|
queues.py | File | 8.03 KB | 0644 |
|
runners.py | File | 2.01 KB | 0644 |
|
selector_events.py | File | 38.08 KB | 0644 |
|
sslproto.py | File | 26.57 KB | 0644 |
|
staggered.py | File | 5.85 KB | 0644 |
|
streams.py | File | 26.03 KB | 0644 |
|
subprocess.py | File | 7.88 KB | 0644 |
|
tasks.py | File | 33.13 KB | 0644 |
|
transports.py | File | 10.24 KB | 0644 |
|
trsock.py | File | 5.74 KB | 0644 |
|
unix_events.py | File | 47.96 KB | 0644 |
|
windows_events.py | File | 32.1 KB | 0644 |
|
windows_utils.py | File | 4.94 KB | 0644 |
|