tblockchain: move init_headers_file from network.py to blockchain.py - electrum - Electrum Bitcoin wallet
HTML git clone https://git.parazyd.org/electrum
DIR Log
DIR Files
DIR Refs
DIR Submodules
---
DIR commit ce81957d25e66296c0baaf48683adcc623a3dae4
DIR parent b21bcf597734544aa3ec1c732eea4b940f412d4a
HTML Author: SomberNight <somber.night@protonmail.com>
Date: Thu, 27 Feb 2020 20:45:29 +0100
blockchain: move init_headers_file from network.py to blockchain.py
and don't run it every time the network restarts
Diffstat:
M electrum/blockchain.py | 14 ++++++++++++++
M electrum/network.py | 15 +--------------
2 files changed, 15 insertions(+), 14 deletions(-)
---
DIR diff --git a/electrum/blockchain.py b/electrum/blockchain.py
t@@ -159,6 +159,20 @@ _CHAINWORK_CACHE = {
} # type: Dict[str, int]
+def init_headers_file_for_best_chain():
+ b = get_best_chain()
+ filename = b.path()
+ length = HEADER_SIZE * len(constants.net.CHECKPOINTS) * 2016
+ if not os.path.exists(filename) or os.path.getsize(filename) < length:
+ with open(filename, 'wb') as f:
+ if length > 0:
+ f.seek(length - 1)
+ f.write(b'\x00')
+ util.ensure_sparse_file(filename)
+ with b.lock:
+ b.update_size()
+
+
class Blockchain(Logger):
"""
Manages blockchain headers and their verification
DIR diff --git a/electrum/network.py b/electrum/network.py
t@@ -253,6 +253,7 @@ class Network(Logger):
self.daemon = daemon
blockchain.read_blockchains(self.config)
+ blockchain.init_headers_file_for_best_chain()
self.logger.info(f"blockchains {list(map(lambda b: b.forkpoint, blockchain.blockchains.values()))}")
self._blockchain_preferred_block = self.config.get('blockchain_preferred_block', None) # type: Optional[Dict]
self._blockchain = blockchain.get_best_chain()
t@@ -776,19 +777,6 @@ class Network(Logger):
return False
return True
- async def _init_headers_file(self):
- b = blockchain.get_best_chain()
- filename = b.path()
- length = HEADER_SIZE * len(constants.net.CHECKPOINTS) * 2016
- if not os.path.exists(filename) or os.path.getsize(filename) < length:
- with open(filename, 'wb') as f:
- if length > 0:
- f.seek(length-1)
- f.write(b'\x00')
- util.ensure_sparse_file(filename)
- with b.lock:
- b.update_size()
-
def best_effort_reliable(func):
async def make_reliable_wrapper(self: 'Network', *args, **kwargs):
for i in range(10):
t@@ -1133,7 +1121,6 @@ class Network(Logger):
async def main():
self.logger.info("starting taskgroup.")
try:
- await self._init_headers_file()
# note: if a task finishes with CancelledError, that
# will NOT raise, and the group will keep the other tasks running
async with taskgroup as group: