Skip to content

Commit a8d7420

Browse files
Store AsyncPaymentsMessages for later sending
Upcoming commits will support sending and receiving held_htlc_available and release_held_htlc messages. These messages need to be enqueued so that they can be released in ChannelManager's implementation of AsyncPaymentsMessageHandler to OnionMessenger for sending.
1 parent 10b4efb commit a8d7420

File tree

1 file changed

+6
-1
lines changed

1 file changed

+6
-1
lines changed

lightning/src/ln/channelmanager.rs

Lines changed: 6 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1848,6 +1848,8 @@ where
18481848
//
18491849
// `pending_offers_messages`
18501850
//
1851+
// `pending_async_payments_messages`
1852+
//
18511853
// `total_consistency_lock`
18521854
// |
18531855
// |__`forward_htlcs`
@@ -2100,6 +2102,7 @@ where
21002102
needs_persist_flag: AtomicBool,
21012103

21022104
pending_offers_messages: Mutex<Vec<PendingOnionMessage<OffersMessage>>>,
2105+
pending_async_payments_messages: Mutex<Vec<PendingOnionMessage<AsyncPaymentsMessage>>>,
21032106

21042107
/// Tracks the message events that are to be broadcasted when we are connected to some peer.
21052108
pending_broadcast_messages: Mutex<Vec<MessageSendEvent>>,
@@ -2894,6 +2897,7 @@ where
28942897
funding_batch_states: Mutex::new(BTreeMap::new()),
28952898

28962899
pending_offers_messages: Mutex::new(Vec::new()),
2900+
pending_async_payments_messages: Mutex::new(Vec::new()),
28972901
pending_broadcast_messages: Mutex::new(Vec::new()),
28982902

28992903
last_days_feerates: Mutex::new(VecDeque::new()),
@@ -10421,7 +10425,7 @@ where
1042110425
ResponseInstruction::NoResponse
1042210426
}
1042310427

10424-
fn release_held_htlc(&self, _message: ReleaseHeldHtlc) {}
10428+
fn release_held_htlc(&self, _message: ReleaseHeldHtlc, _payment_id: Option<PaymentId>) {}
1042510429

1042610430
fn release_pending_messages(&self) -> Vec<PendingOnionMessage<AsyncPaymentsMessage>> {
1042710431
Vec::new()
@@ -12149,6 +12153,7 @@ where
1214912153
funding_batch_states: Mutex::new(BTreeMap::new()),
1215012154

1215112155
pending_offers_messages: Mutex::new(Vec::new()),
12156+
pending_async_payments_messages: Mutex::new(Vec::new()),
1215212157

1215312158
pending_broadcast_messages: Mutex::new(Vec::new()),
1215412159

0 commit comments

Comments
 (0)