From bf0a65f829ce5b72f0a310ca8b18416df27542a2 Mon Sep 17 00:00:00 2001
From: JohnnyFFM <JohnnyDeluxe@habmalnefrage.de>
Date: Sat, 5 Jun 2021 09:16:53 +0200
Subject: [PATCH] added wallet/pool response time output

---
 src/requests.rs | 11 ++++++++---
 1 file changed, 8 insertions(+), 3 deletions(-)

diff --git a/src/requests.rs b/src/requests.rs
index b714b78..4dc2c54 100644
--- a/src/requests.rs
+++ b/src/requests.rs
@@ -10,6 +10,7 @@ use std::u64;
 use tokio;
 use tokio::runtime::TaskExecutor;
 use url::Url;
+use stopwatch::Stopwatch;
 
 #[derive(Clone)]
 pub struct RequestHandler {
@@ -66,10 +67,13 @@ impl RequestHandler {
         let stream = PrioRetry::new(rx, Duration::from_secs(3))
             .and_then(move |submission_params| {
                 let tx_submit_data = tx_submit_data.clone();
+                let mut sw = Stopwatch::new();
+                sw.start();
                 client
                     .clone()
                     .submit_nonce(&submission_params)
                     .then(move |res| {
+                        sw.stop();
                         match res {
                             Ok(res) => {
                                 if submission_params.deadline != res.deadline {
@@ -85,6 +89,7 @@ impl RequestHandler {
                                         submission_params.account_id,
                                         submission_params.nonce,
                                         submission_params.deadline,
+                                        sw.elapsed_ms()
                                     );
                                 }
                             }
@@ -201,10 +206,10 @@ fn log_submission_not_accepted(
     );
 }
 
-fn log_submission_accepted(account_id: u64, nonce: u64, deadline: u64) {
+fn log_submission_accepted(account_id: u64, nonce: u64, deadline: u64, latency: i64) {
     info!(
-        "deadline accepted: account={}, nonce={}, deadline={}",
-        account_id, nonce, deadline
+        "deadline accepted: account={}, nonce={}, deadline={}, latency={}ms",
+        account_id, nonce, deadline, latency
     );
 }