2023-11-26 14:23:20 +00:00
|
|
|
import threading
|
|
|
|
import data_frame_factory
|
2023-11-26 14:45:41 +00:00
|
|
|
import command_beacon
|
2023-11-26 14:23:20 +00:00
|
|
|
|
2023-11-26 20:51:19 +00:00
|
|
|
class Beacon:
|
2023-11-26 14:23:20 +00:00
|
|
|
|
2023-11-26 20:51:19 +00:00
|
|
|
BEACON_LOOP_INTERVAL = 1
|
2023-11-26 14:23:20 +00:00
|
|
|
|
2024-01-04 14:46:58 +00:00
|
|
|
def __init__(self, config, states, event_manager, logger, modem):
|
2023-11-26 14:23:20 +00:00
|
|
|
|
2023-11-26 20:51:19 +00:00
|
|
|
self.modem_config = config
|
2023-11-26 21:24:09 +00:00
|
|
|
self.states = states
|
2024-01-04 14:46:58 +00:00
|
|
|
self.event_manager = event_manager
|
2023-11-26 20:51:19 +00:00
|
|
|
self.log = logger
|
2023-12-21 16:47:48 +00:00
|
|
|
self.modem = modem
|
2023-11-26 14:23:20 +00:00
|
|
|
|
2023-11-26 21:24:09 +00:00
|
|
|
self.loop_running = True
|
2023-11-26 20:51:19 +00:00
|
|
|
self.paused = False
|
|
|
|
self.thread = None
|
|
|
|
self.event = threading.Event()
|
2023-11-26 14:23:20 +00:00
|
|
|
|
2023-11-26 20:51:19 +00:00
|
|
|
self.frame_factory = data_frame_factory.DataFrameFactory(config)
|
2023-11-26 14:23:20 +00:00
|
|
|
|
2023-11-26 20:51:19 +00:00
|
|
|
def start(self):
|
|
|
|
beacon_thread = threading.Thread(target=self.run_beacon, name="beacon", daemon=True)
|
|
|
|
beacon_thread.start()
|
2023-11-26 14:23:20 +00:00
|
|
|
|
2023-11-26 21:24:09 +00:00
|
|
|
def stop(self):
|
|
|
|
self.loop_running = False
|
|
|
|
|
2023-11-26 20:51:19 +00:00
|
|
|
def refresh(self):
|
|
|
|
self.event.set()
|
|
|
|
self.event.clear()
|
|
|
|
|
|
|
|
def run_beacon(self) -> None:
|
2023-11-26 21:24:09 +00:00
|
|
|
while self.loop_running:
|
2023-11-26 20:51:19 +00:00
|
|
|
while (self.states.is_beacon_running and
|
|
|
|
not self.paused and
|
|
|
|
True):
|
|
|
|
#not self.states.channel_busy):
|
2023-11-26 14:23:20 +00:00
|
|
|
|
2024-01-04 14:46:58 +00:00
|
|
|
cmd = command_beacon.BeaconCommand(self.modem_config, self.states, self.event_manager)
|
|
|
|
cmd.run(self.event_manager, self.modem)
|
2023-11-26 20:51:19 +00:00
|
|
|
self.event.wait(self.modem_config['MODEM']['beacon_interval'])
|
2023-11-26 14:23:20 +00:00
|
|
|
|
2023-11-26 20:51:19 +00:00
|
|
|
self.event.wait(self.BEACON_LOOP_INTERVAL)
|
|
|
|
|