LBRYCommunity/hub
1
0
Fork 0
Code Issues 35 Pull requests 6 Projects Releases Packages Wiki Activity

try making sending header notifications faster

Browse source
This commit is contained in:
Jack Robison 2022-04-02 11:44:55 -04:00
parent ba2e2a1dcc
commit a5120d772c
No known key found for this signature in database
GPG key ID: DF25C68FE0239BB2
1 changed files with 12 additions and 7 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

19
scribe/hub/mempool.py
View file

@ -221,13 +221,18 @@ class MemPool:
return return
if height_changed: if height_changed:
header_tasks = [ notified = 0
session.send_notification('blockchain.headers.subscribe', (self.session_manager.hsub_results[session.subscribe_headers_raw], )) for session in self.session_manager.sessions.values():
for session in self.session_manager.sessions.values() if session.subscribe_headers if session.subscribe_headers:
] notified += 1
if header_tasks: asyncio.create_task(
self.logger.info(f'notify {len(header_tasks)} sessions of new header') session.send_notification('blockchain.headers.subscribe',
asyncio.create_task(asyncio.wait(header_tasks)) (self.session_manager.hsub_results[session.subscribe_headers_raw], ))
)
if notified % 10 == 0:
await asyncio.sleep(0) # break up the loop somewhat, there can be many headers notifications
if notified:
self.logger.info(f'queued notify {notified} sessions of new header')
for hashX in touched.intersection(self.session_manager.mempool_statuses.keys()): for hashX in touched.intersection(self.session_manager.mempool_statuses.keys()):
self.session_manager.mempool_statuses.pop(hashX, None) self.session_manager.mempool_statuses.pop(hashX, None)
# self.bp._chain_executor # self.bp._chain_executor