CopterExpress/clever-show
1
0
Fork 0
mirror of https://github.com/CopterExpress/clever-show.git synced 2026-06-03 02:29:34 +00:00
Code Issues Packages Projects Releases Wiki Activity

Optimized request behaviour

Browse Source
This commit is contained in:
Artem30801
2019-10-17 16:27:32 +03:00
parent 37a7d32e87
commit 7232bdae36
1 changed files with 11 additions and 12 deletions
Download Patch File Download Diff File Expand all files Collapse all files

23
messaging_lib.py
View File

@@ -356,21 +356,20 @@ class ConnectionManager(object):
def _process_response(self, message):
request_id, requested_value = message.content["request_id"], message.content["requested_value"]
with self._request_lock:
for key, value in self._request_queue.items(): # TODO as try []
if (key == request_id) and (value.requested_value == requested_value):
request = self._request_queue.pop(key)
value = message.content["value"]
logger.debug(
"Request {} successfully closed with value {}".format(request, message.content["value"])
)
request = self._request_queue.pop(request_id, None)
f = request.callback
f(value, *request.callback_args, **request.callback_kwargs)
if (request is not None) and (request.requested_value == requested_value):
value = message.content["value"]
logger.debug(
"Request {} successfully closed with value {}".format(request, message.content["value"])
)
break
else:
logger.warning("Unexpected response!")
f = request.callback
f(value, *request.callback_args, **request.callback_kwargs)
else:
logger.warning("Unexpected response!")
def _process_filetransfer(self, message): # TODO path?
if message.jsonheader["content-type"] == "binary":