From 6e2872f43625aba71eba019e16f7fbd74743f590 Mon Sep 17 00:00:00 2001
From: Alexandre Flament <alex@al-f.net>
Date: Tue, 5 Jan 2021 11:22:48 +0100
Subject: [enh] add searx.shared

shared dictionary between the workers (UWSGI or werkzeug)
scheduler: run a task once every x seconds (UWSGI or werkzeug)
---
 searx/shared/shared_simple.py | 38 ++++++++++++++++++++++++++++++++++++++
 1 file changed, 38 insertions(+)
 create mode 100644 searx/shared/shared_simple.py

(limited to 'searx/shared/shared_simple.py')

diff --git a/searx/shared/shared_simple.py b/searx/shared/shared_simple.py
new file mode 100644
index 000000000..5b970aad9
--- /dev/null
+++ b/searx/shared/shared_simple.py
@@ -0,0 +1,38 @@
+# SPDX-License-Identifier: AGPL-3.0-or-later
+
+import threading
+
+from . import shared_abstract
+
+
+class SimpleSharedDict(shared_abstract.SharedDict):
+
+    __slots__ = 'd',
+
+    def __init__(self):
+        self.d = {}
+
+    def get_int(self, key):
+        return self.d.get(key, None)
+
+    def set_int(self, key, value):
+        self.d[key] = value
+
+    def get_str(self, key):
+        return self.d.get(key, None)
+
+    def set_str(self, key, value):
+        self.d[key] = value
+
+
+def schedule(delay, func, *args):
+    def call_later():
+        t = threading.Timer(delay, wrapper)
+        t.daemon = True
+        t.start()
+
+    def wrapper():
+        call_later()
+        func(*args)
+
+    call_later()
-- 
cgit v1.2.3


From 912c7e975c3943db798d748fa48d460467b66d30 Mon Sep 17 00:00:00 2001
From: Alexandre Flament <alex@al-f.net>
Date: Wed, 13 Jan 2021 14:07:39 +0100
Subject: [fix] checker: don't run the checker when uwsgi is not properly
 configured

Before this commit, even with the scheduler disabled, the checker was running
at least once for each uwsgi worker.
---
 searx/shared/shared_simple.py | 1 +
 1 file changed, 1 insertion(+)

(limited to 'searx/shared/shared_simple.py')

diff --git a/searx/shared/shared_simple.py b/searx/shared/shared_simple.py
index 5b970aad9..48d8cb822 100644
--- a/searx/shared/shared_simple.py
+++ b/searx/shared/shared_simple.py
@@ -36,3 +36,4 @@ def schedule(delay, func, *args):
         func(*args)
 
     call_later()
+    return True
-- 
cgit v1.2.3