diff --git a/hippolyzer/lib/base/message/circuit.py b/hippolyzer/lib/base/message/circuit.py index 4f6b832..6a0f16e 100644 --- a/hippolyzer/lib/base/message/circuit.py +++ b/hippolyzer/lib/base/message/circuit.py @@ -21,7 +21,7 @@ class ReliableResendInfo: last_resent: dt.datetime message: Message completed: asyncio.Future = dataclasses.field(default_factory=asyncio.Future) - tries_left: int = 3 + tries_left: int = 10 class Circuit: @@ -34,7 +34,7 @@ class Circuit: self.last_packet_at = dt.datetime.now() self.packet_id_base = 0 self.unacked_reliable: Dict[Tuple[Direction, int], ReliableResendInfo] = {} - self.resend_every: float = 5.0 + self.resend_every: float = 3.0 def _send_prepared_message(self, message: Message, transport=None): try: diff --git a/tests/proxy/test_messages.py b/tests/proxy/test_messages.py index c6fee88..3bd7fbc 100644 --- a/tests/proxy/test_messages.py +++ b/tests/proxy/test_messages.py @@ -250,7 +250,7 @@ class PacketIDTests(unittest.IsolatedAsyncioTestCase): resend_info = self.circuit.unacked_reliable[(Direction.OUT, 1)] self.circuit.resend_unacked() # Should have been too soon to retry - self.assertEqual(3, resend_info.tries_left) + self.assertEqual(10, resend_info.tries_left) # Switch to allowing resends every 0s self.circuit.resend_every = 0.0 self.circuit.resend_unacked() @@ -259,8 +259,8 @@ class PacketIDTests(unittest.IsolatedAsyncioTestCase): # Should have resent (1, "ChatFromViewer", Direction.OUT, True, ()), ]) - self.assertEqual(2, resend_info.tries_left) - for _ in range(3): + self.assertEqual(9, resend_info.tries_left) + for _ in range(resend_info.tries_left): self.circuit.resend_unacked() # Should have used up all the retry attempts and been kicked out of the retry queue self.assertEqual(set(), set(self.circuit.unacked_reliable))