Skip to content

Commit 0e37cb0

Browse files
Extract _internal macro for new mon update handling
Finishes work over the past few commits of breaking up the handle_new_monitor_update macro.
1 parent c42a5ac commit 0e37cb0

File tree

1 file changed

+8
-8
lines changed

1 file changed

+8
-8
lines changed

lightning/src/ln/channelmanager.rs

Lines changed: 8 additions & 8 deletions
Original file line numberDiff line numberDiff line change
@@ -3654,7 +3654,7 @@ macro_rules! handle_post_close_monitor_update {
36543654
WithContext::from(&$self.logger, Some($counterparty_node_id), Some($channel_id), None);
36553655
let in_flight_updates;
36563656
let idx;
3657-
handle_new_monitor_update!(
3657+
handle_new_monitor_update_internal!(
36583658
$self,
36593659
$funding_txo,
36603660
$update,
@@ -3664,7 +3664,6 @@ macro_rules! handle_post_close_monitor_update {
36643664
$counterparty_node_id,
36653665
in_flight_updates,
36663666
idx,
3667-
_internal_outer,
36683667
{
36693668
// If we get a monitor update for a closed channel
36703669
let _ = in_flight_updates.remove(idx);
@@ -3702,7 +3701,7 @@ macro_rules! handle_new_monitor_update_actions_processed_later {
37023701
let counterparty_node_id = $chan_context.get_counterparty_node_id();
37033702
let in_flight_updates;
37043703
let idx;
3705-
handle_new_monitor_update!(
3704+
handle_new_monitor_update_internal!(
37063705
$self,
37073706
$funding_txo,
37083707
$update,
@@ -3712,19 +3711,18 @@ macro_rules! handle_new_monitor_update_actions_processed_later {
37123711
counterparty_node_id,
37133712
in_flight_updates,
37143713
idx,
3715-
_internal_outer,
37163714
{
37173715
let _ = in_flight_updates.remove(idx);
37183716
}
37193717
)
37203718
}};
37213719
}
37223720

3723-
macro_rules! handle_new_monitor_update {
3721+
macro_rules! handle_new_monitor_update_internal {
37243722
(
37253723
$self: ident, $funding_txo: expr, $update: expr, $peer_state: expr, $logger: expr,
37263724
$chan_id: expr, $counterparty_node_id: expr, $in_flight_updates: ident, $update_idx: ident,
3727-
_internal_outer, $completed: expr
3725+
$completed: expr
37283726
) => {{
37293727
$in_flight_updates = &mut $peer_state
37303728
.in_flight_monitor_updates
@@ -3769,6 +3767,9 @@ macro_rules! handle_new_monitor_update {
37693767
false
37703768
}
37713769
}};
3770+
}
3771+
3772+
macro_rules! handle_new_monitor_update {
37723773
(
37733774
$self: ident, $funding_txo: expr, $update: expr, $peer_state_lock: expr, $peer_state: expr,
37743775
$per_peer_state_lock: expr, $chan: expr
@@ -3778,7 +3779,7 @@ macro_rules! handle_new_monitor_update {
37783779
let counterparty_node_id = $chan.context.get_counterparty_node_id();
37793780
let in_flight_updates;
37803781
let idx;
3781-
handle_new_monitor_update!(
3782+
handle_new_monitor_update_internal!(
37823783
$self,
37833784
$funding_txo,
37843785
$update,
@@ -3788,7 +3789,6 @@ macro_rules! handle_new_monitor_update {
37883789
counterparty_node_id,
37893790
in_flight_updates,
37903791
idx,
3791-
_internal_outer,
37923792
{
37933793
let _ = in_flight_updates.remove(idx);
37943794
if in_flight_updates.is_empty() && $chan.blocked_monitor_updates_pending() == 0 {

0 commit comments

Comments
 (0)