Skip to content

Commit b078172

Browse files
committed
Also update latest_sync_ timestamps in sync_wallets
... which we previously omitted.
1 parent d6e4570 commit b078172

File tree

1 file changed

+13
-0
lines changed

1 file changed

+13
-0
lines changed

src/lib.rs

Lines changed: 13 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -1097,6 +1097,8 @@ impl Node {
10971097
&*sync_cmon as &(dyn Confirm + Sync + Send),
10981098
&*sync_sweeper as &(dyn Confirm + Sync + Send),
10991099
];
1100+
let sync_wallet_timestamp = Arc::clone(&self.latest_wallet_sync_timestamp);
1101+
let sync_onchain_wallet_timestamp = Arc::clone(&self.latest_onchain_wallet_sync_timestamp);
11001102
let sync_monitor_archival_height = Arc::clone(&self.latest_channel_monitor_archival_height);
11011103

11021104
tokio::task::block_in_place(move || {
@@ -1110,6 +1112,11 @@ impl Node {
11101112
"Sync of on-chain wallet finished in {}ms.",
11111113
now.elapsed().as_millis()
11121114
);
1115+
let unix_time_secs_opt = SystemTime::now()
1116+
.duration_since(UNIX_EPOCH)
1117+
.ok()
1118+
.map(|d| d.as_secs());
1119+
*sync_onchain_wallet_timestamp.write().unwrap() = unix_time_secs_opt;
11131120
},
11141121
Err(e) => {
11151122
log_error!(sync_logger, "Sync of on-chain wallet failed: {}", e);
@@ -1126,6 +1133,12 @@ impl Node {
11261133
now.elapsed().as_millis()
11271134
);
11281135

1136+
let unix_time_secs_opt = SystemTime::now()
1137+
.duration_since(UNIX_EPOCH)
1138+
.ok()
1139+
.map(|d| d.as_secs());
1140+
*sync_wallet_timestamp.write().unwrap() = unix_time_secs_opt;
1141+
11291142
periodically_archive_fully_resolved_monitors(
11301143
archive_cman,
11311144
archive_cmon,

0 commit comments

Comments
 (0)