AaronFiore/electrum
1
0
Fork 0
Code Activity

add timeout

Browse Source
This commit is contained in:
thomasv
2012-10-17 17:47:48 +02:00
parent 8957c705ac
commit 11a8e04dd0
1 changed files with 8 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

12
scripts/servers
View File

@@ -14,16 +14,20 @@ for i in interfaces:
else: else:
servers.remove(i.server) servers.remove(i.server)
while servers: for i in interfaces:
for i in interfaces: while True:
try: try:
r = i.responses.get(False) r = i.responses.get(True,1)
except Queue.Empty: except Queue.Empty:
continue break
if r.get('method') == 'blockchain.numblocks.subscribe': if r.get('method') == 'blockchain.numblocks.subscribe':
results.append((i.host, r.get('result'))) results.append((i.host, r.get('result')))
servers.remove(i.server) servers.remove(i.server)
break
for s in servers:
print "%30s "%s, "timed out"
from collections import defaultdict from collections import defaultdict
d = defaultdict(int) d = defaultdict(int)