+ def connectionLost(self, reason):
+ try:
+ mbody = self._m.decode('utf-8')
+ except Exception:
+ mbody = repr(self._m)
+ if not reason.check(twisted.web.client.ResponseDone):
+ mbody += ' || ' + str(reason)
+ req_err(self._req,
+ "FAILED %d %s | %s"
+ % (self._resp.code, self._phrase, mbody))
+
+def req_ok(req, resp):
+ log_debug(DBG.HTTP_CTRL,
+ 'req_ok %d %s %s' % (resp.code, repr(resp.phrase), str(resp)),
+ idof=req)
+ if resp.code == 200:
+ rc = ResponseConsumer(req)
+ else:
+ rc = ErrorResponseConsumer(req, resp)
+
+ resp.deliverBody(rc)
+ # now rc is responsible for calling req_fin
+
+def req_err(req, err):
+ # called when the Deferred fails, or (if it completes),
+ # later, by ResponsConsumer or ErrorResponsConsumer
+ try:
+ log_debug(DBG.HTTP_CTRL, 'req_err ' + str(err), idof=req)
+ if isinstance(err, twisted.python.failure.Failure):
+ err = err.getTraceback()
+ print('[%#x] %s' % (id(req), err), file=sys.stderr)
+ if not isinstance(outstanding[req], int):
+ raise RuntimeError('[%#x] previously %s' % (id(req), outstanding[req]))
+ outstanding[req] = err
+ log_outstanding()
+ reactor.callLater(c.http_retry, partial(req_fin, req))
+ except Exception as e:
+ crash(traceback.format_exc() + '\n----- handling -----\n' + err)
+
+def req_fin(req):
+ del outstanding[req]
+ log_debug(DBG.HTTP_CTRL, 'req_fin OS=%d' % len(outstanding), idof=req)