Skip to content

Commit 3bb6762

Browse files
committed
f more log + better var names
1 parent 7670967 commit 3bb6762

File tree

1 file changed

+8
-5
lines changed

1 file changed

+8
-5
lines changed

lightning/src/chain/channelmonitor.rs

+8-5
Original file line numberDiff line numberDiff line change
@@ -3111,17 +3111,20 @@ impl<Signer: Sign> ChannelMonitorImpl<Signer> {
31113111
F::Target: FeeEstimator,
31123112
L::Target: Logger,
31133113
{
3114-
let mut height = None;
3114+
let mut removed_height = None;
31153115
for entry in self.onchain_events_awaiting_threshold_conf.iter() {
31163116
if entry.txid == *txid {
3117-
height = Some(entry.height);
3117+
removed_height = Some(entry.height);
31183118
break;
31193119
}
31203120
}
31213121

3122-
if let Some(height) = height {
3123-
log_info!(logger, "transaction_unconfirmed of txid {} implies height {} was reorg'd out", txid, height);
3124-
self.onchain_events_awaiting_threshold_conf.retain(|ref entry| entry.height < height);
3122+
if let Some(removed_height) = removed_height {
3123+
log_info!(logger, "transaction_unconfirmed of txid {} implies height {} was reorg'd out", txid, removed_height);
3124+
self.onchain_events_awaiting_threshold_conf.retain(|ref entry| if entry.height >= removed_height {
3125+
log_info!(logger, "Transaction {} reorg'd out", entry.txid);
3126+
false
3127+
} else { true });
31253128
}
31263129

31273130
debug_assert!(!self.onchain_events_awaiting_threshold_conf.iter().any(|ref entry| entry.txid == *txid));

0 commit comments

Comments
 (0)