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: tweak sub/sql logging for slow queries

Browse Source
This commit is contained in:
Greg Heartsfield 2022-12-16 14:55:45 -06:00
parent b0bfaa48fc
commit e554b10ac2
1 changed files with 16 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

20
src/db.rs
View File

@ -611,7 +611,6 @@ pub async fn db_query(
mut abandon_query_rx: tokio::sync::oneshot::Receiver<()>, mut abandon_query_rx: tokio::sync::oneshot::Receiver<()>,
) { ) {
task::spawn_blocking(move || { task::spawn_blocking(move || {
trace!("going to query for: {:?}", sub);
let mut row_count: usize = 0; let mut row_count: usize = 0;
let start = Instant::now(); let start = Instant::now();
// generate SQL query // generate SQL query
@ -620,7 +619,7 @@ pub async fn db_query(
// show pool stats // show pool stats
debug!("DB pool stats: {:?}", pool.state()); debug!("DB pool stats: {:?}", pool.state());
// cutoff for displaying slow queries // cutoff for displaying slow queries
let slow_cutoff = Duration::from_millis(200); let slow_cutoff = Duration::from_millis(1000);
let start = Instant::now(); let start = Instant::now();
if let Ok(conn) = pool.get() { if let Ok(conn) = pool.get() {
// execute the query. Don't cache, since queries vary so much. // execute the query. Don't cache, since queries vary so much.
@ -630,10 +629,23 @@ pub async fn db_query(
while let Some(row) = event_rows.next()? { while let Some(row) = event_rows.next()? {
if first_result { if first_result {
let first_result_elapsed = start.elapsed(); let first_result_elapsed = start.elapsed();
// logging for slow queries // logging for slow queries; show sub and SQL
if first_result_elapsed >= slow_cutoff { if first_result_elapsed >= slow_cutoff {
info!("final query string (slow): {}", q); info!(
"going to query for: {:?} (cid={}, sub={:?})",
sub, client_id, sub.id
);
info!(
"final query string (slow): {} (cid={}, sub={:?})",
q, client_id, sub.id
);
} else { } else {
trace!(
"going to query for: {:?} (cid={}, sub={:?})",
sub,
client_id,
sub.id
);
trace!("final query string: {}", q); trace!("final query string: {}", q);
} }
debug!( debug!(