Successful ARQ v2 transfer for the 1st time

This commit is contained in:
Pedro 2023-12-13 15:35:16 +01:00
parent ba846013e8
commit bef2e80acc
3 changed files with 7 additions and 7 deletions

View file

@ -94,7 +94,7 @@ class ARQSessionIRS(arq_session.ARQSession):
def run(self):
self.set_state(self.STATE_WAITING_DATA)
self.thread = threading.Thread(target=self.runner, name=f"ARQ IRS Session {self.id}", daemon=True)
self.thread = threading.Thread(target=self.runner, name=f"ARQ IRS Session {self.id}", daemon=False)
self.thread.start()
def send_open_ack(self):

View file

@ -52,7 +52,7 @@ class ARQSessionISS(arq_session.ARQSession):
return self.send_data()
def run(self):
self.thread = threading.Thread(target=self.runner, name=f"ARQ ISS Session {self.id}", daemon=True)
self.thread = threading.Thread(target=self.runner, name=f"ARQ ISS Session {self.id}", daemon=False)
self.thread.run()
def handshake(self, frame, event):
@ -123,11 +123,11 @@ class ARQSessionISS(arq_session.ARQSession):
self.set_state(self.STATE_DISCONNECTED)
return False
def on_transfer_ack_received(self, ack):
def on_burst_ack_received(self, ack):
self.speed_level = ack['speed_level']
self.event_transfer_ack_received.set()
def on_transfer_nack_received(self, nack):
def on_burst_nack_received(self, nack):
self.speed_level = nack['speed_level']
self.event_transfer_ack_received.set()

View file

@ -35,9 +35,9 @@ class DISPATCHER():
FR_TYPE.ARQ_CONNECTION_OPEN.value: {"class": ARQFrameHandler, "name": "ARQ OPEN SESSION"},
FR_TYPE.ARQ_STOP.value: {"class": ARQFrameHandler, "name": "ARQ STOP TX"},
FR_TYPE.BEACON.value: {"class": FrameHandler, "name": "BEACON"},
FR_TYPE.BURST_FRAME.value:{"class": ARQFrameHandler, "name": "BURST_01"},
FR_TYPE.BURST_ACK.value: {"class": FrameHandler, "name": "BURST ACK"},
FR_TYPE.BURST_NACK.value: {"class": FrameHandler, "name": "BURST NACK"},
FR_TYPE.BURST_FRAME.value:{"class": ARQFrameHandler, "name": "BURST FRAME"},
FR_TYPE.BURST_ACK.value: {"class": ARQFrameHandler, "name": "BURST ACK"},
FR_TYPE.BURST_NACK.value: {"class": ARQFrameHandler, "name": "BURST NACK"},
FR_TYPE.CQ.value: {"class": CQFrameHandler, "name": "CQ"},
FR_TYPE.FR_ACK.value: {"class": FrameHandler, "name": "FRAME ACK"},
FR_TYPE.FR_NACK.value: {"class": FrameHandler, "name": "FRAME NACK"},