From c84205ed9b501b9709aa4620ed4ea91952557c20 Mon Sep 17 00:00:00 2001
From: jesopo
Date: Sun, 11 Nov 2018 12:40:24 +0000
Subject: Add a `threading.Lock()` around `cursor.execute(...)` in Database.py

---
 src/Database.py | 5 +++--
 1 file changed, 3 insertions(+), 2 deletions(-)

(limited to 'src/Database.py')

diff --git a/src/Database.py b/src/Database.py
index 1ed977de..28d86960 100644
--- a/src/Database.py
+++ b/src/Database.py
@@ -274,6 +274,7 @@ class Database(object):
             check_same_thread=False, isolation_level=None)
         self.database.execute("PRAGMA foreign_keys = ON")
         self._cursor = None
+        self._lock = threading.Lock()
 
         self.make_servers_table()
         self.make_channels_table()
@@ -307,8 +308,8 @@ class Database(object):
         start = time.monotonic()
 
         cursor = self.cursor()
-        cursor.execute(query, params)
-        value = fetch_func(cursor)
+        with self._lock:
+            cursor.execute(query, params)
 
         end = time.monotonic()
         total_milliseconds = (end - start) * 1000
-- 
cgit v1.3.1-10-gc9f91