From 58f77b2a1c132d321f5ea410b336cdcc665d59db Mon Sep 17 00:00:00 2001
From: Victor Shyba <victor1984@riseup.net>
Date: Sat, 25 Apr 2020 04:24:19 -0300
Subject: [PATCH] load/dump header file using executor

---
 lbry/wallet/header.py | 18 +++++++++++-------
 1 file changed, 11 insertions(+), 7 deletions(-)

diff --git a/lbry/wallet/header.py b/lbry/wallet/header.py
index 6094aa017..c67b0dd1d 100644
--- a/lbry/wallet/header.py
+++ b/lbry/wallet/header.py
@@ -51,10 +51,12 @@ class Headers:
     async def open(self):
         self.io = BytesIO()
         if self.path != ':memory:':
-            if os.path.exists(self.path):
-                with open(self.path, 'r+b') as header_file:
-                    self.io.seek(0)
-                    self.io.write(header_file.read())
+            def _readit():
+                if os.path.exists(self.path):
+                    with open(self.path, 'r+b') as header_file:
+                        self.io.seek(0)
+                        self.io.write(header_file.read())
+            await asyncio.get_event_loop().run_in_executor(None, _readit)
         bytes_size = self.io.seek(0, os.SEEK_END)
         self._size = bytes_size // self.header_size
         max_checkpointed_height = max(self.checkpoints.keys() or [-1]) + 1000
@@ -69,9 +71,11 @@ class Headers:
 
     async def close(self):
         if self.io is not None:
-            flags = 'r+b' if os.path.exists(self.path) else 'w+b'
-            with open(self.path, flags) as header_file:
-                header_file.write(self.io.getbuffer())
+            def _close():
+                flags = 'r+b' if os.path.exists(self.path) else 'w+b'
+                with open(self.path, flags) as header_file:
+                    header_file.write(self.io.getbuffer())
+            await asyncio.get_event_loop().run_in_executor(None, _close)
             self.io.close()
             self.io = None