X-Git-Url: https://git.novaco.in/?a=blobdiff_plain;f=scripts%2Fpeers;fp=scripts%2Fpeers;h=ef71fffa986470b5276a903b680c743af71d3c89;hb=45514c7ba942c4e021e81f530a8728458ffa0a2f;hp=2a37f21f1a57ead8800cd497795aa3e9a672d068;hpb=c295c79754313fbf68801159587a7536ad973f5c;p=electrum-nvc.git diff --git a/scripts/peers b/scripts/peers index 2a37f21..ef71fff 100755 --- a/scripts/peers +++ b/scripts/peers @@ -27,15 +27,22 @@ results_queue = Queue.Queue() reached_servers = [] for i in interfaces: i.start(q) +t0 = time.time() while peers: try: - i = q.get(timeout=3) + i = q.get(timeout=1) except: - break + if time.time() - t0 > 10: + print "timeout" + break + else: + continue peers.remove(i.server) if i.is_connected: i.send([('blockchain.headers.subscribe',[])], lambda i,x: results_queue.put((i,x))) reached_servers.append(i.server) + else: + print "Connection failed:", i.server print "%d servers could be reached"%len(reached_servers)