jacob.eva/Reticulum
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

Fixed potential None reference

Browse Source
This commit is contained in:
Mark Qvist 2023-09-18 20:52:36 +02:00
parent 7ee9b07d9c
commit 254c966159
1 changed files with 3 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
RNS/Channel.py
View File

@ -530,8 +530,9 @@ class Channel(contextlib.AbstractContextManager):
def _update_packet_timeouts(self): def _update_packet_timeouts(self):
for envelope in self._tx_ring: for envelope in self._tx_ring:
updated_timeout = self._get_packet_timeout_time(envelope.tries) updated_timeout = self._get_packet_timeout_time(envelope.tries)
if updated_timeout > envelope.packet.receipt.timeout: if envelope.packet and envelope.packet.receipt and envelope.packet.receipt.timeout:
envelope.packet.receipt.set_timeout(updated_timeout) if updated_timeout > envelope.packet.receipt.timeout:
envelope.packet.receipt.set_timeout(updated_timeout)
def _get_packet_timeout_time(self, tries: int) -> float: def _get_packet_timeout_time(self, tries: int) -> float:
to = pow(1.5, tries - 1) * max(self._outlet.rtt*2.5, 0.025) * (len(self._tx_ring)+1.5) to = pow(1.5, tries - 1) * max(self._outlet.rtt*2.5, 0.025) * (len(self._tx_ring)+1.5)