mirror of
https://github.com/sunnypilot/sunnypilot.git
synced 2026-07-25 18:22:05 +08:00
github-actions[bot]
ba6db36314
version: sunnypilot v2026.003.000 (dev)
date: 2026-07-24T16:32:00
master commit: a0cc313fdc
31 lines
836 B
Python
31 lines
836 B
Python
import os
|
|
from openpilot.cereal import log as capnp_log, messaging
|
|
from openpilot.cereal.services import SERVICE_LIST
|
|
|
|
from openpilot.tools.lib.logreader import LogIterable, RawLogIterable
|
|
|
|
|
|
ALL_SERVICES = list(SERVICE_LIST.keys())
|
|
|
|
def raw_live_logreader(services: list[str] = ALL_SERVICES, addr: str = '127.0.0.1') -> RawLogIterable:
|
|
if addr != "127.0.0.1":
|
|
os.environ["ZMQ"] = "1"
|
|
messaging.reset_context()
|
|
|
|
poller = messaging.Poller()
|
|
|
|
for m in services:
|
|
messaging.sub_sock(m, poller, addr=addr)
|
|
|
|
while True:
|
|
polld = poller.poll(100)
|
|
for sock in polld:
|
|
msg = sock.receive()
|
|
yield msg
|
|
|
|
|
|
def live_logreader(services: list[str] = ALL_SERVICES, addr: str = '127.0.0.1') -> LogIterable:
|
|
for m in raw_live_logreader(services, addr):
|
|
with capnp_log.Event.from_bytes(m) as evt:
|
|
yield evt
|