mirror of
https://github.com/sunnypilot/sunnypilot.git
synced 2026-02-19 03:03:57 +08:00
77321dbac4
* improve tools.lib.kbhit and tools.sim.lib.keyboard_ctrl * unpack more efficiently * minor improvements * agnos.py match spec better * manual_ctrl test missing queue arg * fix incorrect type annotation * queues are generic * varname reuse resulting in incorrect type inference * bytes().hex() rather than bytes.hex(bytes()) * a bit of type hinting stuff
37 lines
855 B
Python
Executable File
37 lines
855 B
Python
Executable File
#!/usr/bin/env python3
|
|
import zmq
|
|
from typing import NoReturn
|
|
|
|
import cereal.messaging as messaging
|
|
from common.logging_extra import SwagLogFileFormatter
|
|
from selfdrive.swaglog import get_file_handler
|
|
|
|
|
|
def main() -> NoReturn:
|
|
log_handler = get_file_handler()
|
|
log_handler.setFormatter(SwagLogFileFormatter(None))
|
|
log_level = 20 # logging.INFO
|
|
|
|
ctx = zmq.Context().instance()
|
|
sock = ctx.socket(zmq.PULL)
|
|
sock.bind("ipc:///tmp/logmessage")
|
|
|
|
# and we publish them
|
|
pub_sock = messaging.pub_sock('logMessage')
|
|
|
|
while True:
|
|
dat = b''.join(sock.recv_multipart())
|
|
level = dat[0]
|
|
record = dat[1:].decode("utf-8")
|
|
if level >= log_level:
|
|
log_handler.emit(record)
|
|
|
|
# then we publish them
|
|
msg = messaging.new_message()
|
|
msg.logMessage = record
|
|
pub_sock.send(msg.to_bytes())
|
|
|
|
|
|
if __name__ == "__main__":
|
|
main()
|