@@ -11,6 +11,7 @@ use lazy_static::lazy_static;
1111
1212use crate :: apps:: signer:: Signer ;
1313use crate :: config:: TASK_INTERVAL ;
14+ use crate :: helper:: now;
1415use super :: gossip:: HeartBeatMessage ;
1516
1617lazy_static ! {
@@ -36,7 +37,7 @@ pub const ALIVE_WINDOW: u64 = TASK_INTERVAL.as_secs() * 2;
3637pub const BLOCK_TOLERENCE : u64 = ALIVE_WINDOW / 6 + 1 ;
3738
3839pub fn update_alive_table ( self_identifier : & Identifier , hbm : HeartBeatMessage ) {
39- // tracing::debug!("Received {}, {}, {}, {} ", get_name(&hbm.payload.identifier), hbm.payload.version, hbm.payload.block_height, if hbm.payload.last_seen > now() {hbm.payload.last_seen - now()} else {0} );
40+ tracing:: debug!( "Received {}, {}, {}, {} " , get_name( & hbm. payload. identifier) , hbm. payload. version, hbm. payload. block_height, if hbm. payload. last_seen > now( ) { hbm. payload. last_seen - now( ) } else { 0 } ) ;
4041 let mut table= AliveTable . lock ( ) . unwrap ( ) ;
4142
4243 table. insert ( hbm. payload . identifier , hbm. payload . block_height ) ;
@@ -45,7 +46,7 @@ pub fn update_alive_table(self_identifier: &Identifier, hbm: HeartBeatMessage) {
4546 table. retain ( |_, v| v. abs_diff ( t) <= BLOCK_TOLERENCE ) ;
4647 }
4748
48- tracing:: debug!( "Heartbeats: {:?}" , table. iter( ) . map( |( k, v) | ( get_name( k) , v) ) . collect:: <Vec <_>>( ) ) ;
49+ // tracing::debug!("Heartbeats: {:?}", table.iter().map(|(k, v) | (get_name(k), v)).collect::<Vec<_>>());
4950
5051}
5152
0 commit comments