stevazi/addon
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases 3 Wiki Activity

Probabile Fix Blocco Ricerca Globale

Browse Source
This commit is contained in:
Alhaziel01
2021-10-05 09:36:45 +02:00
parent d6b19b2966
commit 775b8745f8
1 changed files with 19 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

23
specials/globalsearch.py
View File

@@ -332,8 +332,22 @@ class SearchWindow(xbmcgui.WindowXML):
try:
with futures.ThreadPoolExecutor(max_workers=set_workers()) as executor:
for searchAction in self.getActions():
if self.exit: return
if self.exit: break
self.search_threads.append(executor.submit(self.get_channel_results, searchAction))
for res in futures.as_completed(self.search_threads):
if self.exit: break
if res.result():
channel, valid, results = res.result()
self.update(channel, valid, results)
# if results:
# name = results[0].channel
# if name not in results:
# self.channels[name] = []
# self.channels[name].extend(results)
# if valid or results:
# self.update()
except:
import traceback
logger.error(traceback.format_exc())
@@ -384,10 +398,11 @@ class SearchWindow(xbmcgui.WindowXML):
if self.exit:
return
update_lock.acquire()
# update_lock.acquire()
self.count += 1
self.update(channel, valid, other if other else results)
update_lock.release()
return channel, valid, other if other else results
# self.update(channel, valid, other if other else results)
# update_lock.release()
def makeItem(self, url):
item = Item().fromurl(url)