Congegni
/
libretime
mirror of https://github.com/libretime/libretime.git
7
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

fix(playout): also shutdown on SIGTERM (#2104)

This commit is contained in:
Jonas L 2022-09-08 12:41:56 +02:00 committed by GitHub
parent 3990040e7a
commit 03902f6aef
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
3 changed files with 12 additions and 9 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

7
playout/libretime_playout/main.py
View File

@ -30,8 +30,8 @@ from .player.push import PypoPush
from .recorder import Recorder
def keyboardInterruptHandler(signum, frame):
logger.info("\nKeyboard Interrupt\n")
def shutdown_handler(signum, frame):
logger.info("shutting down")
sys.exit(0)
@ -63,7 +63,8 @@ def cli(log_level: str, log_filepath: Optional[Path], config_filepath: Optional[
logger.info("Timezone: %s" % str(time.tzname))
logger.info("UTC time: %s" % str(datetime.utcnow()))
signal.signal(signal.SIGINT, keyboardInterruptHandler)
signal.signal(signal.SIGINT, shutdown_handler)
signal.signal(signal.SIGTERM, shutdown_handler)
legacy_client = LegacyClient()
api_client = ApiClient(

7
playout/libretime_playout/player/fetch.py
View File

@ -23,12 +23,13 @@ from .liquidsoap import PypoLiquidsoap
from .schedule import get_schedule
def keyboardInterruptHandler(signum, frame):
logger.info("\nKeyboard Interrupt\n")
def shutdown_handler(signum, frame):
logger.info("shutting down")
sys.exit(0)
signal.signal(signal.SIGINT, keyboardInterruptHandler)
signal.signal(signal.SIGINT, shutdown_handler)
signal.signal(signal.SIGTERM, shutdown_handler)
class PypoFetch(Thread):

7
playout/libretime_playout/player/queue.py
View File

@ -11,12 +11,13 @@ from ..utils import seconds_between
from .liquidsoap import PypoLiquidsoap
def keyboardInterruptHandler(signum, frame):
logger.info("\nKeyboard Interrupt\n")
def shutdown_handler(signum, frame):
logger.info("shutting down")
sys.exit(0)
signal.signal(signal.SIGINT, keyboardInterruptHandler)
signal.signal(signal.SIGINT, shutdown_handler)
signal.signal(signal.SIGTERM, shutdown_handler)
class PypoLiqQueue(Thread):