@@ -2117,7 +2117,7 @@ impl<Signer: Sign, M: Deref, T: Deref, K: Deref, F: Deref, L: Deref> ChannelMana
2117
2117
let ( monitor_update_option, mut failed_htlcs) = shutdown_res;
2118
2118
log_debug ! ( self . logger, "Finishing force-closure of channel with {} HTLCs to fail" , failed_htlcs. len( ) ) ;
2119
2119
for htlc_source in failed_htlcs. drain ( ..) {
2120
- self . fail_htlc_backwards_internal ( self . channel_state . lock ( ) . unwrap ( ) , htlc_source. 0 , & htlc_source. 1 , HTLCFailReason :: Reason { failure_code : 0x4000 | 8 , data : Vec :: new ( ) } , self . get_our_node_id ( ) ) ;
2120
+ self . fail_htlc_backwards_internal ( self . channel_state . lock ( ) . unwrap ( ) , htlc_source. 0 , & htlc_source. 1 , HTLCFailReason :: Reason { failure_code : 0x4000 | 8 , data : Vec :: new ( ) } , htlc_source . 2 ) ;
2121
2121
}
2122
2122
if let Some ( ( funding_txo, monitor_update) ) = monitor_update_option {
2123
2123
// There isn't anything we can do if we get an update failure - we're already
@@ -7059,7 +7059,7 @@ impl<'a, Signer: Sign, M: Deref, T: Deref, K: Deref, F: Deref, L: Deref>
7059
7059
} ;
7060
7060
7061
7061
for htlc_source in failed_htlcs. drain ( ..) {
7062
- channel_manager. fail_htlc_backwards_internal ( channel_manager. channel_state . lock ( ) . unwrap ( ) , htlc_source. 0 , & htlc_source. 1 , HTLCFailReason :: Reason { failure_code : 0x4000 | 8 , data : Vec :: new ( ) } , channel_manager . get_our_node_id ( ) ) ;
7062
+ channel_manager. fail_htlc_backwards_internal ( channel_manager. channel_state . lock ( ) . unwrap ( ) , htlc_source. 0 , & htlc_source. 1 , HTLCFailReason :: Reason { failure_code : 0x4000 | 8 , data : Vec :: new ( ) } , htlc_source . 2 ) ;
7063
7063
}
7064
7064
7065
7065
//TODO: Broadcast channel update for closed channels, but only after we've made a
0 commit comments