Message185345
A multiprocessing queue currently uses a 32-bit signed int to encode object length (in bytes):
def _send_bytes(self, buf):
# For wire compatibility with 3.2 and lower
n = len(buf)
self._send(struct.pack("!i", n))
# The condition is necessary to avoid "broken pipe" errors
# when sending a 0-length buffer if the other end closed the pipe.
if n > 0:
self._send(buf)
I *think* we need to keep compatibility with the wire format, but perhaps we could use a special length value (-1?) to introduce a longer (64-bit) length value. |
|
Date |
User |
Action |
Args |
2013-03-27 16:00:26 | pitrou | set | recipients:
+ pitrou, mrjbq7, sbt |
2013-03-27 16:00:26 | pitrou | set | messageid: <1364400026.8.0.966956442144.issue17560@psf.upfronthosting.co.za> |
2013-03-27 16:00:26 | pitrou | link | issue17560 messages |
2013-03-27 16:00:26 | pitrou | create | |
|