@@ -5498,7 +5498,7 @@ impl<Signer: Sign> Channel<Signer> {
5498
5498
/// those explicitly stated to be allowed after shutdown completes, eg some simple getters).
5499
5499
/// Also returns the list of payment_hashes for channels which we can safely fail backwards
5500
5500
/// immediately (others we will have to allow to time out).
5501
- pub fn force_shutdown ( & mut self , should_broadcast : bool ) -> ( Option < ( OutPoint , ChannelMonitorUpdate ) > , Vec < ( HTLCSource , PaymentHash ) > ) {
5501
+ pub fn force_shutdown ( & mut self , should_broadcast : bool ) -> ( Option < ( OutPoint , ChannelMonitorUpdate ) > , Vec < ( HTLCSource , PaymentHash , PublicKey ) > ) {
5502
5502
// Note that we MUST only generate a monitor update that indicates force-closure - we're
5503
5503
// called during initialization prior to the chain_monitor in the encompassing ChannelManager
5504
5504
// being fully configured in some cases. Thus, its likely any monitor events we generate will
@@ -5508,10 +5508,11 @@ impl<Signer: Sign> Channel<Signer> {
5508
5508
// We go ahead and "free" any holding cell HTLCs or HTLCs we haven't yet committed to and
5509
5509
// return them to fail the payment.
5510
5510
let mut dropped_outbound_htlcs = Vec :: with_capacity ( self . holding_cell_htlc_updates . len ( ) ) ;
5511
+ let counterparty_node_id = self . get_counterparty_node_id ( ) ;
5511
5512
for htlc_update in self . holding_cell_htlc_updates . drain ( ..) {
5512
5513
match htlc_update {
5513
5514
HTLCUpdateAwaitingACK :: AddHTLC { source, payment_hash, .. } => {
5514
- dropped_outbound_htlcs. push ( ( source, payment_hash) ) ;
5515
+ dropped_outbound_htlcs. push ( ( source, payment_hash, counterparty_node_id ) ) ;
5515
5516
} ,
5516
5517
_ => { }
5517
5518
}
0 commit comments