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

perf: shed DB query load when queue gets large

Browse Source
This commit is contained in:
Greg Heartsfield 2022-12-20 13:23:21 -06:00
parent dc11d9a619
commit 1c153bc784
1 changed files with 10 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

12
src/db.rs
View File

@ -647,8 +647,16 @@ pub async fn db_query(
let pre_spawn_start = Instant::now(); let pre_spawn_start = Instant::now();
task::spawn_blocking(move || { task::spawn_blocking(move || {
let db_queue_time = pre_spawn_start.elapsed(); let db_queue_time = pre_spawn_start.elapsed();
// report queuing time if it is slow // if the queue time was very long (>5 seconds), spare the DB and abort.
if db_queue_time > Duration::from_secs(1) { if db_queue_time > Duration::from_secs(5) {
info!(
"shedding DB query load from {:?} (cid: {}, sub: {:?})",
db_queue_time, client_id, sub.id
);
return Ok(());
}
// otherwise, report queuing time if it is slow
else if db_queue_time > Duration::from_secs(1) {
debug!( debug!(
"(slow) DB query queued for {:?} (cid: {}, sub: {:?})", "(slow) DB query queued for {:?} (cid: {}, sub: {:?})",
db_queue_time, client_id, sub.id db_queue_time, client_id, sub.id