mirror of
https://github.com/DJ2LS/FreeDATA
synced 2024-05-14 08:04:33 +00:00
WIP adding arq data frame
This commit is contained in:
parent
73f6bba630
commit
e3bca5bdc7
2 changed files with 3 additions and 6 deletions
|
@ -56,15 +56,13 @@ class ARQSessionIRS(arq_session.ARQSession):
|
||||||
self.log("Timeout waiting for data")
|
self.log("Timeout waiting for data")
|
||||||
self.state = self.STATE_FAILED
|
self.state = self.STATE_FAILED
|
||||||
return
|
return
|
||||||
else:
|
|
||||||
print("data received")
|
|
||||||
print(self.frame)
|
|
||||||
|
|
||||||
self.log("Finished ARQ IRS session")
|
self.log("Finished ARQ IRS session")
|
||||||
|
|
||||||
def run(self):
|
def run(self):
|
||||||
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=True)
|
||||||
self.thread.run()
|
self.thread.start()
|
||||||
|
|
||||||
|
|
||||||
def on_data_received(self, data_frame):
|
def on_data_received(self, data_frame):
|
||||||
if self.state != self.STATE_WAITING_DATA:
|
if self.state != self.STATE_WAITING_DATA:
|
||||||
|
|
|
@ -24,7 +24,6 @@ class ARQFrameHandler(frame_handler.FrameHandler):
|
||||||
iss_session:ARQSessionISS = self.states.get_arq_iss_session(frame['session_id'])
|
iss_session:ARQSessionISS = self.states.get_arq_iss_session(frame['session_id'])
|
||||||
iss_session.on_connection_ack_received(frame)
|
iss_session.on_connection_ack_received(frame)
|
||||||
|
|
||||||
|
|
||||||
# ARQ session data frame received
|
# ARQ session data frame received
|
||||||
if frame['frame_type_int'] in [FR.BURST_01.value, FR.BURST_02.value, FR.BURST_03.value, FR.BURST_04.value, FR.BURST_05.value]:
|
if frame['frame_type_int'] in [FR.BURST_01.value, FR.BURST_02.value, FR.BURST_03.value, FR.BURST_04.value, FR.BURST_05.value]:
|
||||||
print("received data frame....")
|
print("received data frame....")
|
||||||
|
|
Loading…
Reference in a new issue