+ def _asyncfailure(self, reason):
+ self._log(DBG.HTTP_CTRL, '_asyncFailure ' + str(reason))
+ global outstanding
+ outstanding += 1
+ req_err(self._req, reason)
+
+def req_ok(req, resp):
+ log_debug(DBG.HTTP_CTRL, 'req_ok ' + str(resp), idof=req)
+ rc = ResponseConsumer(req)
+ resp.deliverBody(rc)