cerc-io/lighthouse
16
0
Fork 0
Code Issues 1 Pull Requests Packages Projects Releases Wiki Activity

Discovery and gossip bug fixes

Browse Source
This commit is contained in:
Age Manning 2019-04-18 15:26:30 +10:00
parent f80c34b74f
commit cb7d5eba1c
No known key found for this signature in database
GPG Key ID: 05EED64B79E06A93
2 changed files with 5 additions and 17 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
beacon_node/Cargo.toml
View File

@ -22,5 +22,5 @@ tokio-timer = "0.2.10"
futures = "0.1.25" futures = "0.1.25"
exit-future = "0.1.3" exit-future = "0.1.3"
state_processing = { path = "../eth2/state_processing" } state_processing = { path = "../eth2/state_processing" }
slog = { version = "^2.2.3" , features = ["max_level_trace", "release_max_level_debug"] } slog = "^2.2.3"
env_logger = "0.6.1" env_logger = "0.6.1"

20
beacon_node/eth2-libp2p/src/discovery.rs
View File

@ -83,18 +83,9 @@ where
NetworkBehaviour::new_handler(&mut self.discovery) NetworkBehaviour::new_handler(&mut self.discovery)
} }
// TODO: we store all peers in known_peers, when upgrading to discv5 we will avoid duplication
// of peer storage.
fn addresses_of_peer(&mut self, peer_id: &PeerId) -> Vec<Multiaddr> { fn addresses_of_peer(&mut self, peer_id: &PeerId) -> Vec<Multiaddr> {
if let Some(addresses) = self.known_peers.get(peer_id) { // Let discovery track possible known peers.
addresses.clone() self.discovery.addresses_of_peer(peer_id)
} else {
debug!(
self.log,
"Tried to dial: {:?} but no address stored", peer_id
);
Vec::new()
}
} }
fn inject_connected(&mut self, peer_id: PeerId, endpoint: ConnectedPoint) { fn inject_connected(&mut self, peer_id: PeerId, endpoint: ConnectedPoint) {
@ -151,11 +142,6 @@ where
peer_id, addresses, .. peer_id, addresses, ..
} => { } => {
debug!(self.log, "Kademlia peer discovered"; "Peer"=> format!("{:?}", peer_id), "Addresses" => format!("{:?}", addresses)); debug!(self.log, "Kademlia peer discovered"; "Peer"=> format!("{:?}", peer_id), "Addresses" => format!("{:?}", addresses));
(*self
.known_peers
.entry(peer_id.clone())
.or_insert_with(|| vec![]))
.extend(addresses.clone());
} }
KademliaOut::FindNodeResult { closer_peers, .. } => { KademliaOut::FindNodeResult { closer_peers, .. } => {
debug!( debug!(
@ -163,6 +149,8 @@ where
"Kademlia query found {} peers", "Kademlia query found {} peers",
closer_peers.len() closer_peers.len()
); );
debug!(self.log, "Kademlia peers discovered"; "Peer"=> format!("{:?}", closer_peers));
if closer_peers.is_empty() { if closer_peers.is_empty() {
debug!(self.log, "Kademlia random query yielded empty results"); debug!(self.log, "Kademlia random query yielded empty results");
} }