diff --git a/daemon/core/api/tlv/corehandlers.py b/daemon/core/api/tlv/corehandlers.py index 79c2e1dc..d28776a1 100644 --- a/daemon/core/api/tlv/corehandlers.py +++ b/daemon/core/api/tlv/corehandlers.py @@ -527,6 +527,10 @@ class CoreHandler(socketserver.BaseRequestHandler): "%s handling message:\n%s", threading.currentThread().getName(), message ) + # provide to sdt, if enabled + if self.session and self.session.sdt.is_enabled(): + self.session.sdt.handle_distributed(message) + if message.message_type not in self.message_handlers: logging.error("no handler for message type: %s", message.type_str()) return diff --git a/daemon/core/plugins/sdt.py b/daemon/core/plugins/sdt.py index b6dcdd1b..0f605100 100644 --- a/daemon/core/plugins/sdt.py +++ b/daemon/core/plugins/sdt.py @@ -242,8 +242,8 @@ class Sdt: if self.sock is None: return False try: - logging.info("sdt: %s", cmdstr) - self.sock.sendall(f"{cmdstr}\n") + cmd = f"{cmdstr}\n".encode() + self.sock.sendall(cmd) return True except IOError: logging.exception("SDT connection error")