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