X-Git-Url: http://www.chiark.greenend.org.uk/ucgi/~ian/git?a=blobdiff_plain;ds=sidebyside;f=server;h=8a16c34a390d6d195430f5b7f3e06163283b65ff;hb=ca386ea20592402ba35ced4f7f964f06a6263cab;hp=e5aa67b588878fca227564a896f808e2fd5382f6;hpb=6f387df3234541f1066eff163d18fa6becf59c82;p=hippotat.git diff --git a/server b/server index e5aa67b..8a16c34 100755 --- a/server +++ b/server @@ -12,8 +12,6 @@ from twisted.web.server import NOT_DONE_YET import syslog -import traceback - clients = { } #---------- "router" ---------- @@ -100,6 +98,10 @@ class Client(): 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: @@ -123,7 +125,7 @@ class Client(): 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)