diff --git a/beacon_node/network/src/message_handler.rs b/beacon_node/network/src/message_handler.rs index 3b95c1263..bf0df1aa6 100644 --- a/beacon_node/network/src/message_handler.rs +++ b/beacon_node/network/src/message_handler.rs @@ -65,7 +65,7 @@ impl MessageHandler { // Initialise sync and begin processing in thread // generate the Message handler - let sync = SimpleSync::new(beacon_chain.clone()); + let sync = SimpleSync::new(beacon_chain.clone(), &log); let mut handler = MessageHandler { // TODO: The handler may not need a chain, perhaps only sync? diff --git a/beacon_node/network/src/sync/simple_sync.rs b/beacon_node/network/src/sync/simple_sync.rs index 2a3cc7089..50f6f4a50 100644 --- a/beacon_node/network/src/sync/simple_sync.rs +++ b/beacon_node/network/src/sync/simple_sync.rs @@ -1,6 +1,7 @@ use crate::beacon_chain::BeaconChain; use libp2p::rpc::HelloMessage; use libp2p::PeerId; +use slog::{debug, o}; use std::collections::HashMap; use std::sync::Arc; use types::{Epoch, Hash256, Slot}; @@ -36,11 +37,14 @@ pub struct SimpleSync { latest_finalized_epoch: Epoch, /// The latest block of the syncing chain. latest_block: Hash256, + /// Sync logger. + log: slog::Logger, } impl SimpleSync { - pub fn new(beacon_chain: Arc) -> Self { + pub fn new(beacon_chain: Arc, log: &slog::Logger) -> Self { let state = beacon_chain.get_state(); + let sync_logger = log.new(o!("Service"=> "Sync")); SimpleSync { chain: beacon_chain.clone(), known_peers: HashMap::new(), @@ -48,6 +52,7 @@ impl SimpleSync { network_id: beacon_chain.get_spec().network_id, latest_finalized_epoch: state.finalized_epoch, latest_block: state.finalized_root, //TODO: Build latest block function into Beacon chain and correct this + log: sync_logger, } } @@ -87,7 +92,9 @@ impl SimpleSync { best_slot: hello_message.best_slot, }; + debug!(self.log, "Handshake successful. Peer: {:?}", peer_id); self.known_peers.insert(peer_id, peer_info); + //TODO: Start syncing true