@@ -6641,37 +6641,37 @@ impl<Signer: Sign, M: Deref, T: Deref, K: Deref, F: Deref, L: Deref> Writeable f
6641
6641
}
6642
6642
}
6643
6643
6644
- let mut htlc_purposes : Vec < events :: PaymentPurpose > = Vec :: new ( ) ;
6645
- {
6646
- let claimable_htlcs = self . claimable_htlcs . lock ( ) . unwrap ( ) ;
6647
- ( claimable_htlcs . len ( ) as u64 ) . write ( writer ) ? ;
6648
- for ( payment_hash , ( purpose , previous_hops ) ) in claimable_htlcs . iter ( ) {
6649
- payment_hash . write ( writer) ?;
6650
- ( previous_hops . len ( ) as u64 ) . write ( writer ) ? ;
6651
- for htlc in previous_hops . iter ( ) {
6652
- htlc . write ( writer) ?;
6653
- }
6654
- htlc_purposes . push ( purpose . clone ( ) ) ;
6644
+ let per_peer_state = self . per_peer_state . write ( ) . unwrap ( ) ;
6645
+ let pending_inbound_payments = self . pending_inbound_payments . lock ( ) . unwrap ( ) ;
6646
+ let claimable_htlcs = self . claimable_htlcs . lock ( ) . unwrap ( ) ;
6647
+
6648
+ let mut htlc_purposes : Vec < & events :: PaymentPurpose > = Vec :: new ( ) ;
6649
+ ( claimable_htlcs . len ( ) as u64 ) . write ( writer) ?;
6650
+ for ( payment_hash , ( purpose , previous_hops ) ) in claimable_htlcs . iter ( ) {
6651
+ payment_hash . write ( writer ) ? ;
6652
+ ( previous_hops . len ( ) as u64 ) . write ( writer) ?;
6653
+ for htlc in previous_hops . iter ( ) {
6654
+ htlc . write ( writer ) ? ;
6655
6655
}
6656
+ htlc_purposes. push ( purpose) ;
6656
6657
}
6657
6658
6658
- let per_peer_state = self . per_peer_state . write ( ) . unwrap ( ) ;
6659
6659
( per_peer_state. len ( ) as u64 ) . write ( writer) ?;
6660
6660
for ( peer_pubkey, peer_state_mutex) in per_peer_state. iter ( ) {
6661
6661
peer_pubkey. write ( writer) ?;
6662
6662
let peer_state = peer_state_mutex. lock ( ) . unwrap ( ) ;
6663
6663
peer_state. latest_features . write ( writer) ?;
6664
6664
}
6665
6665
6666
- let pending_inbound_payments = self . pending_inbound_payments . lock ( ) . unwrap ( ) ;
6667
6666
let pending_outbound_payments = self . pending_outbound_payments . lock ( ) . unwrap ( ) ;
6668
6667
let events = self . pending_events . lock ( ) . unwrap ( ) ;
6668
+ let background_events = self . pending_background_events . lock ( ) . unwrap ( ) ;
6669
+
6669
6670
( events. len ( ) as u64 ) . write ( writer) ?;
6670
6671
for event in events. iter ( ) {
6671
6672
event. write ( writer) ?;
6672
6673
}
6673
6674
6674
- let background_events = self . pending_background_events . lock ( ) . unwrap ( ) ;
6675
6675
( background_events. len ( ) as u64 ) . write ( writer) ?;
6676
6676
for event in background_events. iter ( ) {
6677
6677
match event {
0 commit comments