From d9874ecb0169ddd6c66f382ecb79383042639b2e Mon Sep 17 00:00:00 2001
From: ThomasV <thomasv@gitorious>
Date: Wed, 25 Mar 2015 10:18:32 +0100
Subject: [PATCH] add 10 second timeout to header requests

---
 lib/blockchain.py | 12 +++++++++---
 1 file changed, 9 insertions(+), 3 deletions(-)

diff --git a/lib/blockchain.py b/lib/blockchain.py
index 9cd68e23..aaa6476c 100644
--- a/lib/blockchain.py
+++ b/lib/blockchain.py
@@ -269,12 +269,15 @@ class Blockchain(util.DaemonThread):
         i.send_request({'method':'blockchain.block.get_header', 'params':[h]}, queue)
 
     def retrieve_request(self, queue):
+        t = time.time()
         while self.is_running():
             try:
-                ir = queue.get(timeout=1)
+                ir = queue.get(timeout=0.1)
             except Queue.Empty:
-                self.print_error('blockchain: request timeout')
-                continue
+                if time.time() - t > 10:
+                    return
+                else:
+                    continue
             i, r = ir
             result = r['result']
             return result
@@ -291,6 +294,7 @@ class Blockchain(util.DaemonThread):
             if requested_header:
                 header = self.retrieve_request(queue)
                 if not header:
+                    self.print_error('chain request timed out, giving up')
                     return
                 chain = [ header ] + chain
                 requested_header = False
@@ -325,6 +329,8 @@ class Blockchain(util.DaemonThread):
             self.print_error( "Requesting chunk:", n )
             i.send_request({'method':'blockchain.block.get_chunk', 'params':[n]}, queue)
             r = self.retrieve_request(queue)
+            if not r:
+                return False
             try:
                 self.verify_chunk(n, r)
                 n = n + 1