From 11a8e04dd07f39988a278f907d2d9dd8a9e12949 Mon Sep 17 00:00:00 2001 From: thomasv Date: Wed, 17 Oct 2012 17:47:48 +0200 Subject: [PATCH] add timeout --- scripts/servers | 12 ++++++++---- 1 files changed, 8 insertions(+), 4 deletions(-) diff --git a/scripts/servers b/scripts/servers index 0a1da1e..8297135 100755 --- a/scripts/servers +++ b/scripts/servers @@ -14,16 +14,20 @@ for i in interfaces: else: servers.remove(i.server) -while servers: - for i in interfaces: +for i in interfaces: + while True: try: - r = i.responses.get(False) + r = i.responses.get(True,1) except Queue.Empty: - continue + break if r.get('method') == 'blockchain.numblocks.subscribe': results.append((i.host, r.get('result'))) servers.remove(i.server) + break + +for s in servers: + print "%30s "%s, "timed out" from collections import defaultdict d = defaultdict(int) -- 1.7.1