mirror of
https://github.com/trezor/trezor-firmware.git
synced 2025-08-05 13:26:57 +00:00
re-enable retransmission tmp
This commit is contained in:
parent
a272de9453
commit
c8c999919a
@ -8,8 +8,8 @@ from trezor.wire.thp.writer import write_payload_to_wire_and_add_checksum
|
|||||||
if TYPE_CHECKING:
|
if TYPE_CHECKING:
|
||||||
from trezor.wire.thp.channel import Channel
|
from trezor.wire.thp.channel import Channel
|
||||||
|
|
||||||
MAX_RETRANSMISSION_COUNT = const(1)
|
MAX_RETRANSMISSION_COUNT = const(50)
|
||||||
MIN_RETRANSMISSION_COUNT = const(1)
|
MIN_RETRANSMISSION_COUNT = const(2)
|
||||||
|
|
||||||
|
|
||||||
class TransmissionLoop:
|
class TransmissionLoop:
|
||||||
@ -31,12 +31,12 @@ class TransmissionLoop:
|
|||||||
await write_payload_to_wire_and_add_checksum(
|
await write_payload_to_wire_and_add_checksum(
|
||||||
self.channel.iface, self.header, self.transport_payload
|
self.channel.iface, self.header, self.transport_payload
|
||||||
)
|
)
|
||||||
# self.wait_task = loop.spawn(self._wait(i))
|
self.wait_task = loop.spawn(self._wait(i))
|
||||||
# try:
|
try:
|
||||||
# await self.wait_task
|
await self.wait_task
|
||||||
# except loop.TaskClosed:
|
except loop.TaskClosed:
|
||||||
# self.wait_task = None
|
self.wait_task = None
|
||||||
# break
|
break
|
||||||
|
|
||||||
def stop_immediately(self):
|
def stop_immediately(self):
|
||||||
if self.wait_task is not None:
|
if self.wait_task is not None:
|
||||||
|
Loading…
Reference in New Issue
Block a user