From: Matt Corallo <git@bluematt.me>
Date: Tue, 21 May 2019 03:19:08 +0000 (-0400)
Subject: Always get 30 seconds of nodes to scan at a time
X-Git-Url: http://git.bitcoin.ninja/index.cgi?a=commitdiff_plain;h=fe75877d32ada49d31f7debb3977e8948c17d73b;p=dnsseed-rust

Always get 30 seconds of nodes to scan at a time
---

diff --git a/src/datastore.rs b/src/datastore.rs
index ba984d2..6255cd4 100644
--- a/src/datastore.rs
+++ b/src/datastore.rs
@@ -481,12 +481,15 @@ impl Store {
 	}
 
 	pub fn get_next_scan_nodes(&self) -> Vec<SocketAddr> {
-		let mut res = Vec::with_capacity(600);
+		let results = 30 * self.get_u64(U64Setting::ConnsPerSec) as usize;
+		let per_bucket_results = results / (AddressState::get_count() as usize);
+		let mut res = Vec::with_capacity(results);
 		let cur_time = Instant::now();
+
 		let mut nodes = self.nodes.write().unwrap();
 		for (state, state_nodes) in nodes.state_next_scan.iter_mut() {
 			let cmp_time = cur_time - Duration::from_secs(self.get_u64(U64Setting::RescanInterval(*state)));
-			let split_point = cmp::min(cmp::min(600 - res.len(), 60),
+			let split_point = cmp::min(cmp::min(results - res.len(), per_bucket_results),
 					state_nodes.binary_search_by(|a| a.0.cmp(&cmp_time)).unwrap_or_else(|idx| idx));
 			let mut new_nodes = state_nodes.split_off(split_point);
 			mem::swap(&mut new_nodes, state_nodes);