From 7bc7aff1acb09e9275199398d3035e752d236b55 Mon Sep 17 00:00:00 2001
From: mac12m99 <10120390+mac12m99@users.noreply.github.com>
Date: Tue, 27 Apr 2021 22:11:42 +0200
Subject: [PATCH] TMDB: lock gestito globalmente

---
 core/tmdb.py             | 7 ++++---
 specials/globalsearch.py | 5 +++--
 2 files changed, 7 insertions(+), 5 deletions(-)

diff --git a/core/tmdb.py b/core/tmdb.py
index 82fe3949..3e1219b7 100644
--- a/core/tmdb.py
+++ b/core/tmdb.py
@@ -21,9 +21,11 @@ import ast, copy, re, time
 from core import filetools, httptools, jsontools, scrapertools
 from core.item import InfoLabels
 from platformcode import config, logger, platformtools
+import threading
 
 info_language = ["de", "en", "es", "fr", "it", "pt"] # from videolibrary.json
 def_lang = info_language[config.get_setting("info_language", "videolibrary")]
+lock = threading.Lock()
 
 # ------------------------------------------------- -------------------------------------------------- --------
 # Set of functions related to infoLabels.
@@ -200,11 +202,8 @@ def set_infoLabels_itemlist(item_list, seekTmdb=False, idioma_busqueda=def_lang,
 
     if not config.get_setting('tmdb_active') and not forced:
         return
-    import threading
-
     # threads_num = config.get_setting("tmdb_threads", default=20)
     # semaforo = threading.Semaphore(threads_num)
-    lock = threading.Lock()
     r_list = list()
     i = 0
     l_hilo = list()
@@ -217,6 +216,8 @@ def set_infoLabels_itemlist(item_list, seekTmdb=False, idioma_busqueda=def_lang,
         except:
             import traceback
             logger.error(traceback.format_exc(1))
+        if lock and lock.locked():
+            lock.release()
         # logger.debug(str(ret) + "item: " + _item.tostring())
         # semaforo.release()
         r_list.append((_i, _item, ret))
diff --git a/specials/globalsearch.py b/specials/globalsearch.py
index eb50490f..1afe7f0a 100644
--- a/specials/globalsearch.py
+++ b/specials/globalsearch.py
@@ -292,6 +292,7 @@ class SearchWindow(xbmcgui.WindowXML):
 
     def timer(self):
         while self.searchActions:
+            if self.exit: return
             percent = (float(self.count) / len(self.searchActions)) * 100
             self.LOADING.setVisible(False)
             self.PROGRESS.setPercent(percent)
@@ -325,15 +326,15 @@ class SearchWindow(xbmcgui.WindowXML):
                     if self.exit: return
                     self.search_threads.append(executor.submit(self.get_channel_results, searchAction))
                 for ch in futures.as_completed(self.search_threads):
+                    self.count += 1
                     if self.exit: return
                     if ch.result():
-                        self.count += 1
                         channel, valid, other = ch.result()
                         self.update(channel, valid, other)
         except:
             import traceback
             logger.error(traceback.format_exc())
-            self.count = len(self.searchActions)
+        self.count = len(self.searchActions)
 
     def get_channel_results(self, searchAction):
         def search(text):