From: ThomasV <thomasv@gitorious>
Date: Sat, 22 Mar 2014 10:04:52 +0000 (+0100)
Subject: handle timeout in peers script
X-Git-Url: https://git.novaco.in/?p=electrum-nvc.git;a=commitdiff_plain;h=0f44ebac5589b129d39ef3377818b77664362105

handle timeout in peers script
---

diff --git a/scripts/peers b/scripts/peers
index efc1669..2a37f21 100755
--- a/scripts/peers
+++ b/scripts/peers
@@ -19,6 +19,7 @@ r = q.get(timeout=10000)
 peers = parse_servers(r.get('result'))
 peers = filter_protocol(peers,'s')
 
+print "Contacting %d servers"%len(peers)
 # start interfaces
 config = SimpleConfig()
 interfaces = map ( lambda server: Interface(server, config), peers )
@@ -27,12 +28,17 @@ reached_servers = []
 for i in interfaces: i.start(q)
 
 while peers:
-    i = q.get(timeout=10)
+    try:
+        i = q.get(timeout=3)
+    except:
+        break
     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)
 
+print "%d servers could be reached"%len(reached_servers)
+
 def analyze(results):
     out = {}
     dd = {}