return
try:
self._ssd.flush()
- req_fin(req)
+ req_fin(self._req)
except Exception as e:
self._handleexception()
raise RuntimeError('[%#x] previously %s' % (id(req), outstanding[req]))
outstanding[req] = err
log_outstanding()
- reactor.callLater(c.http_retry, (lambda: req_fin(req)))
+ reactor.callLater(c.http_retry, partial(req_fin, req))
except Exception as e:
crash(traceback.format_exc() + '\n----- handling -----\n' + err)
log_debug(DBG.HTTP_CTRL, 'req_fin OS=%d' % len(outstanding), idof=req)
check_outbound()
+class Errb:
+ def __init__(self, req):
+ self._req = req
+ def call(self, err):
+ req_err(self._req, err)
+
def check_outbound():
global outstanding
outstanding[req] = len(d)
log_debug(DBG.HTTP_CTRL, 'request OS=%d' % len(outstanding), idof=req, d=d)
req.addTimeout(c.http_timeout, reactor)
- req.addCallback((lambda resp: req_ok(req, resp)))
- req.addErrback((lambda err: req_err(req, err)))
+ req.addCallback(partial(req_ok, req))
+ req.addErrback(partial(req_err, req))
log_outstanding()