self._rq.append(request)
self._check_outbound()
+ def _req_write(self, req, d):
+ self._log(DBG.HTTP, 'req_write ', idof=req, d=d)
+ req.write(d)
+
def _check_outbound(self):
log_debug(DBG.HTTP_CTRL, 'CHKO')
while True:
self._log(DBG.HTTP_CTRL, 'CHKO processing', idof=request)
# request, and also some non-expired packets
self._pq.process((lambda: request.sentLength),
- request.write,
+ (lambda d: self._req_write(request, d)),
self.max_batch_down)
assert(request.sentLength)