f9fcc7adab
date: 2026-06-28T09:48:35 master commit: da6313dbe95b3f24bb5d8018b0e5f950f5823ca7
47 lines
1.5 KiB
Python
Executable File
47 lines
1.5 KiB
Python
Executable File
#!/usr/bin/env python3
|
|
|
|
import time
|
|
from multiprocessing import Process
|
|
|
|
from openpilot.common.params import Params
|
|
from openpilot.system.manager.process import launcher
|
|
from openpilot.common.swaglog import cloudlog
|
|
from openpilot.system.hardware import HARDWARE
|
|
from openpilot.system.version import get_build_metadata
|
|
|
|
ATHENA_MGR_PID_PARAM = "AthenadPid"
|
|
|
|
|
|
def main():
|
|
manage_athenad("DongleId", ATHENA_MGR_PID_PARAM, 'athenad', 'system.athena.athenad')
|
|
|
|
|
|
def manage_athenad(dongle_id_param, pid_param, process_name, target):
|
|
params = Params()
|
|
dongle_id = params.get(dongle_id_param)
|
|
build_metadata = get_build_metadata()
|
|
|
|
cloudlog.bind_global(dongle_id=dongle_id,
|
|
version=build_metadata.openpilot.version,
|
|
origin=build_metadata.openpilot.git_normalized_origin,
|
|
branch=build_metadata.channel,
|
|
commit=build_metadata.openpilot.git_commit,
|
|
dirty=build_metadata.openpilot.is_dirty,
|
|
device=HARDWARE.get_device_type())
|
|
|
|
try:
|
|
while 1:
|
|
cloudlog.info(f"starting {process_name} daemon")
|
|
proc = Process(name=process_name, target=launcher, args=(target, process_name))
|
|
proc.start()
|
|
proc.join()
|
|
cloudlog.event(f"{process_name} exited", exitcode=proc.exitcode)
|
|
time.sleep(5)
|
|
except Exception:
|
|
cloudlog.exception(f"manage_{process_name}.exception")
|
|
finally:
|
|
params.remove(pid_param)
|
|
|
|
if __name__ == '__main__':
|
|
main()
|