andreas/heartbeat
Public Access
1
0
Fork 1
Code Issues Pull Requests Actions Packages Projects Releases 44 Wiki Activity

send shutdown msg only if we sent a boot msg. Don't send eithe when restarting.

Browse Source
This commit is contained in:
Andreas Wrede
2026-05-06 11:57:43 -04:00
parent d9fc8d632f
commit f006077a71
1 changed files with 5 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files
scripts/hbc_mini.py
+5 -2
View File
@@ -1028,7 +1028,7 @@ def _reconfigure_syslog(level: int):
# --------------------------------------------------------------------------- # ---------------------------------------------------------------------------
async def _async_main(args, cfg: Dict[str, Any]) -> int: async def _async_main(args, cfg: Dict[str, Any]) -> int:
global _running, _shutdown_event, _active_tasks global _running, _shutdown_event, _active_tasks, send_shutdown
_running = True _running = True
_shutdown_event = asyncio.Event() _shutdown_event = asyncio.Event()
_active_tasks = [] _active_tasks = []
@@ -1059,10 +1059,13 @@ async def _async_main(args, cfg: Dict[str, Any]) -> int:
return 1 return 1
# Boot / one-shot message # Boot / one-shot message
send_shutdown = False
if args.boot or args.message: if args.boot or args.message:
bmsg: Dict[str, Any] = {"acks": 0} bmsg: Dict[str, Any] = {"acks": 0}
if args.boot: if args.boot:
bmsg["boot"] = 1 bmsg["boot"] = 1
args.boot = False # don't repeat on restart
send_shutdown = True
if args.message: if args.message:
bmsg["service"] = "service" bmsg["service"] = "service"
bmsg["msg"] = args.message bmsg["msg"] = args.message
@@ -1100,7 +1103,7 @@ async def _async_main(args, cfg: Dict[str, Any]) -> int:
log.info("shutting down") log.info("shutting down")
target = next((c for c in connections if c._transport), connections[0] if connections else None) target = next((c for c in connections if c._transport), connections[0] if connections else None)
if target: if target and send_shutdown:
try: try:
await target.sendto({"shutdown": 1, "acks": target.ackcount}) await target.sendto({"shutdown": 1, "acks": target.ackcount})
except Exception: except Exception: