Fix errors

sigp · Dec 15, 2020 · a1f23be · a1f23be
1 parent fa15368
commit a1f23be
Show file tree

Hide file tree

Showing 2 changed files with 3 additions and 3 deletions.
diff --git a/beacon_node/eth2_libp2p/src/peer_manager/mod.rs b/beacon_node/eth2_libp2p/src/peer_manager/mod.rs
@@ -11,7 +11,7 @@ use futures::Stream;
 use hashset_delay::HashSetDelay;
 use libp2p::core::multiaddr::Protocol as MProtocol;
 use libp2p::identify::IdentifyInfo;
-use slog::{crit, debug, error, trace, warn};
+use slog::{crit, debug, error, warn};
 use smallvec::SmallVec;
 use std::{
     net::SocketAddr,

diff --git a/beacon_node/network/src/service.rs b/beacon_node/network/src/service.rs
@@ -466,7 +466,7 @@ fn spawn_service<T: BeaconChainTypes>(
                             },
                             BehaviourEvent::PeerDisconnected(peer_id) => {
                                 // Remove all subscriptions from peerdb for the disconnected peer.
-                                service.libp2p.peer_manager().remove_all_subscriptions(&peer_id);
+                                service.libp2p.swarm.peer_manager().remove_all_subscriptions(&peer_id);
                                 let _ = service
                                     .router_send
                                     .send(RouterMessage::PeerDisconnected(peer_id))
@@ -546,7 +546,7 @@ fn spawn_service<T: BeaconChainTypes>(
                                 }
                             }
                             BehaviourEvent::PeerSubscribed(_, _) => {},
-                            BehaviourEvent::PeerUnsubscribed(peer_id, topic) => {},
+                            BehaviourEvent::PeerUnsubscribed(_, _) => {},
                         }
                         Libp2pEvent::NewListenAddr(multiaddr) => {
                             service.network_globals.listen_multiaddrs.write().push(multiaddr);