X-Git-Url: http://www.chiark.greenend.org.uk/ucgi/~ian/git?p=hippotat.git;a=blobdiff_plain;f=client;h=e4e5eae7a01df3e180be74d170b6404f37a78f6f;hp=16b23f525dc8e492ec66022e681ac7d0fd14ad1d;hb=3393242040c461d71187af33fb0338036784e513;hpb=ccd371b3995c3b9f380fc76938eea0ae54d18a7e;ds=inline diff --git a/client b/client index 16b23f5..e4e5eae 100755 --- a/client +++ b/client @@ -75,11 +75,17 @@ class ResponseConsumer(twisted.internet.protocol.Protocol): self._log(DBG.HTTP_CTRL, 'connectionMade') def connectionLost(self, reason): + self._log(DBG.HTTP_CTRL, 'connectionLost') if isinstance(reason, twisted.internet.error.ConnectionDone): try: self._ssd.flush() except Exception as e: asyncfailure(e) else: - asyncfailure(reason) + self._asyncfailure(reason) + + def _asyncfailure(self, reason): + global outstanding + outstanding += 1 + req_err(reason) def req_ok(req, resp): rc = ResponseConsumer(req)