Madiator2011/lbry-sdk
1
0
Fork 0
forked from LBRYCommunity/lbry-sdk
Code Pull requests Activity

WAL_CHECKPOINT on close

Browse source
This commit is contained in:
Victor Shyba 2020-11-16 10:53:41 -03:00
parent 0ed067cbe5
commit 550458b2f1
1 changed files with 6 additions and 1 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

7
lbry/wallet/database.py
View file

@ -121,7 +121,12 @@ class AIOSQLite:
if self._closing: if self._closing:
return return
self._closing = True self._closing = True
await asyncio.get_event_loop().run_in_executor(self.writer_executor, self.writer_connection.close)
def __checkpoint_and_close(conn: sqlite3.Connection):
conn.execute("PRAGMA WAL_CHECKPOINT(FULL);")
conn.close()
await asyncio.get_event_loop().run_in_executor(
self.writer_executor, __checkpoint_and_close, self.writer_connection)
self.writer_executor.shutdown(wait=True) self.writer_executor.shutdown(wait=True)
self.reader_executor.shutdown(wait=True) self.reader_executor.shutdown(wait=True)
self.read_ready.clear() self.read_ready.clear()