From 3fcaf97a158eb4be1063f24f6d3c0330a7484c35 Mon Sep 17 00:00:00 2001 From: Greg Heartsfield Date: Mon, 30 Jan 2023 18:02:40 -0600 Subject: [PATCH] improvement: move sqlite connection acquisition into blocking thread --- src/repo/sqlite.rs | 4 +++- 1 file changed, 3 insertions(+), 1 deletion(-) diff --git a/src/repo/sqlite.rs b/src/repo/sqlite.rs index 17b497c..0d7fd09 100644 --- a/src/repo/sqlite.rs +++ b/src/repo/sqlite.rs @@ -282,9 +282,11 @@ impl NostrRepo for SqliteRepo { let start = Instant::now(); let _write_guard = self.write_in_progress.lock().await; // spawn a blocking thread - let mut conn = self.write_pool.get()?; + //let mut conn = self.write_pool.get()?; + let pool = self.write_pool.clone(); let e = e.clone(); let event_count = task::spawn_blocking(move || { + let mut conn = pool.get()?; SqliteRepo::persist_event(&mut conn, &e) }).await?; self.metrics