revert: Revert out bounded service logic

nervosnetwork · Mar 21, 2019 · 3999aee · 3999aee
1 parent 4a068b6
commit 3999aee
Showing 1 changed file with 4 additions and 7 deletions.
diff --git a/network/src/service/outbound_peer_service.rs b/network/src/service/outbound_peer_service.rs
@@ -37,14 +37,11 @@ impl Stream for OutboundPeerService {
                         .network
                         .peer_store()
                         .read()
-                        .random_peers(new_outbound as u32)
+                        .peers_to_attempt(new_outbound as u32);
+                    for (peer_id, addr) in attempt_peers
                         .into_iter()
-                        .filter(|(peer_id, _addr)| {
-                            self.network.get_peer_index(peer_id).is_none()
-                                && self.network.local_peer_id() != peer_id
-                        })
-                        .collect::<Vec<_>>();
-                    for (peer_id, addr) in attempt_peers.into_iter() {
+                        .filter(|(peer_id, _addr)| self.network.local_peer_id() != peer_id)
+                    {
                         self.network.dial(&peer_id, addr);
                     }
                 }