LBRYCommunity/lbry-sdk
1
0
Fork 1
Code Issues Pull requests Projects Releases 282 Packages Wiki Activity

non blocking mempool loop

Browse source
This commit is contained in:
Jack Robison 2021-07-27 16:12:07 -04:00 committed by Victor Shyba
parent d1560ef09b
commit cd1ce32377
1 changed files with 3 additions and 1 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

4
lbry/wallet/server/session.py
View file

@ -663,7 +663,9 @@ class SessionManager:
for hashX in touched.intersection(self.mempool_statuses.keys()): for hashX in touched.intersection(self.mempool_statuses.keys()):
self.mempool_statuses.pop(hashX, None) self.mempool_statuses.pop(hashX, None)
touched.intersection_update(self.hashx_subscriptions_by_session.keys()) await asyncio.get_event_loop().run_in_executor(
None, touched.intersection_update, self.hashx_subscriptions_by_session.keys()
)
if touched or (height_changed and self.mempool_statuses): if touched or (height_changed and self.mempool_statuses):
notified_hashxs = 0 notified_hashxs = 0