Crash_Override/FreeDATA
1
0
Fork 0
mirror of https://github.com/DJ2LS/FreeDATA synced 2024-05-14 10:04:33 +02:00
Code Issues Packages Projects Releases Wiki Activity

ARQ WIP

Browse source
This commit is contained in:
Pedro 2023-12-06 11:59:35 +01:00
parent bb0fc79b4f
commit a290c854d5
3 changed files with 11 additions and 11 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

16
modem/arq_session.py
View file

@ -1,18 +1,14 @@
import queue, threading
from codec2 import FREEDV_MODE
import codec2
import data_frame_factory
import structlog
class ARQSession():
MODE_BY_SPEED = [
FREEDV_MODE.datac4.value,
FREEDV_MODE.datac3.value,
FREEDV_MODE.datac1.value,
]
SIZE_BY_SPEED = [
codec2.FREEDV_MODE.datac4.value,
codec2.FREEDV_MODE.datac3.value,
codec2.FREEDV_MODE.datac1.value,
]
def __init__(self, config: dict, tx_frame_queue: queue.Queue, dxcall: str):
@ -44,3 +40,7 @@ class ARQSession():
def setState(self, state):
self.state = state
self.logger.info(f"state changed to {state}")
def get_payload_size(self, speed_level):
mode = self.MODE_BY_SPEED[speed_level]
return codec2.get_bytes_per_frame(mode)

2
modem/arq_session_iss.py
View file

@ -76,7 +76,7 @@ class ARQSessionISS(arq_session.ARQSession):
def send_data(self):
offset = 0
while offset < len(self.data):
max_size = self.get_max_size_for_speed_level(self.speed_level)
max_size = self.get_payload_size(self.speed_level)
end_offset = min(len(self.data), max_size)
frame_payload = self.data[offset:end_offset]
data_frame = self.frame_factory.build_arq_session_send(self.speed_level,

4
tests/test_arq_session.py
View file

@ -51,9 +51,9 @@ class TestARQSession(unittest.TestCase):
transmission_item = modem_transmit_queue.get()
frame_bytes = bytes(transmission_item['frame'])
if random.randint(0, 100) < self.loss_probability:
self.logger.info("[TestChannel] Frame lost...")
self.logger.info(f"[{threading.current_thread().name}] Frame lost...")
continue
self.logger.info("[TestChannel] Redirecting frame")
self.logger.info(f"[{threading.current_thread().name}] Redirecting frame")
frame_dispatcher.new_process_data(frame_bytes, None, len(frame_bytes), 0, 0)
def establishChannels(self):