|
@ -306,6 +306,9 @@ class Network(util.DaemonThread): |
|
|
# Resend unanswered requests |
|
|
# Resend unanswered requests |
|
|
requests = self.unanswered_requests.values() |
|
|
requests = self.unanswered_requests.values() |
|
|
self.unanswered_requests = {} |
|
|
self.unanswered_requests = {} |
|
|
|
|
|
if self.interface.ping_required(): |
|
|
|
|
|
params = [ELECTRUM_VERSION, PROTOCOL_VERSION] |
|
|
|
|
|
self.queue_request('server.version', params, self.interface) |
|
|
for request in requests: |
|
|
for request in requests: |
|
|
message_id = self.queue_request(request[0], request[1]) |
|
|
message_id = self.queue_request(request[0], request[1]) |
|
|
self.unanswered_requests[message_id] = request |
|
|
self.unanswered_requests[message_id] = request |
|
@ -314,9 +317,6 @@ class Network(util.DaemonThread): |
|
|
self.queue_request('server.peers.subscribe', []) |
|
|
self.queue_request('server.peers.subscribe', []) |
|
|
self.request_fee_estimates() |
|
|
self.request_fee_estimates() |
|
|
self.queue_request('blockchain.relayfee', []) |
|
|
self.queue_request('blockchain.relayfee', []) |
|
|
if self.interface.ping_required(): |
|
|
|
|
|
params = [ELECTRUM_VERSION, PROTOCOL_VERSION] |
|
|
|
|
|
self.queue_request('server.version', params, self.interface) |
|
|
|
|
|
for h in self.subscribed_addresses: |
|
|
for h in self.subscribed_addresses: |
|
|
self.queue_request('blockchain.scripthash.subscribe', [h]) |
|
|
self.queue_request('blockchain.scripthash.subscribe', [h]) |
|
|
|
|
|
|
|
|