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):
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()