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

improvement: reduce logging

Browse Source
This commit is contained in:
Greg Heartsfield 2022-12-22 10:29:27 -06:00
parent 168cf513ac
commit 53c2a8051c
2 changed files with 7 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
src/db.rs
View File

@ -715,7 +715,10 @@ pub async fn db_query(
let mut row_count: usize = 0; let mut row_count: usize = 0;
// generate SQL query // generate SQL query
let (q, p) = query_from_sub(&sub); let (q, p) = query_from_sub(&sub);
debug!("SQL generated in {:?}", start.elapsed()); let sql_gen_elapsed = start.elapsed();
if sql_gen_elapsed > Duration::from_millis(10) {
debug!("SQL (slow) generated in {:?}", start.elapsed());
}
// show pool stats // show pool stats
log_pool_stats("reader", &pool); log_pool_stats("reader", &pool);
// cutoff for displaying slow queries // cutoff for displaying slow queries

6
src/server.rs
View File

@ -248,10 +248,10 @@ pub fn start_server(settings: Settings, shutdown_rx: MpscReceiver<()>) -> Result
// limit concurrent SQLite blocking threads // limit concurrent SQLite blocking threads
.max_blocking_threads(settings.limits.max_blocking_threads) .max_blocking_threads(settings.limits.max_blocking_threads)
.on_thread_start(|| { .on_thread_start(|| {
debug!("started new thread"); trace!("started new thread");
}) })
.on_thread_stop(|| { .on_thread_stop(|| {
debug!("stopping thread"); trace!("stopping thread");
}) })
.build() .build()
.unwrap(); .unwrap();
@ -538,7 +538,7 @@ async fn nostr_server(
// TODO: serialize at broadcast time, instead of // TODO: serialize at broadcast time, instead of
// once for each consumer. // once for each consumer.
if let Ok(event_str) = serde_json::to_string(&global_event) { if let Ok(event_str) = serde_json::to_string(&global_event) {
debug!("sub match for client: {}, sub: {:?}, event: {:?}", trace!("sub match for client: {}, sub: {:?}, event: {:?}",
cid, s, cid, s,
global_event.get_event_id_prefix()); global_event.get_event_id_prefix());
// create an event response and send it // create an event response and send it