@@ -6037,15 +6037,13 @@ where
6037
6037
let mut peer_state_lock = peer_state_mutex. lock ( ) . unwrap ( ) ;
6038
6038
let peer_state = & mut * peer_state_lock;
6039
6039
peer_state. channel_by_id . retain ( |_, chan| {
6040
- if chan. get_counterparty_node_id ( ) == * counterparty_node_id {
6041
- chan. remove_uncommitted_htlcs_and_mark_paused ( & self . logger ) ;
6042
- if chan. is_shutdown ( ) {
6043
- update_maps_on_chan_removal ! ( self , chan) ;
6044
- self . issue_channel_close_events ( chan, ClosureReason :: DisconnectedPeer ) ;
6045
- return false ;
6046
- } else {
6047
- no_channels_remain = false ;
6048
- }
6040
+ chan. remove_uncommitted_htlcs_and_mark_paused ( & self . logger ) ;
6041
+ if chan. is_shutdown ( ) {
6042
+ update_maps_on_chan_removal ! ( self , chan) ;
6043
+ self . issue_channel_close_events ( chan, ClosureReason :: DisconnectedPeer ) ;
6044
+ return false ;
6045
+ } else {
6046
+ no_channels_remain = false ;
6049
6047
}
6050
6048
true
6051
6049
} ) ;
@@ -6171,9 +6169,6 @@ where
6171
6169
let mut peer_state_lock = peer_state_mutex. lock ( ) . unwrap ( ) ;
6172
6170
let peer_state = & mut * peer_state_lock;
6173
6171
if let Some ( chan) = peer_state. channel_by_id . get_mut ( & msg. channel_id ) {
6174
- if chan. get_counterparty_node_id ( ) != * counterparty_node_id {
6175
- return ;
6176
- }
6177
6172
if let Ok ( msg) = chan. maybe_handle_error_without_close ( self . genesis_hash ) {
6178
6173
channel_state. pending_msg_events . push ( events:: MessageSendEvent :: SendOpenChannel {
6179
6174
node_id : * counterparty_node_id,
0 commit comments