diff --git a/scripts/peers b/scripts/peers index 80b5cea51..002368dbe 100755 --- a/scripts/peers +++ b/scripts/peers @@ -87,12 +87,23 @@ for i in reached_servers: i.send_request({'method':'blockchain.headers.subscribe','params':[]}, results_queue) results = {} +t0 = time.time() while reached_servers: - i, r = results_queue.get(timeout=10000) + try: + i, r = results_queue.get(timeout=1) + except: + if time.time() - t0 > 10: + break + else: + continue results[i.server] = r.get('result') reached_servers.remove(i) i.stop() +for i in reached_servers: + print i.server, "did not answer" +print "%d answers"%len(results) + errors = analyze(results).keys() for n,v in sorted(results.items(), key=lambda x:x[1]['block_height']):