chiark
/
gitweb
/
~ian
/
hippotat.git
/ commitdiff
commit
grep
author
committer
pickaxe
?
search:
re
summary
|
shortlog
|
log
|
commit
| commitdiff |
tree
raw
|
patch
|
inline
| side by side (parent:
db6ba58
)
wip
author
Ian Jackson
<ijackson@chiark.greenend.org.uk>
Sat, 1 Apr 2017 22:07:16 +0000
(23:07 +0100)
committer
Ian Jackson
<ijackson@chiark.greenend.org.uk>
Sat, 1 Apr 2017 22:07:16 +0000
(23:07 +0100)
server
patch
|
blob
|
history
diff --git
a/server
b/server
index 7c66edd2892fd52ea6825fbb9d4b7b594a0e2fab..8a16c34a390d6d195430f5b7f3e06163283b65ff 100755
(executable)
--- a/
server
+++ b/
server
@@
-98,6
+98,10
@@
class Client():
self._rq.append(request)
self._check_outbound()
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:
def _check_outbound(self):
log_debug(DBG.HTTP_CTRL, 'CHKO')
while True:
@@
-121,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),
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)
self.max_batch_down)
assert(request.sentLength)