From 9ce83025b449c500b237f6fbb7f3db8e57fb92b7 Mon Sep 17 00:00:00 2001
From: Brandon Thomas <echelon@gmail.com>
Date: Tue, 8 Jun 2021 00:47:41 -0400
Subject: [PATCH] mutual exclusion seems to work well!

---
 src/job_queries/tts_inference_job_queries.rs | 2 ++
 src/tts_inference_job.rs                     | 4 ++--
 2 files changed, 4 insertions(+), 2 deletions(-)

diff --git a/src/job_queries/tts_inference_job_queries.rs b/src/job_queries/tts_inference_job_queries.rs
index 9d1450facd..7025efc721 100644
--- a/src/job_queries/tts_inference_job_queries.rs
+++ b/src/job_queries/tts_inference_job_queries.rs
@@ -138,6 +138,8 @@ FOR UPDATE
   info!("Can acquire lock??? {}", can_transact);
 
   if !can_transact {
+    info!("returning");
+    transaction.rollback().await?;
     return Ok(false);
   }
 
diff --git a/src/tts_inference_job.rs b/src/tts_inference_job.rs
index f538d09ef1..961dbb7215 100644
--- a/src/tts_inference_job.rs
+++ b/src/tts_inference_job.rs
@@ -223,7 +223,7 @@ async fn main_loop(inferencer: Inferencer) {
 
     if jobs.is_empty() {
       info!("No jobs!");
-      std::thread::sleep(Duration::from_millis(1500));
+      std::thread::sleep(Duration::from_millis(20));
       continue;
     }
 
@@ -241,7 +241,7 @@ async fn main_loop(inferencer: Inferencer) {
 
     timeout_millis = START_TIMEOUT_MILLIS; // reset
 
-    std::thread::sleep(Duration::from_millis(500));
+    std::thread::sleep(Duration::from_millis(20));
   }
 }