arno/trezor-firmware
1
0
Fork 0
mirror of https://github.com/trezor/trezor-firmware.git synced 2024-12-16 03:18:09 +00:00
Code Issues Releases Wiki Activity

refactor(core): remove unused features from loop.race

Browse Source
This commit is contained in:
matejcik 2023-07-25 10:47:04 +02:00 committed by matejcik
parent b7b09b8836
commit 0334b42c8e
1 changed files with 6 additions and 22 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

26
core/src/trezor/loop.py
View File

@ -287,7 +287,6 @@ class race(Syscall):
directly). Return value of `race` is the return value of the child that directly). Return value of `race` is the return value of the child that
triggered the completion. Other running children are killed (by cancelling triggered the completion. Other running children are killed (by cancelling
any pending schedules and raising a `GeneratorExit` by calling `close()`). any pending schedules and raising a `GeneratorExit` by calling `close()`).
Child that caused the completion is present in `self.finished`.
Example: Example:
@ -297,19 +296,14 @@ class race(Syscall):
>>> animation_task = animate_logo() >>> animation_task = animate_logo()
>>> racer = loop.race(touch_task, animation_task) >>> racer = loop.race(touch_task, animation_task)
>>> result = await racer >>> result = await racer
>>> if animation_task in racer.finished:
>>> print('animation task returned value:', result)
>>> elif touch_task in racer.finished:
>>> print('touch task returned value:', result)
Note: You should not directly `yield` a `race` instance, see logic in Note: You should not directly `yield` a `race` instance, see logic in
`race.__iter__` for explanation. Always use `await`. `race.__iter__` for explanation. Always use `await`.
""" """
def __init__(self, *children: AwaitableTask, exit_others: bool = True) -> None: def __init__(self, *children: AwaitableTask) -> None:
self.children = children self.children = children
self.exit_others = exit_others self.finished = False
self.finished: list[AwaitableTask] = [] # children that finished
self.scheduled: list[Task] = [] # scheduled wrapper tasks self.scheduled: list[Task] = [] # scheduled wrapper tasks
def handle(self, task: Task) -> None: def handle(self, task: Task) -> None:
@ -318,11 +312,10 @@ class race(Syscall):
""" """
finalizer = self._finish finalizer = self._finish
scheduled = self.scheduled scheduled = self.scheduled
finished = self.finished self.finished = False
self.callback = task self.callback = task
scheduled.clear() scheduled.clear()
finished.clear()
for child in self.children: for child in self.children:
child_task: Task child_task: Task
@ -346,16 +339,7 @@ class race(Syscall):
def _finish(self, task: Task, result: Any) -> None: def _finish(self, task: Task, result: Any) -> None:
if not self.finished: if not self.finished:
# because we create tasks for children that are not generators yet, self.finished = True
# we need to find the child value that the caller supplied
for index, child_task in enumerate(self.scheduled):
if child_task is task:
child = self.children[index]
break
else:
raise RuntimeError # task not found in scheduled
self.finished.append(child)
if self.exit_others:
self.exit(task) self.exit(task)
schedule(self.callback, result) schedule(self.callback, result)
@ -366,7 +350,7 @@ class race(Syscall):
# exception was raised on the waiting task externally with # exception was raised on the waiting task externally with
# close() or throw(), kill the children tasks and re-raise # close() or throw(), kill the children tasks and re-raise
# Make sure finalizers don't continue processing. # Make sure finalizers don't continue processing.
self.finished.append(self) self.finished = True
self.exit() self.exit()
raise raise