@@ -36,7 +36,7 @@ use prelude::*;
36
36
use io;
37
37
use alloc:: collections:: LinkedList ;
38
38
use sync:: { Arc , Mutex , MutexGuard , FairRwLock } ;
39
- use core:: sync:: atomic:: { AtomicBool , AtomicU64 , Ordering } ;
39
+ use core:: sync:: atomic:: { AtomicBool , AtomicU32 , Ordering } ;
40
40
use core:: { cmp, hash, fmt, mem} ;
41
41
use core:: ops:: Deref ;
42
42
use core:: convert:: Infallible ;
@@ -540,7 +540,7 @@ pub struct PeerManager<Descriptor: SocketDescriptor, CM: Deref, RM: Deref, OM: D
540
540
541
541
/// Used to track the last value sent in a node_announcement "timestamp" field. We ensure this
542
542
/// value increases strictly since we don't assume access to a time source.
543
- last_node_announcement_serial : AtomicU64 ,
543
+ last_node_announcement_serial : AtomicU32 ,
544
544
545
545
our_node_secret : SecretKey ,
546
546
ephemeral_key_midstate : Sha256Engine ,
@@ -594,7 +594,7 @@ impl<Descriptor: SocketDescriptor, CM: Deref, OM: Deref, L: Deref> PeerManager<D
594
594
/// minute should suffice.
595
595
///
596
596
/// (C-not exported) as we can't export a PeerManager with a dummy route handler
597
- pub fn new_channel_only ( channel_message_handler : CM , onion_message_handler : OM , our_node_secret : SecretKey , current_time : u64 , ephemeral_random_data : & [ u8 ; 32 ] , logger : L ) -> Self {
597
+ pub fn new_channel_only ( channel_message_handler : CM , onion_message_handler : OM , our_node_secret : SecretKey , current_time : u32 , ephemeral_random_data : & [ u8 ; 32 ] , logger : L ) -> Self {
598
598
Self :: new ( MessageHandler {
599
599
chan_handler : channel_message_handler,
600
600
route_handler : IgnoringMessageHandler { } ,
@@ -620,7 +620,7 @@ impl<Descriptor: SocketDescriptor, RM: Deref, L: Deref> PeerManager<Descriptor,
620
620
/// cryptographically secure random bytes.
621
621
///
622
622
/// (C-not exported) as we can't export a PeerManager with a dummy channel handler
623
- pub fn new_routing_only ( routing_message_handler : RM , our_node_secret : SecretKey , current_time : u64 , ephemeral_random_data : & [ u8 ; 32 ] , logger : L ) -> Self {
623
+ pub fn new_routing_only ( routing_message_handler : RM , our_node_secret : SecretKey , current_time : u32 , ephemeral_random_data : & [ u8 ; 32 ] , logger : L ) -> Self {
624
624
Self :: new ( MessageHandler {
625
625
chan_handler : ErroringMessageHandler :: new ( ) ,
626
626
route_handler : routing_message_handler,
@@ -684,7 +684,7 @@ impl<Descriptor: SocketDescriptor, CM: Deref, RM: Deref, OM: Deref, L: Deref, CM
684
684
/// incremented irregularly internally. In general it is best to simply use the current UNIX
685
685
/// timestamp, however if it is not available a persistent counter that increases once per
686
686
/// minute should suffice.
687
- pub fn new ( message_handler : MessageHandler < CM , RM , OM > , our_node_secret : SecretKey , current_time : u64 , ephemeral_random_data : & [ u8 ; 32 ] , logger : L , custom_message_handler : CMH ) -> Self {
687
+ pub fn new ( message_handler : MessageHandler < CM , RM , OM > , our_node_secret : SecretKey , current_time : u32 , ephemeral_random_data : & [ u8 ; 32 ] , logger : L , custom_message_handler : CMH ) -> Self {
688
688
let mut ephemeral_key_midstate = Sha256 :: engine ( ) ;
689
689
ephemeral_key_midstate. input ( ephemeral_random_data) ;
690
690
@@ -701,7 +701,7 @@ impl<Descriptor: SocketDescriptor, CM: Deref, RM: Deref, OM: Deref, L: Deref, CM
701
701
our_node_secret,
702
702
ephemeral_key_midstate,
703
703
peer_counter : AtomicCounter :: new ( ) ,
704
- last_node_announcement_serial : AtomicU64 :: new ( current_time) ,
704
+ last_node_announcement_serial : AtomicU32 :: new ( current_time) ,
705
705
logger,
706
706
custom_message_handler,
707
707
secp_ctx,
@@ -2001,7 +2001,7 @@ impl<Descriptor: SocketDescriptor, CM: Deref, RM: Deref, OM: Deref, L: Deref, CM
2001
2001
. or ( self . message_handler . onion_message_handler . provided_node_features ( ) ) ;
2002
2002
let announcement = msgs:: UnsignedNodeAnnouncement {
2003
2003
features,
2004
- timestamp : self . last_node_announcement_serial . fetch_add ( 1 , Ordering :: AcqRel ) as u32 ,
2004
+ timestamp : self . last_node_announcement_serial . fetch_add ( 1 , Ordering :: AcqRel ) ,
2005
2005
node_id : PublicKey :: from_secret_key ( & self . secp_ctx , & self . our_node_secret ) ,
2006
2006
rgb, alias, addresses,
2007
2007
excess_address_data : Vec :: new ( ) ,
0 commit comments