X-Git-Url: https://git.mxchange.org/?a=blobdiff_plain;ds=sidebyside;f=apt_dht%2FHTTPDownloader.py;h=91ce7c14c598cb70af1cb545547225674754ea32;hb=85d160514bda0e66058f0fb1ac70c8cf52b4435d;hp=cd3352f04b672db963ed27145b64ba79e5dc163a;hpb=13e446aceb6ca774419f63d1028ee7b1bda71b30;p=quix0rs-apt-p2p.git diff --git a/apt_dht/HTTPDownloader.py b/apt_dht/HTTPDownloader.py index cd3352f..91ce7c1 100644 --- a/apt_dht/HTTPDownloader.py +++ b/apt_dht/HTTPDownloader.py @@ -2,6 +2,7 @@ from twisted.internet import reactor, defer, protocol from twisted.internet.protocol import ClientFactory from twisted import version as twisted_version +from twisted.python import log from twisted.web2.client.interfaces import IHTTPClientManager from twisted.web2.client.http import ProtocolError, ClientRequest, HTTPClientProtocol from twisted.web2 import stream as stream_mod, http_headers @@ -75,15 +76,16 @@ class HTTPClientManager(ClientFactory): req = self.request_queue.pop(0) self.response_queue.append(req) req.deferResponse = self.proto.submitRequest(req, False) - req.deferResponse.addCallback(self.requestComplete) - req.deferResponse.addErrback(self.requestError) + req.deferResponse.addCallbacks(self.requestComplete, self.requestError) def requestComplete(self, resp): req = self.response_queue.pop(0) + log.msg('%s of %s completed with code %d' % (req.method, req.uri, resp.code)) req.deferRequest.callback(resp) def requestError(self, error): req = self.response_queue.pop(0) + log.msg('Download of %s generated error %r' % (req.uri, error)) req.deferRequest.errback(error) def clientBusy(self, proto):