Skip to content

Commit 8775862

Browse files
committed
f Start measuring sync time right before we sync
1 parent c68aaac commit 8775862

File tree

1 file changed

+2
-2
lines changed

1 file changed

+2
-2
lines changed

src/lib.rs

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -799,12 +799,12 @@ impl<K: KVStore + Sync + Send + 'static> Node<K> {
799799
onchain_wallet_sync_interval
800800
.set_missed_tick_behavior(tokio::time::MissedTickBehavior::Skip);
801801
loop {
802-
let now = Instant::now();
803802
tokio::select! {
804803
_ = stop_sync.changed() => {
805804
return;
806805
}
807806
_ = onchain_wallet_sync_interval.tick() => {
807+
let now = Instant::now();
808808
match wallet.sync().await {
809809
Ok(()) => log_trace!(
810810
sync_logger,
@@ -838,7 +838,6 @@ impl<K: KVStore + Sync + Send + 'static> Node<K> {
838838
tokio::time::interval(Duration::from_secs(wallet_sync_interval_secs));
839839
wallet_sync_interval.set_missed_tick_behavior(tokio::time::MissedTickBehavior::Skip);
840840
loop {
841-
let now = Instant::now();
842841
tokio::select! {
843842
_ = stop_sync.changed() => {
844843
return;
@@ -848,6 +847,7 @@ impl<K: KVStore + Sync + Send + 'static> Node<K> {
848847
&*sync_cman as &(dyn Confirm + Sync + Send),
849848
&*sync_cmon as &(dyn Confirm + Sync + Send),
850849
];
850+
let now = Instant::now();
851851
match tx_sync.sync(confirmables).await {
852852
Ok(()) => log_trace!(
853853
sync_logger,

0 commit comments

Comments
 (0)