Commit 70d21494 authored by Jason Madden's avatar Jason Madden

Add support for recvmsg_into. Add changelog. Fixes #773.

parent 8d4a7b73
......@@ -329,6 +329,15 @@ class socket(object):
raise
self._wait(self._read_event)
def recvmsg_into(self, *args):
while True:
try:
return _socket.socket.recvmsg_into(self._sock, *args)
except error as ex:
if ex.args[0] != EWOULDBLOCK or self.timeout == 0.0:
raise
self._wait(self._read_event)
def recvfrom(self, *args):
while True:
try:
......
......@@ -365,6 +365,7 @@ if sys.version_info[:2] >= (3, 5):
'test_socket.InterruptedRecvTimeoutTest.testInterruptedSendTimeout',
'test_socket.InterruptedRecvTimeoutTest.testInterruptedSendtoTimeout',
'test_socket.InterruptedRecvTimeoutTest.testInterruptedRecvmsgTimeout',
'test_socket.InterruptedRecvTimeoutTest.testInterruptedRecvmsgIntoTimeout',
'test_socket.InterruptedSendTimeoutTest.testInterruptedSendmsgTimeout',
]
......
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