@@ -3620,7 +3620,10 @@ impl<Signer: Sign, M: Deref, T: Deref, K: Deref, F: Deref, L: Deref> ChannelMana
3620
3620
// Fail a list of HTLCs that were just freed from the holding cell. The HTLCs need to be
3621
3621
// failed backwards or, if they were one of our outgoing HTLCs, then their failure needs to
3622
3622
// be surfaced to the user.
3623
- fn fail_holding_cell_htlcs ( & self , mut htlcs_to_fail : Vec < ( HTLCSource , PaymentHash ) > , channel_id : [ u8 ; 32 ] , _counterparty_node_id : & PublicKey ) {
3623
+ fn fail_holding_cell_htlcs (
3624
+ & self , mut htlcs_to_fail : Vec < ( HTLCSource , PaymentHash ) > , channel_id : [ u8 ; 32 ] ,
3625
+ _counterparty_node_id : & PublicKey
3626
+ ) {
3624
3627
for ( htlc_src, payment_hash) in htlcs_to_fail. drain ( ..) {
3625
3628
match htlc_src {
3626
3629
HTLCSource :: PreviousHopData ( HTLCPreviousHopData { .. } ) => {
@@ -5066,7 +5069,11 @@ impl<Signer: Sign, M: Deref, T: Deref, K: Deref, F: Deref, L: Deref> ChannelMana
5066
5069
match chan. maybe_free_holding_cell_htlcs ( & self . logger ) {
5067
5070
Ok ( ( commitment_opt, holding_cell_failed_htlcs) ) => {
5068
5071
if !holding_cell_failed_htlcs. is_empty ( ) {
5069
- failed_htlcs. push ( ( holding_cell_failed_htlcs, * channel_id, chan. get_counterparty_node_id ( ) ) ) ;
5072
+ failed_htlcs. push ( (
5073
+ holding_cell_failed_htlcs,
5074
+ * channel_id,
5075
+ chan. get_counterparty_node_id ( )
5076
+ ) ) ;
5070
5077
}
5071
5078
if let Some ( ( commitment_update, monitor_update) ) = commitment_opt {
5072
5079
if let Err ( e) = self . chain_monitor . update_channel ( chan. get_funding_txo ( ) . unwrap ( ) , monitor_update) {
0 commit comments