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

comment the broadcast interruption case

Browse source
This commit is contained in:
Victor Shyba 2019-12-19 16:20:12 -03:00
parent ada03e12fc
commit 84b8a22423
1 changed files with 1 additions and 0 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

1
torba/torba/server/mempool.py
View file

@ -213,6 +213,7 @@ class MemPool:
synchronized_event.clear() synchronized_event.clear()
await self.api.on_mempool(touched, height) await self.api.on_mempool(touched, height)
try: try:
# we wait up to `refresh_secs` but go early if a broadcast happens (which triggers wakeup event)
await asyncio.wait_for(self.wakeup.wait(), timeout=self.refresh_secs) await asyncio.wait_for(self.wakeup.wait(), timeout=self.refresh_secs)
except asyncio.TimeoutError: except asyncio.TimeoutError:
pass pass