From 6d0fcf0970e4b379ffea8ef551189842acf692f5 Mon Sep 17 00:00:00 2001 From: JonnyWong16 <9099342+JonnyWong16@users.noreply.github.com> Date: Fri, 15 Oct 2021 00:39:19 -0700 Subject: [PATCH] Remove unused logger functions --- plexpy/logger.py | 64 ------------------------------------------------ 1 file changed, 64 deletions(-) diff --git a/plexpy/logger.py b/plexpy/logger.py index 33e0d2b2..c30518ef 100644 --- a/plexpy/logger.py +++ b/plexpy/logger.py @@ -18,14 +18,10 @@ from __future__ import unicode_literals from future.builtins import str -from logutils.queue import QueueHandler, QueueListener from logging import handlers import cherrypy -import contextlib -import errno import logging -import multiprocessing import os import re import sys @@ -207,66 +203,6 @@ class PlexTokenFilter(RegexFilter): return text.replace(token, 16 * '*') -@contextlib.contextmanager -def listener(): - """ - Wrapper that create a QueueListener, starts it and automatically stops it. - To be used in a with statement in the main process, for multiprocessing. - """ - - global queue - - # Initialize queue if not already done - if queue is None: - try: - queue = multiprocessing.Queue() - except OSError as e: - queue = False - - # Some machines don't have access to /dev/shm. See - # http://stackoverflow.com/questions/2009278 for more information. - if e.errno == errno.EACCES: - logger.warning('Multiprocess logging disabled, because ' - 'current user cannot map shared memory. You won\'t see any' \ - 'logging generated by the worker processed.') - - # Multiprocess logging may be disabled. - if not queue: - yield - else: - queue_listener = QueueListener(queue, *logger.handlers) - - try: - queue_listener.start() - yield - finally: - queue_listener.stop() - - -def initMultiprocessing(): - """ - Remove all handlers and add QueueHandler on top. This should only be called - inside a multiprocessing worker process, since it changes the logger - completely. - """ - - # Multiprocess logging may be disabled. - if not queue: - return - - # Remove all handlers and add the Queue handler as the only one. - for handler in logger.handlers[:]: - logger.removeHandler(handler) - - queue_handler = QueueHandler(queue) - queue_handler.setLevel(logging.DEBUG) - - logger.addHandler(queue_handler) - - # Change current thread name for log record - threading.current_thread().name = multiprocessing.current_process().name - - def initLogger(console=False, log_dir=False, verbose=False): """ Setup logging for Tautulli. It uses the logger instance with the name