Archives/searxng
2
0
Fork 1
mirror of https://github.com/searxng/searxng synced 2024-11-03 09:40:20 +00:00
Code Issues Packages Projects Releases Wiki Activity

[fix] searx.results: fix pylint issue "useless-with-lock"

Browse Source 
Replace "with threading.Lock():" by "with self._lock"
This commit is contained in:
Alexandre Flament 2021-11-26 08:46:43 +01:00
parent da1d502cf7
commit 0d41f26a20
1 changed files with 16 additions and 13 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

29
searx/results.py
View File

@ -145,7 +145,8 @@ class ResultContainer:
"""docstring for ResultContainer""" """docstring for ResultContainer"""
__slots__ = '_merged_results', 'infoboxes', 'suggestions', 'answers', 'corrections', '_number_of_results',\ __slots__ = '_merged_results', 'infoboxes', 'suggestions', 'answers', 'corrections', '_number_of_results',\
'_closed', 'paging', 'unresponsive_engines', 'timings', 'redirect_url', 'engine_data', 'on_result' '_closed', 'paging', 'unresponsive_engines', 'timings', 'redirect_url', 'engine_data', 'on_result',\
'_lock'
def __init__(self): def __init__(self):
super().__init__() super().__init__()
@ -162,6 +163,7 @@ class ResultContainer:
self.timings = [] self.timings = []
self.redirect_url = None self.redirect_url = None
self.on_result = lambda _: True self.on_result = lambda _: True
self._lock = RLock()
def extend(self, engine_name, results): def extend(self, engine_name, results):
if self._closed: if self._closed:
@ -216,10 +218,11 @@ class ResultContainer:
infobox['engines'] = set([infobox['engine']]) infobox['engines'] = set([infobox['engine']])
if infobox_id is not None: if infobox_id is not None:
parsed_url_infobox_id = urlparse(infobox_id) parsed_url_infobox_id = urlparse(infobox_id)
for existingIndex in self.infoboxes: with self._lock:
if compare_urls(urlparse(existingIndex.get('id', '')), parsed_url_infobox_id): for existingIndex in self.infoboxes:
merge_two_infoboxes(existingIndex, infobox) if compare_urls(urlparse(existingIndex.get('id', '')), parsed_url_infobox_id):
add_infobox = False merge_two_infoboxes(existingIndex, infobox)
add_infobox = False
if add_infobox: if add_infobox:
self.infoboxes.append(infobox) self.infoboxes.append(infobox)
@ -262,14 +265,14 @@ class ResultContainer:
def __merge_url_result(self, result, position): def __merge_url_result(self, result, position):
result['engines'] = set([result['engine']]) result['engines'] = set([result['engine']])
duplicated = self.__find_duplicated_http_result(result) with self._lock:
if duplicated: duplicated = self.__find_duplicated_http_result(result)
self.__merge_duplicated_http_result(duplicated, result, position) if duplicated:
return self.__merge_duplicated_http_result(duplicated, result, position)
return
# if there is no duplicate found, append result # if there is no duplicate found, append result
result['positions'] = [position] result['positions'] = [position]
with RLock():
self._merged_results.append(result) self._merged_results.append(result)
def __find_duplicated_http_result(self, result): def __find_duplicated_http_result(self, result):
@ -314,7 +317,7 @@ class ResultContainer:
def __merge_result_no_url(self, result, position): def __merge_result_no_url(self, result, position):
result['engines'] = set([result['engine']]) result['engines'] = set([result['engine']])
result['positions'] = [position] result['positions'] = [position]
with RLock(): with self._lock:
self._merged_results.append(result) self._merged_results.append(result)
def close(self): def close(self):