mirror of
https://github.com/DJ2LS/FreeDATA
synced 2024-05-14 08:04:33 +00:00
Improve ARQ setting of failed state
This commit is contained in:
parent
fd33ccbe1e
commit
a3d05f3521
|
@ -59,9 +59,11 @@ class ARQSessionISS(arq_session.ARQSession):
|
||||||
for f in burst:
|
for f in burst:
|
||||||
self.transmit_frame(f)
|
self.transmit_frame(f)
|
||||||
if self.event_frame_received.wait(timeout):
|
if self.event_frame_received.wait(timeout):
|
||||||
self.log("Timeout interrupted due to received frame.")
|
|
||||||
break
|
break
|
||||||
|
self.log("Timeout...")
|
||||||
retries = retries - 1
|
retries = retries - 1
|
||||||
|
self.set_state(self.STATE_FAILED)
|
||||||
|
self.log("Session failed")
|
||||||
|
|
||||||
def launch_twr(self, frame_or_burst, timeout, retries):
|
def launch_twr(self, frame_or_burst, timeout, retries):
|
||||||
twr = threading.Thread(target = self.transmit_wait_and_retry, args=[frame_or_burst, timeout, retries])
|
twr = threading.Thread(target = self.transmit_wait_and_retry, args=[frame_or_burst, timeout, retries])
|
||||||
|
|
|
@ -72,7 +72,7 @@ class TestARQSession(unittest.TestCase):
|
||||||
def testARQSession(self):
|
def testARQSession(self):
|
||||||
|
|
||||||
# set Packet Error Rate (PER) / frame loss probability
|
# set Packet Error Rate (PER) / frame loss probability
|
||||||
self.loss_probability = 0
|
self.loss_probability = 30
|
||||||
|
|
||||||
self.establishChannels()
|
self.establishChannels()
|
||||||
params = {
|
params = {
|
||||||
|
|
Loading…
Reference in a new issue