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

log mempool task exceptions

Browse source
This commit is contained in:
Victor Shyba 2021-03-02 19:59:15 -03:00
parent 02eb789f84
commit 319187d6d6
1 changed files with 10 additions and 1 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

11
lbry/wallet/server/mempool.py
View file

@ -210,6 +210,15 @@ class MemPool:
return deferred, {prevout: utxo_map[prevout] for prevout in unspent} return deferred, {prevout: utxo_map[prevout] for prevout in unspent}
async def _mempool_loop(self, synchronized_event):
try:
return await self._refresh_hashes(synchronized_event)
except asyncio.CancelledError:
raise
except Exception as e:
self.logger.exception("MEMPOOL DIED")
raise e
async def _refresh_hashes(self, synchronized_event): async def _refresh_hashes(self, synchronized_event):
"""Refresh our view of the daemon's mempool.""" """Refresh our view of the daemon's mempool."""
while True: while True:
@ -326,7 +335,7 @@ class MemPool:
async def keep_synchronized(self, synchronized_event): async def keep_synchronized(self, synchronized_event):
"""Keep the mempool synchronized with the daemon.""" """Keep the mempool synchronized with the daemon."""
await asyncio.wait([ await asyncio.wait([
self._refresh_hashes(synchronized_event), self._mempool_loop(synchronized_event),
# self._refresh_histogram(synchronized_event), # self._refresh_histogram(synchronized_event),
self._logging(synchronized_event) self._logging(synchronized_event)
]) ])