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

initialize new sessions with high priority

Browse source
This commit is contained in:
Victor Shyba 2021-10-13 15:57:15 -03:00 • committed by Jack Robison
parent 17eeafd62c
commit 6ec88e2101
No known key found for this signature in database
GPG key ID: DF25C68FE0239BB2
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

@ -891,13 +891,13 @@ class LBRYElectrumX(SessionBase):
self.daemon = self.session_mgr.daemon self.daemon = self.session_mgr.daemon
self.bp: BlockProcessor = self.session_mgr.bp self.bp: BlockProcessor = self.session_mgr.bp
self.db: LevelDB = self.bp.db 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): def schedule_requests(self, requests):
for request in requests: for request in requests:
current = time.perf_counter() current = time.perf_counter()
elapsed = current - self.time_since_last_request elapsed = current - self.last_request_received_at
self.time_since_last_request = current self.last_request_received_at = current
self.session_mgr.priority_queue.put_nowait((elapsed, self._handle_request(request))) self.session_mgr.priority_queue.put_nowait((elapsed, self._handle_request(request)))
@classmethod @classmethod