X-Git-Url: https://git.distorted.org.uk/~mdw/hippotat/blobdiff_plain/4224dc197474ed0a2535cdb100193fffaa697d0e..d41617043a477168c2460e00e6099528219c7163:/hippotat diff --git a/hippotat b/hippotat index 997996d..abe1cae 100755 --- a/hippotat +++ b/hippotat @@ -30,9 +30,10 @@ import twisted.web.client import io class GeneralResponseConsumer(twisted.internet.protocol.Protocol): - def __init__(self, cl, req, desc): + def __init__(self, cl, req, resp, desc): self._cl = cl self._req = req + self._resp = resp self._desc = desc def _log(self, dflag, msg, **kwargs): @@ -43,7 +44,7 @@ class GeneralResponseConsumer(twisted.internet.protocol.Protocol): class ResponseConsumer(GeneralResponseConsumer): def __init__(self, cl, req, resp): - super().__init__(cl, req, 'RC') + super().__init__(cl, req, resp, 'RC') ssddesc = '[%s] %s' % (id(req), self._desc) self._ssd = SlipStreamDecoder(ssddesc, partial(queue_inbound, cl.ipif)) self._log(DBG.HTTP_CTRL, '__init__') @@ -78,8 +79,7 @@ class ResponseConsumer(GeneralResponseConsumer): class ErrorResponseConsumer(GeneralResponseConsumer): def __init__(self, cl, req, resp): - super().__init__(cl, req, 'ERROR-RC') - self._resp = resp + super().__init__(cl, req, resp, 'ERROR-RC') self._m = b'' try: self._phrase = resp.phrase.decode('utf-8')