+fn poll_dnsseeds(bgp_client: Arc<BGPClient>) {
+ tokio::spawn(future::lazy(|| {
+ let printer = unsafe { PRINTER.as_ref().unwrap() };
+ let store = unsafe { DATA_STORE.as_ref().unwrap() };
+
+ let mut new_addrs = 0;
+ for seed in ["seed.bitcoin.sipa.be", "dnsseed.bitcoin.dashjr.org", "seed.bitcoinstats.com", "seed.bitcoin.jonasschnelli.ch", "seed.btc.petertodd.org", "seed.bitcoin.sprovoost.nl", "dnsseed.emzy.de"].iter() {
+ new_addrs += store.add_fresh_addrs((*seed, 8333u16).to_socket_addrs().unwrap_or(Vec::new().into_iter()));
+ new_addrs += store.add_fresh_addrs((("x9.".to_string() + seed).as_str(), 8333u16).to_socket_addrs().unwrap_or(Vec::new().into_iter()));
+ }
+ printer.add_line(format!("Added {} new addresses from other DNS seeds", new_addrs), false);
+ Delay::new(Instant::now() + Duration::from_secs(60)).then(|_| {
+ let store = unsafe { DATA_STORE.as_ref().unwrap() };
+ let dns_future = store.write_dns(Arc::clone(&bgp_client));
+ store.save_data().join(dns_future).then(|_| {
+ if !START_SHUTDOWN.load(Ordering::Relaxed) {
+ poll_dnsseeds(bgp_client);
+ } else {
+ bgp_client.disconnect();
+ }
+ future::ok(())
+ })
+ })
+ }));
+}
+