diff --git a/src/database/database-thread.c b/src/database/database-thread.c
index a8671de0..19d877cc 100644
--- a/src/database/database-thread.c
+++ b/src/database/database-thread.c
@@ -77,7 +77,9 @@ void *DB_thread(void *val)
 		// Do this once per second
 		if(now > before)
 		{
+			lock_shm();
 			queries_to_database();
+			unlock_shm();
 			before = now;
 		}