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

fix logging number of notified sessions

Browse source
This commit is contained in:
Jack Robison 2021-09-20 14:42:47 -04:00 committed by Victor Shyba
parent 6e93c5bc0d
commit 7d3eef1fd9
1 changed files with 3 additions and 3 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

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

@ -637,15 +637,15 @@ class SessionManager:
if touched or (height_changed and self.mempool_statuses): if touched or (height_changed and self.mempool_statuses):
notified_hashxs = 0 notified_hashxs = 0
notified_sessions = 0 notified_sessions = set()
to_notify = touched if height_changed else new_touched to_notify = touched if height_changed else new_touched
for hashX in to_notify: for hashX in to_notify:
for session_id in self.hashx_subscriptions_by_session[hashX]: for session_id in self.hashx_subscriptions_by_session[hashX]:
asyncio.create_task(self.sessions[session_id].send_history_notification(hashX)) asyncio.create_task(self.sessions[session_id].send_history_notification(hashX))
notified_sessions += 1 notified_sessions.add(session_id)
notified_hashxs += 1 notified_hashxs += 1
if notified_sessions: if notified_sessions:
self.logger.info(f'notified {notified_sessions} sessions/{notified_hashxs:,d} touched addresses') self.logger.info(f'notified {len(notified_sessions)} sessions/{notified_hashxs:,d} touched addresses')
def add_session(self, session): def add_session(self, session):
self.sessions[id(session)] = session self.sessions[id(session)] = session