From 45514c7ba942c4e021e81f530a8728458ffa0a2f Mon Sep 17 00:00:00 2001 From: ThomasV Date: Mon, 28 Apr 2014 14:46:07 +0200 Subject: [PATCH] global timeout in peers script --- scripts/peers | 11 +++++++++-- 1 files changed, 9 insertions(+), 2 deletions(-) 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) -- 1.7.1