mirror of
https://github.com/alexgo-io/stacks-puppet-node.git
synced 2026-01-12 22:43:42 +08:00
chore: address PR feedback
This commit is contained in:
@@ -3128,8 +3128,6 @@ pub mod test {
|
||||
let mut mempool = self.mempool.take().unwrap();
|
||||
let indexer = self.indexer.take().unwrap();
|
||||
|
||||
// let indexer = BitcoinIndexer::new_unit_test(&self.config.burnchain.working_dir);
|
||||
|
||||
let ret = self.network.run(
|
||||
&indexer,
|
||||
&mut sortdb,
|
||||
|
||||
@@ -556,7 +556,7 @@ impl ToNeighborKey for NeighborKey {
|
||||
impl ToNeighborKey for NeighborAddress {
|
||||
fn to_neighbor_key(&self, network: &PeerNetwork) -> NeighborKey {
|
||||
// NOTE: PartialEq and Hash for NeighborKey ignore the low bits of peer version
|
||||
// and ignore network ID, and the CovnersationP2P ensures that we never even connect
|
||||
// and ignore network ID, and the ConversationP2P ensures that we never even connect
|
||||
// to a node with the wrong network ID or wrong peer version bits anyway, so
|
||||
// it's safe to use the local node's copies of this data to construct a
|
||||
// NeighborKey for the purposes of later disconnecting from it.
|
||||
|
||||
@@ -253,7 +253,6 @@ impl PeerDBNeighborWalk {
|
||||
}
|
||||
|
||||
impl NeighborWalkDB for PeerDBNeighborWalk {
|
||||
/// implements get_fresh_random_neighbors
|
||||
fn get_fresh_random_neighbors(
|
||||
&self,
|
||||
network: &PeerNetwork,
|
||||
@@ -283,7 +282,6 @@ impl NeighborWalkDB for PeerDBNeighborWalk {
|
||||
Ok(neighbors)
|
||||
}
|
||||
|
||||
/// implements lookup_stale_neighbors
|
||||
fn lookup_stale_neighbors(
|
||||
&self,
|
||||
network: &PeerNetwork,
|
||||
@@ -336,7 +334,6 @@ impl NeighborWalkDB for PeerDBNeighborWalk {
|
||||
Ok((resolved, to_resolve))
|
||||
}
|
||||
|
||||
/// implements add_or_schedule_replace_neighbor
|
||||
fn add_or_schedule_replace_neighbor(
|
||||
&self,
|
||||
network: &mut PeerNetwork,
|
||||
@@ -397,7 +394,6 @@ impl NeighborWalkDB for PeerDBNeighborWalk {
|
||||
Ok((true, neighbor_from_handshake))
|
||||
}
|
||||
|
||||
/// implements get_initial_walk_neighbors
|
||||
fn get_initial_walk_neighbors(
|
||||
&self,
|
||||
network: &PeerNetwork,
|
||||
@@ -419,7 +415,6 @@ impl NeighborWalkDB for PeerDBNeighborWalk {
|
||||
Ok(allowed_peers)
|
||||
}
|
||||
|
||||
/// implements check_neighbor_denied
|
||||
fn check_neighbor_denied(
|
||||
&self,
|
||||
network: &PeerNetwork,
|
||||
@@ -442,7 +437,6 @@ impl NeighborWalkDB for PeerDBNeighborWalk {
|
||||
Ok(())
|
||||
}
|
||||
|
||||
/// implements replace_neighbors
|
||||
fn replace_neighbors(
|
||||
&self,
|
||||
network: &mut PeerNetwork,
|
||||
@@ -483,7 +477,6 @@ impl NeighborWalkDB for PeerDBNeighborWalk {
|
||||
Ok(())
|
||||
}
|
||||
|
||||
/// implements neighbor_from_handshake
|
||||
fn neighbor_from_handshake(
|
||||
&self,
|
||||
network: &PeerNetwork,
|
||||
@@ -499,7 +492,6 @@ impl NeighborWalkDB for PeerDBNeighborWalk {
|
||||
.map(|(neighbor, _)| neighbor)
|
||||
}
|
||||
|
||||
/// implements save_neighbor_from_handshake
|
||||
fn save_neighbor_from_handshake(
|
||||
&self,
|
||||
network: &mut PeerNetwork,
|
||||
@@ -519,7 +511,6 @@ impl NeighborWalkDB for PeerDBNeighborWalk {
|
||||
Ok(neighbor_from_handshake)
|
||||
}
|
||||
|
||||
/// implements update_neighbor
|
||||
fn update_neighbor(
|
||||
&self,
|
||||
network: &mut PeerNetwork,
|
||||
@@ -540,7 +531,6 @@ impl NeighborWalkDB for PeerDBNeighborWalk {
|
||||
Ok(cur_neighbor)
|
||||
}
|
||||
|
||||
/// implements get_asn_count
|
||||
fn get_asn_count(&self, network: &PeerNetwork, asn: u32) -> u64 {
|
||||
PeerDB::asn_count(network.peerdb_conn(), asn).unwrap_or(1)
|
||||
}
|
||||
|
||||
Reference in New Issue
Block a user