mirror of
https://github.com/DJ2LS/FreeDATA
synced 2024-05-14 08:04:33 +00:00
WIP ARQ
This commit is contained in:
parent
2e02186ea6
commit
a30d42f11b
2 changed files with 1 additions and 1 deletions
|
@ -89,7 +89,6 @@ class ARQSessionIRS(arq_session.ARQSession):
|
|||
def on_data_received(self, frame):
|
||||
if self.state != self.STATE_WAITING_DATA:
|
||||
raise RuntimeError(f"ARQ Session: Received data while in state {self.state}, expected {self.STATE_WAITING_DATA}")
|
||||
self.rx_data_chain(frame)
|
||||
self.event_data_received.set()
|
||||
|
||||
def on_transfer_ack_received(self, ack):
|
||||
|
|
|
@ -32,3 +32,4 @@ class ARQFrameHandler(frame_handler.FrameHandler):
|
|||
print("received data frame....")
|
||||
irs_session:ARQSessionIRS = self.states.get_arq_irs_session(frame['session_id'])
|
||||
irs_session.on_data_received(frame)
|
||||
irs_session.rx_data_chain(frame)
|
||||
|
|
Loading…
Reference in a new issue