aboutsummaryrefslogtreecommitdiffstats
path: root/klippy/queuelogger.py
diff options
context:
space:
mode:
authorTomasz Kramkowski <tomasz@kramkow.ski>2025-08-15 21:39:34 +0100
committerTomasz Kramkowski <tomasz@kramkow.ski>2025-08-15 21:46:37 +0100
commit2e957a0efca9ca8f029b7787ba7ebafb2b5aa56a (patch)
treeebacf45d39539dcfe6e171561a101e4bf210a699 /klippy/queuelogger.py
parent5cc72c0da7043af9fa5b72af60a701d0162ea82a (diff)
downloadkutter-2e957a0efca9ca8f029b7787ba7ebafb2b5aa56a.tar.gz
kutter-2e957a0efca9ca8f029b7787ba7ebafb2b5aa56a.tar.xz
kutter-2e957a0efca9ca8f029b7787ba7ebafb2b5aa56a.zip
Remove logfile support
Diffstat (limited to 'klippy/queuelogger.py')
-rw-r--r--klippy/queuelogger.py35
1 files changed, 6 insertions, 29 deletions
diff --git a/klippy/queuelogger.py b/klippy/queuelogger.py
index b5bfc612..2792d513 100644
--- a/klippy/queuelogger.py
+++ b/klippy/queuelogger.py
@@ -22,20 +22,16 @@ class QueueHandler(logging.Handler):
except Exception:
self.handleError(record)
-
# Class to poll a queue in a background thread and log each message
-class QueueListener(logging.handlers.TimedRotatingFileHandler):
- def __init__(self, filename):
- logging.handlers.TimedRotatingFileHandler.__init__(
- self, filename, when="midnight", backupCount=5
- )
+class QueueListener(logging.StreamHandler):
+ def __init__(self):
+ super().__init__()
self.bg_queue = queue.Queue()
self.bg_thread = threading.Thread(target=self._bg_thread)
self.bg_thread.start()
- self.rollover_info = {}
def _bg_thread(self):
- while 1:
+ while True:
record = self.bg_queue.get(True)
if record is None:
break
@@ -45,32 +41,13 @@ class QueueListener(logging.handlers.TimedRotatingFileHandler):
self.bg_queue.put_nowait(None)
self.bg_thread.join()
- def set_rollover_info(self, name, info):
- if info is None:
- self.rollover_info.pop(name, None)
- return
- self.rollover_info[name] = info
-
- def clear_rollover_info(self):
- self.rollover_info.clear()
-
- def doRollover(self):
- logging.handlers.TimedRotatingFileHandler.doRollover(self)
- lines = [self.rollover_info[name] for name in sorted(self.rollover_info)]
- lines.append(
- "=============== Log rollover at %s ===============" % (time.asctime(),)
- )
- self.emit(
- logging.makeLogRecord({"msg": "\n".join(lines), "level": logging.INFO})
- )
-
MainQueueHandler = None
-def setup_bg_logging(filename, debuglevel):
+def setup_bg_logging(debuglevel):
global MainQueueHandler
- ql = QueueListener(filename)
+ ql = QueueListener()
MainQueueHandler = QueueHandler(ql.bg_queue)
root = logging.getLogger()
root.addHandler(MainQueueHandler)