Skip to content

Commit c7e5c70

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 c58cccf commit c7e5c70

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);
@@ -3693,7 +3692,7 @@ macro_rules! handle_new_monitor_update_todo_name {
36933692
let counterparty_node_id = $chan_context.get_counterparty_node_id();
36943693
let in_flight_updates;
36953694
let idx;
3696-
handle_new_monitor_update!(
3695+
handle_new_monitor_update_internal!(
36973696
$self,
36983697
$funding_txo,
36993698
$update,
@@ -3703,19 +3702,18 @@ macro_rules! handle_new_monitor_update_todo_name {
37033702
counterparty_node_id,
37043703
in_flight_updates,
37053704
idx,
3706-
_internal_outer,
37073705
{
37083706
let _ = in_flight_updates.remove(idx);
37093707
}
37103708
)
37113709
}};
37123710
}
37133711

3714-
macro_rules! handle_new_monitor_update {
3712+
macro_rules! handle_new_monitor_update_internal {
37153713
(
37163714
$self: ident, $funding_txo: expr, $update: expr, $peer_state: expr, $logger: expr,
37173715
$chan_id: expr, $counterparty_node_id: expr, $in_flight_updates: ident, $update_idx: ident,
3718-
_internal_outer, $completed: expr
3716+
$completed: expr
37193717
) => {{
37203718
$in_flight_updates = &mut $peer_state
37213719
.in_flight_monitor_updates
@@ -3760,6 +3758,9 @@ macro_rules! handle_new_monitor_update {
37603758
false
37613759
}
37623760
}};
3761+
}
3762+
3763+
macro_rules! handle_new_monitor_update {
37633764
(
37643765
$self: ident, $funding_txo: expr, $update: expr, $peer_state_lock: expr, $peer_state: expr,
37653766
$per_peer_state_lock: expr, $chan: expr
@@ -3769,7 +3770,7 @@ macro_rules! handle_new_monitor_update {
37693770
let counterparty_node_id = $chan.context.get_counterparty_node_id();
37703771
let in_flight_updates;
37713772
let idx;
3772-
handle_new_monitor_update!(
3773+
handle_new_monitor_update_internal!(
37733774
$self,
37743775
$funding_txo,
37753776
$update,
@@ -3779,7 +3780,6 @@ macro_rules! handle_new_monitor_update {
37793780
counterparty_node_id,
37803781
in_flight_updates,
37813782
idx,
3782-
_internal_outer,
37833783
{
37843784
let _ = in_flight_updates.remove(idx);
37853785
if in_flight_updates.is_empty() && $chan.blocked_monitor_updates_pending() == 0 {

0 commit comments

Comments
 (0)