@@ -3617,11 +3617,11 @@ impl<ChanSigner: ChannelKeys + Writeable, M: Deref, T: Deref, K: Deref, F: Deref
3617
3617
peer_state. latest_features . write ( writer) ?;
3618
3618
}
3619
3619
3620
- let events = self . pending_events . lock ( ) . unwrap ( ) ;
3621
- ( events. len ( ) as u64 ) . write ( writer) ?;
3622
- for event in events. iter ( ) {
3623
- event. write ( writer) ?;
3624
- }
3620
+ let events = self . pending_events . lock ( ) . unwrap ( ) ;
3621
+ ( events. len ( ) as u64 ) . write ( writer) ?;
3622
+ for event in events. iter ( ) {
3623
+ event. write ( writer) ?;
3624
+ }
3625
3625
3626
3626
( self . last_node_announcement_serial . load ( Ordering :: Acquire ) as u32 ) . write ( writer) ?;
3627
3627
@@ -3803,15 +3803,15 @@ impl<'a, ChanSigner: ChannelKeys + Readable, M: Deref, T: Deref, K: Deref, F: De
3803
3803
per_peer_state. insert ( peer_pubkey, Mutex :: new ( peer_state) ) ;
3804
3804
}
3805
3805
3806
- let max_alloc_size : u64 = 1024 * 64 ;
3807
- let event_count: u64 = Readable :: read ( reader) ?;
3808
- let mut pending_events_read: Vec < events:: Event > = Vec :: with_capacity ( cmp:: min ( event_count as usize , ( max_alloc_size as usize ) /mem:: size_of :: < events:: Event > ( ) ) ) ;
3809
- for _ in 0 ..event_count {
3810
- match MaybeReadable :: read ( reader) ? {
3811
- Some ( event) => pending_events_read. push ( event) ,
3812
- None => continue ,
3813
- }
3814
- }
3806
+ const MAX_ALLOC_SIZE : u64 = 1024 * 64 ;
3807
+ let event_count: u64 = Readable :: read ( reader) ?;
3808
+ let mut pending_events_read: Vec < events:: Event > = Vec :: with_capacity ( cmp:: min ( event_count as usize , ( MAX_ALLOC_SIZE as usize ) /mem:: size_of :: < events:: Event > ( ) ) ) ;
3809
+ for _ in 0 ..event_count {
3810
+ match MaybeReadable :: read ( reader) ? {
3811
+ Some ( event) => pending_events_read. push ( event) ,
3812
+ None => continue ,
3813
+ }
3814
+ }
3815
3815
3816
3816
let last_node_announcement_serial: u32 = Readable :: read ( reader) ?;
3817
3817
0 commit comments