nostr/nostr-rs-relay
1
0
Fork 0
mirror of https://github.com/scsibug/nostr-rs-relay.git synced 2024-11-24 17:49:07 -05:00
Code Issues Packages Projects Releases Wiki Activity

improvement: move sqlite connection acquisition into blocking thread

Browse Source
This commit is contained in:
Greg Heartsfield 2023-01-30 18:02:40 -06:00
parent cec501b37f
commit 3fcaf97a15
1 changed files with 3 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
src/repo/sqlite.rs
View File

@ -282,9 +282,11 @@ impl NostrRepo for SqliteRepo {
let start = Instant::now(); let start = Instant::now();
let _write_guard = self.write_in_progress.lock().await; let _write_guard = self.write_in_progress.lock().await;
// spawn a blocking thread // 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 e = e.clone();
let event_count = task::spawn_blocking(move || { let event_count = task::spawn_blocking(move || {
let mut conn = pool.get()?;
SqliteRepo::persist_event(&mut conn, &e) SqliteRepo::persist_event(&mut conn, &e)
}).await?; }).await?;
self.metrics self.metrics