From 1f64275da14753dd8f1aa0b4b63a04ada5c2c35a Mon Sep 17 00:00:00 2001 From: Victor Shyba Date: Wed, 13 Oct 2021 16:50:13 -0300 Subject: [PATCH] fix ordering --- lbry/wallet/server/session.py | 7 +++---- 1 file changed, 3 insertions(+), 4 deletions(-) diff --git a/lbry/wallet/server/session.py b/lbry/wallet/server/session.py index 15da0b154..c8f71fbac 100644 --- a/lbry/wallet/server/session.py +++ b/lbry/wallet/server/session.py @@ -2,7 +2,6 @@ import os import ssl import math import time -import json import base64 import codecs import typing @@ -567,7 +566,7 @@ class SessionManager: async def serve_requests(self): async def consumer(): while True: - _, fut = await self.priority_queue.get() + _, _, fut = await self.priority_queue.get() try: await fut except asyncio.CancelledError: @@ -896,9 +895,9 @@ class LBRYElectrumX(SessionBase): def schedule_requests(self, requests): for request in requests: current = time.perf_counter() - elapsed = current - self.last_request_received_at + elapsed = (1 << 65) - current - self.last_request_received_at 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, id(request), self._handle_request(request))) @classmethod def protocol_min_max_strings(cls):