From 39d01158ba41137f46b80eb9018561d834a2e860 Mon Sep 17 00:00:00 2001 From: Timofey Titovets Date: Fri, 25 Jul 2025 19:11:50 +0200 Subject: [PATCH] serialhdl: name the threads per mcu Signed-off-by: Timofey Titovets --- klippy/mcu.py | 4 ++-- klippy/serialhdl.py | 11 ++++++++--- 2 files changed, 10 insertions(+), 5 deletions(-) diff --git a/klippy/mcu.py b/klippy/mcu.py index 8b41e4e0..d3b8ffd7 100644 --- a/klippy/mcu.py +++ b/klippy/mcu.py @@ -564,8 +564,8 @@ class MCU: if self._name.startswith('mcu '): self._name = self._name[4:] # Serial port - wp = "mcu '%s': " % (self._name) - self._serial = serialhdl.SerialReader(self._reactor, warn_prefix=wp) + name = self._name + self._serial = serialhdl.SerialReader(self._reactor, mcu_name = name) self._baud = 0 self._canbus_iface = None canbus_uuid = config.get('canbus_uuid', None) diff --git a/klippy/serialhdl.py b/klippy/serialhdl.py index fc884638..ab26514c 100644 --- a/klippy/serialhdl.py +++ b/klippy/serialhdl.py @@ -12,12 +12,15 @@ class error(Exception): pass class SerialReader: - def __init__(self, reactor, warn_prefix=""): + def __init__(self, reactor, mcu_name=""): self.reactor = reactor - self.warn_prefix = warn_prefix + self.warn_prefix = "" + self.mcu_name = mcu_name + if self.mcu_name: + self.warn_prefix = "mcu '%s': " % (self.mcu_name) # Serial port self.serial_dev = None - self.msgparser = msgproto.MessageParser(warn_prefix=warn_prefix) + self.msgparser = msgproto.MessageParser(warn_prefix=self.warn_prefix) # C interface self.ffi_main, self.ffi_lib = chelper.get_ffi() self.serialqueue = None @@ -34,6 +37,8 @@ class SerialReader: self.last_notify_id = 0 self.pending_notifications = {} def _bg_thread(self): + name_short = ("serialhdl %s" % (self.mcu_name))[:15] + self.ffi_lib.set_thread_name(name_short.encode('utf-8')) response = self.ffi_main.new('struct pull_queue_message *') while 1: self.ffi_lib.serialqueue_pull(self.serialqueue, response)