back.pysim: continue running simulator processes until they suspend.
This commit is contained in:
parent
51a92bc870
commit
d6e98fd934
|
@ -554,10 +554,12 @@ class Simulator:
|
||||||
interval = cmd.interval
|
interval = cmd.interval
|
||||||
self._wait_deadline[process] = self._timestamp + interval
|
self._wait_deadline[process] = self._timestamp + interval
|
||||||
self._suspended.add(process)
|
self._suspended.add(process)
|
||||||
|
break
|
||||||
|
|
||||||
elif isinstance(cmd, Tick):
|
elif isinstance(cmd, Tick):
|
||||||
self._wait_tick[process] = cmd.domain
|
self._wait_tick[process] = cmd.domain
|
||||||
self._suspended.add(process)
|
self._suspended.add(process)
|
||||||
|
break
|
||||||
|
|
||||||
elif isinstance(cmd, Passive):
|
elif isinstance(cmd, Passive):
|
||||||
self._passive.add(process)
|
self._passive.add(process)
|
||||||
|
@ -594,7 +596,7 @@ class Simulator:
|
||||||
raise TypeError("Received unsupported command '{!r}' from process '{}'"
|
raise TypeError("Received unsupported command '{!r}' from process '{}'"
|
||||||
.format(cmd, self._name_process(process)))
|
.format(cmd, self._name_process(process)))
|
||||||
|
|
||||||
break
|
cmd = process.send(None)
|
||||||
|
|
||||||
except StopIteration:
|
except StopIteration:
|
||||||
self._processes.remove(process)
|
self._processes.remove(process)
|
||||||
|
|
Loading…
Reference in a new issue