(stream)
| 21 | buf = stream.read(size) |
| 22 | return struct.unpack(fmt, buf) |
| 23 | def unpack_string(stream): |
| 24 | size, = unpack(stream, ">h") |
| 25 | if size == -1: # null string |
| 26 | return None |
| 27 | res, = unpack(stream, "%ds" % size) |
| 28 | stream.read(1) # \0 |
| 29 | return res |
| 30 | class NotFoundException(Exception): |
| 31 | pass |
| 32 | class AjpBodyRequest(object): |
no test coverage detected