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

improvement: log write pool

Browse Source
This commit is contained in:
Greg Heartsfield 2022-12-20 13:21:57 -06:00
parent 86bb7aeb9a
commit cd1557787b
1 changed files with 5 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

9
src/db.rs
View File

@ -243,6 +243,7 @@ pub async fn db_writer(
); );
event_write = true event_write = true
} else { } else {
log_pool_stats("writer", &pool);
match write_event(&mut pool.get()?, &event) { match write_event(&mut pool.get()?, &event) {
Ok(updated) => { Ok(updated) => {
if updated == 0 { if updated == 0 {
@ -620,12 +621,12 @@ fn _pool_at_capacity(pool: &SqlitePool) -> bool {
state.idle_connections == 0 state.idle_connections == 0
} }
fn log_pool_stats(pool: &SqlitePool) { fn log_pool_stats(name: &str, pool: &SqlitePool) {
let state: r2d2::State = pool.state(); let state: r2d2::State = pool.state();
let in_use_cxns = state.connections - state.idle_connections; let in_use_cxns = state.connections - state.idle_connections;
debug!( debug!(
"DB pool usage (in_use: {}, available: {})", "DB pool {:?} usage (in_use: {}, available: {})",
in_use_cxns, state.connections name, in_use_cxns, state.connections
); );
} }
@ -658,7 +659,7 @@ pub async fn db_query(
let (q, p) = query_from_sub(&sub); let (q, p) = query_from_sub(&sub);
debug!("SQL generated in {:?}", start.elapsed()); debug!("SQL generated in {:?}", start.elapsed());
// show pool stats // show pool stats
log_pool_stats(&pool); log_pool_stats("reader", &pool);
// cutoff for displaying slow queries // cutoff for displaying slow queries
let slow_cutoff = Duration::from_millis(2000); let slow_cutoff = Duration::from_millis(2000);
// any client that doesn't cause us to generate new rows in 5 // any client that doesn't cause us to generate new rows in 5