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

perf: reduce logging for slow queries

Browse Source
This commit is contained in:
Greg Heartsfield 2022-12-18 20:47:11 -06:00
parent fb8375aef2
commit cf144d503d
1 changed files with 6 additions and 7 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

13
src/db.rs
View File

@ -647,7 +647,7 @@ pub async fn db_query(
// show pool stats // show pool stats
log_pool_stats(&pool); log_pool_stats(&pool);
// cutoff for displaying slow queries // cutoff for displaying slow queries
let slow_cutoff = Duration::from_millis(1000); let slow_cutoff = Duration::from_millis(2000);
let start = Instant::now(); let start = Instant::now();
let mut slow_first_event; let mut slow_first_event;
if let Ok(conn) = pool.get() { if let Ok(conn) = pool.get() {
@ -665,9 +665,9 @@ pub async fn db_query(
); );
first_result = false; first_result = false;
} }
// logging for slow queries; show sub and SQL // logging for slow queries; show sub and SQL.
// // to reduce logging; only show 1/16th of clients (leading 0)
if slow_first_event { if slow_first_event && client_id.starts_with('0') {
info!( info!(
"query req (slow): {:?} (cid: {}, sub: {:?})", "query req (slow): {:?} (cid: {}, sub: {:?})",
sub, client_id, sub.id sub, client_id, sub.id
@ -690,9 +690,8 @@ pub async fn db_query(
sub.id sub.id
); );
} }
// check if this is still active // check if this is still active; every 100 rows
// TODO: check every N rows if row_count % 100 == 0 && abandon_query_rx.try_recv().is_ok() {
if abandon_query_rx.try_recv().is_ok() {
debug!("query aborted (cid: {}, sub: {:?})", client_id, sub.id); debug!("query aborted (cid: {}, sub: {:?})", client_id, sub.id);
return Ok(()); return Ok(());
} }