From a730c1b1a4199f9ca440785bd3877937c16c771e Mon Sep 17 00:00:00 2001 From: Jonas L Date: Sun, 14 Aug 2022 19:55:39 +0200 Subject: [PATCH] fix(playout): add thread names (#2056) --- playout/libretime_playout/message_handler.py | 2 ++ playout/libretime_playout/player/fetch.py | 2 ++ playout/libretime_playout/player/file.py | 2 ++ playout/libretime_playout/player/push.py | 2 ++ playout/libretime_playout/player/queue.py | 2 ++ playout/libretime_playout/recorder.py | 2 ++ playout/libretime_playout/timeout.py | 2 ++ 7 files changed, 14 insertions(+) diff --git a/playout/libretime_playout/message_handler.py b/playout/libretime_playout/message_handler.py index 0572b2dc9..0abc6893d 100644 --- a/playout/libretime_playout/message_handler.py +++ b/playout/libretime_playout/message_handler.py @@ -27,6 +27,8 @@ class RabbitConsumer(ConsumerMixin): class PypoMessageHandler(Thread): + name = "message_handler" + def __init__(self, pq, rq, config: RabbitMQConfig): Thread.__init__(self) self.pypo_queue = pq diff --git a/playout/libretime_playout/player/fetch.py b/playout/libretime_playout/player/fetch.py index 7632671b4..17142a1d8 100644 --- a/playout/libretime_playout/player/fetch.py +++ b/playout/libretime_playout/player/fetch.py @@ -30,6 +30,8 @@ signal.signal(signal.SIGINT, keyboardInterruptHandler) class PypoFetch(Thread): + name = "fetch" + def __init__( self, pypoFetch_q, diff --git a/playout/libretime_playout/player/file.py b/playout/libretime_playout/player/file.py index 10f257f09..9d8bed233 100644 --- a/playout/libretime_playout/player/file.py +++ b/playout/libretime_playout/player/file.py @@ -11,6 +11,8 @@ from requests.exceptions import ConnectionError, HTTPError, Timeout class PypoFile(Thread): + name = "file" + def __init__(self, schedule_queue, api_client: ApiClient): Thread.__init__(self) self.media_queue = schedule_queue diff --git a/playout/libretime_playout/player/push.py b/playout/libretime_playout/player/push.py index 3aa791184..21a810c74 100644 --- a/playout/libretime_playout/player/push.py +++ b/playout/libretime_playout/player/push.py @@ -21,6 +21,8 @@ def is_file(media_item): class PypoPush(Thread): + name = "push" + def __init__(self, q, telnet_lock, pypo_liquidsoap, config: Config): Thread.__init__(self) self.queue = q diff --git a/playout/libretime_playout/player/queue.py b/playout/libretime_playout/player/queue.py index e7e5b7be3..e935a01b5 100644 --- a/playout/libretime_playout/player/queue.py +++ b/playout/libretime_playout/player/queue.py @@ -19,6 +19,8 @@ signal.signal(signal.SIGINT, keyboardInterruptHandler) class PypoLiqQueue(Thread): + name = "liquidsoap_queue" + def __init__(self, q, pypo_liquidsoap): Thread.__init__(self) self.queue = q diff --git a/playout/libretime_playout/recorder.py b/playout/libretime_playout/recorder.py index e3d55ccb9..68ab481fc 100644 --- a/playout/libretime_playout/recorder.py +++ b/playout/libretime_playout/recorder.py @@ -36,6 +36,8 @@ def getDateTimeObj(time): class ShowRecorder(Thread): + name = "show_recorder" + def __init__( self, show_instance, diff --git a/playout/libretime_playout/timeout.py b/playout/libretime_playout/timeout.py index 84824da93..f255d880d 100644 --- a/playout/libretime_playout/timeout.py +++ b/playout/libretime_playout/timeout.py @@ -5,6 +5,8 @@ from .player import fetch def __timeout(func, timeout_duration, default, args, kwargs): class InterruptableThread(threading.Thread): + name = "liquidsoap_timeout" + def __init__(self): threading.Thread.__init__(self) self.result = default