AaronFiore/electrum
1
0
Fork 0
Code Activity

catch-up block headers from a single interface at a time

Browse Source
This commit is contained in:
ThomasV
2017-05-19 12:16:21 +02:00
parent 82c9430e7a
commit ac77c9b9bd
1 changed files with 6 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

7
lib/network.py
View File

@@ -221,6 +221,7 @@ class Network(util.DaemonThread):
self.debug = False self.debug = False
self.irc_servers = {} # returned by interface (list from irc) self.irc_servers = {} # returned by interface (list from irc)
self.recent_servers = self.read_recent_servers() self.recent_servers = self.read_recent_servers()
self.catch_up = None # interface catching up
self.banner = '' self.banner = ''
self.donation_address = '' self.donation_address = ''
@@ -687,6 +688,8 @@ class Network(util.DaemonThread):
self.close_interface(self.interfaces[server]) self.close_interface(self.interfaces[server])
self.headers.pop(server, None) self.headers.pop(server, None)
self.notify('interfaces') self.notify('interfaces')
if server == self.catch_up:
self.catch_up = None
def new_interface(self, server, socket): def new_interface(self, server, socket):
self.add_recent_server(server) self.add_recent_server(server)
@@ -851,6 +854,7 @@ class Network(util.DaemonThread):
self.request_header(interface, next_height) self.request_header(interface, next_height)
else: else:
interface.request = None interface.request = None
self.catch_up = None
def maintain_requests(self): def maintain_requests(self):
for interface in self.interfaces.values(): for interface in self.interfaces.values():
@@ -905,7 +909,8 @@ class Network(util.DaemonThread):
self.blockchain.save_header(header) self.blockchain.save_header(header)
self.notify('updated') self.notify('updated')
# otherwise trigger a search # otherwise trigger a search
elif i.request is None: elif self.catch_up is None:
self.catch_up = i.server
self.on_header(i, header) self.on_header(i, header)
if i == self.interface: if i == self.interface: