self._pq.append(packet)
self._check_outbound()
+ def _req_fin(self, dummy, request, cl):
+ self._log(DBG.HTTP_CTRL, '_req_fin ' + repr(dummy), idof=request)
+ try: cl.cancel()
+ except twisted.internet.error.AlreadyCalled: pass
+
def new_request(self, request):
request.setHeader('Content-Type','application/octet-stream')
- reactor.callLater(self.http_timeout, self._req_cancel, request)
- request.notifyFinish().addErrback(self._req_error, request)
+ cl = reactor.callLater(self.http_timeout, self._req_cancel, request)
+ nf = request.notifyFinish()
+ nf.addErrback(self._req_error, request)
+ nf.addCallback(self._req_fin, request, cl)
self._rq.append(request)
self._check_outbound()