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

enable/disable socket interface

Browse source
This commit is contained in:
DJ2LS 2024-03-25 19:29:30 +01:00
parent e24a64ba25
commit bdd8888f1b
6 changed files with 14 additions and 5 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

1
modem/config.ini.example
View file

@ -49,6 +49,7 @@ enable_morse_identifier = False
respond_to_cq = True respond_to_cq = True
tx_delay = 50 tx_delay = 50
maximum_bandwidth = 1700 maximum_bandwidth = 1700
enable_socket_interface = False
[SOCKET_INTERFACE] [SOCKET_INTERFACE]
enable = False enable = False

3
modem/config.py
View file

@ -59,7 +59,8 @@ class CONFIG:
'enable_morse_identifier': bool, 'enable_morse_identifier': bool,
'maximum_bandwidth': int, 'maximum_bandwidth': int,
'respond_to_cq': bool, 'respond_to_cq': bool,
'tx_delay': int 'tx_delay': int,
'enable_socket_interface': bool,
}, },
'SOCKET_INTERFACE': { 'SOCKET_INTERFACE': {
'enable' : bool, 'enable' : bool,

10
modem/service_manager.py
View file

@ -33,19 +33,23 @@ class SM:
self.config = self.app.config_manager.read() self.config = self.app.config_manager.read()
self.start_radio_manager() self.start_radio_manager()
self.start_modem() self.start_modem()
self.socket_interface_manager = SocketInterfaceHandler(self.modem, self.app.config_manager, self.state_manager, self.event_manager).start_servers()
if self.config['MODEM']['enable_socket_interface']:
self.socket_interface_manager = SocketInterfaceHandler(self.modem, self.app.config_manager, self.state_manager, self.event_manager).start_servers()
elif cmd in ['stop'] and self.modem: elif cmd in ['stop'] and self.modem:
self.stop_modem() self.stop_modem()
self.stop_radio_manager() self.stop_radio_manager()
self.socket_interface_manager.stop_servers() if self.config['MODEM']['enable_socket_interface']:
self.socket_interface_manager.stop_servers()
# we need to wait a bit for avoiding a portaudio crash # we need to wait a bit for avoiding a portaudio crash
threading.Event().wait(0.5) threading.Event().wait(0.5)
elif cmd in ['restart']: elif cmd in ['restart']:
self.stop_modem() self.stop_modem()
self.stop_radio_manager() self.stop_radio_manager()
self.socket_interface_manager.stop_servers() if self.config['MODEM']['enable_socket_interface']:
self.socket_interface_manager.stop_servers()
# we need to wait a bit for avoiding a portaudio crash # we need to wait a bit for avoiding a portaudio crash
threading.Event().wait(0.5) threading.Event().wait(0.5)

2
modem/socket_interface.py
View file

@ -1,3 +1,5 @@
""" WORK IN PROGRESS by DJ2LS"""
import socketserver import socketserver
import threading import threading
import structlog import structlog

1
modem/socket_interface_commands.py
View file

@ -1,3 +1,4 @@
""" WORK IN PROGRESS by DJ2LS"""
from command_p2p_connection import P2PConnectionCommand from command_p2p_connection import P2PConnectionCommand
class SocketCommandHandler: class SocketCommandHandler:

2
tests/test_p2p_connection.py
View file

@ -148,7 +148,7 @@ class TestP2PConnectionSession(unittest.TestCase):
length = random.randint(min_length, max_length) length = random.randint(min_length, max_length)
return ''.join(random.choices(string.ascii_letters, k=length))# return ''.join(random.choices(string.ascii_letters, k=length))#
def testARQSessionSmallPayload(self): def DisabledtestARQSessionSmallPayload(self):
# set Packet Error Rate (PER) / frame loss probability # set Packet Error Rate (PER) / frame loss probability
self.loss_probability = 0 self.loss_probability = 0