rafaelcaricio/relay
1
0
Fork 0
forked from mirrors/relay
Code Pull requests Activity

Add complete to signature thread duration

Browse source
This commit is contained in:
asonix 2023-07-27 10:39:24 -05:00
parent 769f7451f9
commit 5de244b848
1 changed files with 2 additions and 4 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

6
src/spawner.rs
View file

@ -12,11 +12,9 @@ fn signature_thread(receiver: flume::Receiver<Box<dyn FnOnce() + Send>>, id: usi
while let Ok(f) = receiver.recv() { while let Ok(f) = receiver.recv() {
let start = Instant::now(); let start = Instant::now();
metrics::increment_counter!("relay.signature-thread.operation.start", "id" => id.to_string()); metrics::increment_counter!("relay.signature-thread.operation.start", "id" => id.to_string());
let res = std::panic::catch_unwind(AssertUnwindSafe(move || { let res = std::panic::catch_unwind(AssertUnwindSafe(f));
(f)();
}));
metrics::increment_counter!("relay.signature-thread.operation.end", "complete" => res.is_ok().to_string(), "id" => id.to_string()); metrics::increment_counter!("relay.signature-thread.operation.end", "complete" => res.is_ok().to_string(), "id" => id.to_string());
metrics::histogram!("relay.signature-thread.operation.duration", start.elapsed().as_secs_f64(), "id" => id.to_string()); metrics::histogram!("relay.signature-thread.operation.duration", start.elapsed().as_secs_f64(), "complete" => res.is_ok().to_string(), "id" => id.to_string());
if let Err(e) = res { if let Err(e) = res {
tracing::warn!("Signature fn panicked: {e:?}"); tracing::warn!("Signature fn panicked: {e:?}");