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

small changes

Browse source
This commit is contained in:
Job Evers-Meltzer 2016-12-30 01:40:06 -06:00
parent 227323b7a4
commit 4eb10b56c1
1 changed files with 5 additions and 3 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

8
lbrynet/core/client/ClientProtocol.py
View file

@ -176,11 +176,12 @@ class ClientProtocol(Protocol):
def _handle_response(self, response): def _handle_response(self, response):
ds = [] ds = []
log.debug("Handling a response. Current expected responses: %s", self._response_deferreds) log.debug(
"Handling a response from %s. Expected responses: %s. Actual responses: %s",
self.peer, self._response_deferreds.keys(), response.keys())
for key, val in response.items(): for key, val in response.items():
if key in self._response_deferreds: if key in self._response_deferreds:
d = self._response_deferreds[key] d = self._response_deferreds.pop(key)
del self._response_deferreds[key]
d.callback({key: val}) d.callback({key: val})
ds.append(d) ds.append(d)
for k, d in self._response_deferreds.items(): for k, d in self._response_deferreds.items():
@ -194,6 +195,7 @@ class ClientProtocol(Protocol):
d.addErrback(self._handle_response_error) d.addErrback(self._handle_response_error)
ds.append(d) ds.append(d)
# TODO: are we sure we want to consume errors here
dl = defer.DeferredList(ds, consumeErrors=True) dl = defer.DeferredList(ds, consumeErrors=True)
def get_next_request(results): def get_next_request(results):