From caa0cbfe1d932beb1f2a704f547e9d5b46355bcd Mon Sep 17 00:00:00 2001
From: Jonathan de Jong <jonathan@automatia.nl>
Date: Sun, 11 Jul 2021 21:48:55 +0200
Subject: [PATCH] change fairmutex to mutex

---
 src/database/abstraction/sqlite.rs | 8 ++++----
 1 file changed, 4 insertions(+), 4 deletions(-)

diff --git a/src/database/abstraction/sqlite.rs b/src/database/abstraction/sqlite.rs
index 310e03aa..fe548133 100644
--- a/src/database/abstraction/sqlite.rs
+++ b/src/database/abstraction/sqlite.rs
@@ -16,7 +16,7 @@ use super::{DatabaseEngine, Tree};
 use log::debug;
 
 use crossbeam::channel::{bounded, Sender as ChannelSender};
-use parking_lot::{FairMutex, FairMutexGuard, Mutex, MutexGuard, RwLock};
+use parking_lot::{Mutex, MutexGuard, RwLock};
 use rusqlite::{params, Connection, DatabaseName::Main, OptionalExtension};
 
 use tokio::sync::oneshot::Sender;
@@ -33,7 +33,7 @@ use tokio::sync::oneshot::Sender;
 //     "SELECT key, value FROM {} WHERE key <= ? ORDER BY DESC";
 
 struct Pool {
-    writer: FairMutex<Connection>,
+    writer: Mutex<Connection>,
     readers: Vec<Mutex<Connection>>,
     spill_tracker: Arc<()>,
     path: PathBuf,
@@ -59,7 +59,7 @@ impl<'a> Deref for HoldingConn<'a> {
 
 impl Pool {
     fn new<P: AsRef<Path>>(path: P, num_readers: usize, cache_size: u32) -> Result<Self> {
-        let writer = FairMutex::new(Self::prepare_conn(&path, Some(cache_size))?);
+        let writer = Mutex::new(Self::prepare_conn(&path, Some(cache_size))?);
 
         let mut readers = Vec::new();
 
@@ -93,7 +93,7 @@ impl Pool {
         Ok(conn)
     }
 
-    fn write_lock(&self) -> FairMutexGuard<'_, Connection> {
+    fn write_lock(&self) -> MutexGuard<'_, Connection> {
         self.writer.lock()
     }