Commit 7f8a0e96 authored by Armin Rigo's avatar Armin Rigo
Browse files

Some missing keepalives (I think)

parent 4c64ef74c612
......@@ -878,6 +878,7 @@ class RSocket(object):
self.wait_for_data(False)
raw = rwbuffer.get_raw_address()
read_bytes = _c.socketrecv(self.fd, raw, nbytes, flags)
keepalive_until_here(rwbuffer)
if read_bytes >= 0:
return read_bytes
raise self.error_handler()
......@@ -919,6 +920,7 @@ class RSocket(object):
raw = rwbuffer.get_raw_address()
read_bytes = _c.recvfrom(self.fd, raw, nbytes, flags,
addr_p, addrlen_p)
keepalive_until_here(rwbuffer)
addrlen = rffi.cast(lltype.Signed, addrlen_p[0])
finally:
lltype.free(addrlen_p, flavor='raw')
......
Markdown is supported
0% or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment