@@ -2236,15 +2236,13 @@ impl ChannelMonitor {
2236
2236
}
2237
2237
}
2238
2238
}
2239
- let mut pending_claims = Vec :: new ( ) ;
2240
2239
if let Some ( ref cur_local_tx) = self . current_local_signed_commitment_tx {
2241
2240
if self . would_broadcast_at_height ( height) {
2242
2241
broadcaster. broadcast_transaction ( & cur_local_tx. tx ) ;
2243
2242
match self . key_storage {
2244
2243
Storage :: Local { ref delayed_payment_base_key, ref latest_per_commitment_point, .. } => {
2245
- let ( txs, mut spendable_output, new_outputs, mut pending_txn ) = self . broadcast_by_local_state ( & cur_local_tx, latest_per_commitment_point, & Some ( * delayed_payment_base_key) , height) ;
2244
+ let ( txs, mut spendable_output, new_outputs, _ ) = self . broadcast_by_local_state ( & cur_local_tx, latest_per_commitment_point, & Some ( * delayed_payment_base_key) , height) ;
2246
2245
spendable_outputs. append ( & mut spendable_output) ;
2247
- pending_claims. append ( & mut pending_txn) ;
2248
2246
if !new_outputs. is_empty ( ) {
2249
2247
watch_outputs. push ( ( cur_local_tx. txid . clone ( ) , new_outputs) ) ;
2250
2248
}
@@ -2253,9 +2251,8 @@ impl ChannelMonitor {
2253
2251
}
2254
2252
} ,
2255
2253
Storage :: Watchtower { .. } => {
2256
- let ( txs, mut spendable_output, new_outputs, mut pending_txn ) = self . broadcast_by_local_state ( & cur_local_tx, & None , & None , height) ;
2254
+ let ( txs, mut spendable_output, new_outputs, _ ) = self . broadcast_by_local_state ( & cur_local_tx, & None , & None , height) ;
2257
2255
spendable_outputs. append ( & mut spendable_output) ;
2258
- pending_claims. append ( & mut pending_txn) ;
2259
2256
if !new_outputs. is_empty ( ) {
2260
2257
watch_outputs. push ( ( cur_local_tx. txid . clone ( ) , new_outputs) ) ;
2261
2258
}
@@ -2266,12 +2263,6 @@ impl ChannelMonitor {
2266
2263
}
2267
2264
}
2268
2265
}
2269
- for claim in pending_claims {
2270
- match self . our_claim_txn_waiting_first_conf . entry ( claim. 0 ) {
2271
- hash_map:: Entry :: Occupied ( _) => { } ,
2272
- hash_map:: Entry :: Vacant ( entry) => { entry. insert ( claim. 1 ) ; }
2273
- }
2274
- }
2275
2266
if let Some ( events) = self . onchain_events_waiting_threshold_conf . remove ( & height) {
2276
2267
for ev in events {
2277
2268
match ev {
0 commit comments