@@ -1788,7 +1788,7 @@ macro_rules! handle_error {
1788
1788
let mut msg_events = Vec::with_capacity(2);
1789
1789
1790
1790
if let Some((shutdown_res, update_option)) = shutdown_finish {
1791
- $self.finish_force_close_channel (shutdown_res);
1791
+ $self.finish_close_channel (shutdown_res);
1792
1792
if let Some(update) = update_option {
1793
1793
msg_events.push(events::MessageSendEvent::BroadcastChannelUpdate {
1794
1794
msg: update
@@ -2565,7 +2565,7 @@ where
2565
2565
}
2566
2566
2567
2567
if let Some(shutdown_result) = shutdown_result {
2568
- self.finish_force_close_channel (shutdown_result);
2568
+ self.finish_close_channel (shutdown_result);
2569
2569
}
2570
2570
2571
2571
Ok(())
@@ -2632,7 +2632,7 @@ where
2632
2632
self.close_channel_internal(channel_id, counterparty_node_id, target_feerate_sats_per_1000_weight, shutdown_script)
2633
2633
}
2634
2634
2635
- fn finish_force_close_channel (&self, shutdown_res: ShutdownResult) {
2635
+ fn finish_close_channel (&self, shutdown_res: ShutdownResult) {
2636
2636
debug_assert_ne!(self.per_peer_state.held_by_thread(), LockHeldState::HeldByThread);
2637
2637
#[cfg(debug_assertions)]
2638
2638
for (_, peer) in self.per_peer_state.read().unwrap().iter() {
@@ -2678,11 +2678,11 @@ where
2678
2678
mem::drop(per_peer_state);
2679
2679
match chan_phase {
2680
2680
ChannelPhase::Funded(mut chan) => {
2681
- self.finish_force_close_channel (chan.context.force_shutdown(broadcast));
2681
+ self.finish_close_channel (chan.context.force_shutdown(broadcast));
2682
2682
(self.get_channel_update_for_broadcast(&chan).ok(), chan.context.get_counterparty_node_id())
2683
2683
},
2684
2684
ChannelPhase::UnfundedOutboundV1(_) | ChannelPhase::UnfundedInboundV1(_) => {
2685
- self.finish_force_close_channel (chan_phase.context_mut().force_shutdown(false));
2685
+ self.finish_close_channel (chan_phase.context_mut().force_shutdown(false));
2686
2686
// Unfunded channel has no update
2687
2687
(None, chan_phase.context().get_counterparty_node_id())
2688
2688
},
@@ -4855,7 +4855,7 @@ where
4855
4855
}
4856
4856
4857
4857
for shutdown_res in shutdown_channels {
4858
- self.finish_force_close_channel (shutdown_res);
4858
+ self.finish_close_channel (shutdown_res);
4859
4859
}
4860
4860
4861
4861
self.pending_outbound_payments.remove_stale_payments(&self.pending_events);
@@ -6081,7 +6081,7 @@ where
6081
6081
self.fail_htlc_backwards_internal(&htlc_source.0, &htlc_source.1, &reason, receiver);
6082
6082
}
6083
6083
if let Some(shutdown_res) = finish_shutdown {
6084
- self.finish_force_close_channel (shutdown_res);
6084
+ self.finish_close_channel (shutdown_res);
6085
6085
}
6086
6086
6087
6087
Ok(())
@@ -6142,7 +6142,7 @@ where
6142
6142
mem::drop(peer_state_mutex);
6143
6143
mem::drop(per_peer_state);
6144
6144
if let Some(shutdown_result) = shutdown_result {
6145
- self.finish_force_close_channel (shutdown_result);
6145
+ self.finish_close_channel (shutdown_result);
6146
6146
}
6147
6147
Ok(())
6148
6148
}
@@ -6747,7 +6747,7 @@ where
6747
6747
}
6748
6748
6749
6749
for failure in failed_channels.drain(..) {
6750
- self.finish_force_close_channel (failure);
6750
+ self.finish_close_channel (failure);
6751
6751
}
6752
6752
6753
6753
has_pending_monitor_events
@@ -6873,7 +6873,7 @@ where
6873
6873
}
6874
6874
6875
6875
if let Some(shutdown_result) = shutdown_result {
6876
- self.finish_force_close_channel (shutdown_result);
6876
+ self.finish_close_channel (shutdown_result);
6877
6877
}
6878
6878
6879
6879
has_update
@@ -6901,7 +6901,7 @@ where
6901
6901
counterparty_node_id, funding_txo, update
6902
6902
});
6903
6903
}
6904
- self.finish_force_close_channel (failure);
6904
+ self.finish_close_channel (failure);
6905
6905
}
6906
6906
}
6907
6907
@@ -7931,7 +7931,7 @@ where
7931
7931
mem::drop(per_peer_state);
7932
7932
7933
7933
for failure in failed_channels.drain(..) {
7934
- self.finish_force_close_channel (failure);
7934
+ self.finish_close_channel (failure);
7935
7935
}
7936
7936
}
7937
7937
0 commit comments