X-Git-Url: http://www.chiark.greenend.org.uk/ucgi/~ian/git?p=hippotat.git;a=blobdiff_plain;f=client;h=fcdc665224110a3ae1d27a43e6e4814e9b68852c;hp=b5a4db5bf5bb639be691feaa04b65fa100d0ed58;hb=ca386ea20592402ba35ced4f7f964f06a6263cab;hpb=eedc8b30ac92c216d6eef8ff9616bc0cf226a8e6 diff --git a/client b/client index b5a4db5..fcdc665 100755 --- a/client +++ b/client @@ -58,12 +58,10 @@ def outbound(packet, saddr, daddr): queue.append(packet) check_outbound() -def crashy(): assert(False) - class ResponseConsumer(twisted.internet.protocol.Protocol): def __init__(self, req): self._req = req - self._ssd = SlipStreamDecoder(crashy) + self._ssd = SlipStreamDecoder('req %s' % id(req), queue_inbound) self._log(DBG.HTTP_CTRL, '__init__') def _log(self, dflag, msg, **kwargs): @@ -72,7 +70,7 @@ class ResponseConsumer(twisted.internet.protocol.Protocol): def dataReceived(self, data): self._log(DBG.HTTP_CTRL, 'dataReceived', d=data) try: - self._ssd.inputdata(mime_translate(data)) + self._ssd.inputdata(data) except Exception as e: self._handleexception()