From 78d745b03f8b1ab7db5c659c46b154887731b885 Mon Sep 17 00:00:00 2001
From: derrod <xlnedder@gmail.com>
Date: Tue, 21 Apr 2020 20:26:17 +0200
Subject: [PATCH] [downloader] Fix log message and close shared memory on exit

---
 legendary/downloader/workers.py | 4 +++-
 1 file changed, 3 insertions(+), 1 deletion(-)

diff --git a/legendary/downloader/workers.py b/legendary/downloader/workers.py
index 9744430..1f3c20f 100644
--- a/legendary/downloader/workers.py
+++ b/legendary/downloader/workers.py
@@ -42,7 +42,7 @@ class DLWorker(Process):
                 continue
 
             if job.kill:  # let worker die
-                self.log.info(f'[{self.name}] Queue Empty, waiting for more...')
+                self.log.info(f'[{self.name}] Worker received kill signal, shutting down...')
                 break
 
             tries = 0
@@ -99,6 +99,8 @@ class DLWorker(Process):
                 self.o_q.put(DownloaderTaskResult(success=False, chunk_guid=job.guid, shm=job.shm, url=job.url))
                 continue
 
+        self.shm.close()
+
 
 class FileWorker(Process):
     def __init__(self, queue, out_queue, base_path, shm, cache_path=None):