From c8c999919adefca42f18f09adcb3b98262386f31 Mon Sep 17 00:00:00 2001 From: M1nd3r Date: Tue, 27 Aug 2024 22:08:03 +0200 Subject: [PATCH] re-enable retransmission tmp --- core/src/trezor/wire/thp/transmission_loop.py | 16 ++++++++-------- 1 file changed, 8 insertions(+), 8 deletions(-) diff --git a/core/src/trezor/wire/thp/transmission_loop.py b/core/src/trezor/wire/thp/transmission_loop.py index d0b5e18d7e..3fdb17ca77 100644 --- a/core/src/trezor/wire/thp/transmission_loop.py +++ b/core/src/trezor/wire/thp/transmission_loop.py @@ -8,8 +8,8 @@ from trezor.wire.thp.writer import write_payload_to_wire_and_add_checksum if TYPE_CHECKING: from trezor.wire.thp.channel import Channel -MAX_RETRANSMISSION_COUNT = const(1) -MIN_RETRANSMISSION_COUNT = const(1) +MAX_RETRANSMISSION_COUNT = const(50) +MIN_RETRANSMISSION_COUNT = const(2) class TransmissionLoop: @@ -31,12 +31,12 @@ class TransmissionLoop: await write_payload_to_wire_and_add_checksum( self.channel.iface, self.header, self.transport_payload ) - # self.wait_task = loop.spawn(self._wait(i)) - # try: - # await self.wait_task - # except loop.TaskClosed: - # self.wait_task = None - # break + self.wait_task = loop.spawn(self._wait(i)) + try: + await self.wait_task + except loop.TaskClosed: + self.wait_task = None + break def stop_immediately(self): if self.wait_task is not None: