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

initialize new sessions with high priority

Browse source
This commit is contained in:
Victor Shyba 2021-10-13 15:57:15 -03:00
parent ea5a0f0090
commit 1d80ce2419
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

@ -895,13 +895,13 @@ class LBRYElectrumX(SessionBase):
self.daemon = self.session_mgr.daemon
self.bp: BlockProcessor = self.session_mgr.bp
self.db: LevelDB = self.bp.db
self.time_since_last_request = time.perf_counter()
self.last_request_received_at = 0
def schedule_requests(self, requests):
for request in requests:
current = time.perf_counter()
elapsed = current - self.time_since_last_request
self.time_since_last_request = current
elapsed = current - self.last_request_received_at
self.last_request_received_at = current
self.session_mgr.priority_queue.put_nowait((elapsed, self._handle_request(request)))
@classmethod