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

__call_at -> __schedule

Browse Source
This commit is contained in:
Jan Pochyla 2016-05-03 18:58:10 +02:00 committed by Pavol Rusnak
parent d612037eda
commit e8122cc975
No known key found for this signature in database
GPG Key ID: 91F3B339B9A02A3D
1 changed files with 7 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

13
src/trezor/loop.py
View File

@ -26,12 +26,13 @@ if __debug__:
log_delay_rb = array.array('i', [0] * log_delay_rb_len) log_delay_rb = array.array('i', [0] * log_delay_rb_len)
def __call_at(time, gen): def __schedule(gen, time=None):
if __debug__: if __debug__:
log.debug(__name__, 'Scheduling %s %s', time, gen) log.debug(__name__, 'Scheduling %s %s', time, gen)
if not time: if not time:
time = utime.ticks_us() time = utime.ticks_us()
heappush(time_queue, (time, gen)) heappush(time_queue, (time, gen))
@ -44,7 +45,7 @@ class Wait():
self.gens = gens self.gens = gens
for g in gens: for g in gens:
__call_at(None, self._wait(g)) __schedule(self._wait(g))
def _wait(self, gen): def _wait(self, gen):
if isinstance(gen, type_gen): if isinstance(gen, type_gen):
@ -58,7 +59,7 @@ class Wait():
self.received += 1 self.received += 1
if self.received == self.wait_for: if self.received == self.wait_for:
__call_at(None, self.callback) __schedule(self.callback)
self.callback = None self.callback = None
if self.exit_others: if self.exit_others:
@ -82,7 +83,7 @@ def run_forever(start_gens):
delay_max = const(1000000) delay_max = const(1000000)
for gen in start_gens: for gen in start_gens:
__call_at(None, gen) __schedule(gen)
while True: while True:
@ -133,7 +134,7 @@ def run_forever(start_gens):
if isinstance(ret, int) and ret >= 0: if isinstance(ret, int) and ret >= 0:
# Sleep until ret, call us later # Sleep until ret, call us later
__call_at(ret, gen) __schedule(gen, ret)
elif isinstance(ret, int) and ret in event_handlers: elif isinstance(ret, int) and ret in event_handlers:
# Wait for event # Wait for event
@ -148,7 +149,7 @@ def run_forever(start_gens):
elif ret is None: elif ret is None:
# Just call us asap # Just call us asap
__call_at(None, gen) __schedule(gen)
else: else:
raise Exception('Unhandled result %s by %s' % (ret, gen)) raise Exception('Unhandled result %s by %s' % (ret, gen))