diff options
| author | Alexandre Flament <alex@al-f.net> | 2021-04-13 15:21:53 +0200 |
|---|---|---|
| committer | Alexandre Flament <alex@al-f.net> | 2021-04-21 16:24:46 +0200 |
| commit | aae7830d14242ac1f98232f428654c5d2c9c5eb2 (patch) | |
| tree | 83df1950b7b5889fb17eda740a095022a816642e /searx/search/checker | |
| parent | ae5954f2dad0386868709a59a1b29d005ebb2b2d (diff) | |
[mod] refactoring: processors
Report to the user suspended engines.
searx.search.processor.abstract:
* manages suspend time (per network).
* reports suspended time to the ResultContainer (method extend_container_if_suspended)
* adds the results to the ResultContainer (method extend_container)
* handles exceptions (method handle_exception)
Diffstat (limited to 'searx/search/checker')
| -rw-r--r-- | searx/search/checker/impl.py | 3 |
1 files changed, 1 insertions, 2 deletions
diff --git a/searx/search/checker/impl.py b/searx/search/checker/impl.py index e54b3f68..1893a82b 100644 --- a/searx/search/checker/impl.py +++ b/searx/search/checker/impl.py @@ -4,7 +4,6 @@ import typing import types import functools import itertools -import threading from time import time from urllib.parse import urlparse @@ -385,7 +384,7 @@ class Checker: engineref_category = search_query.engineref_list[0].category params = self.processor.get_params(search_query, engineref_category) if params is not None: - with threading.RLock(): + with self.processor.lock: self.processor.engine.stats['sent_search_count'] += 1 self.processor.search(search_query.query, params, result_container, time(), 5) return result_container |