mirror of
https://github.com/ansible-collections/community.docker.git
synced 2025-12-16 11:58:43 +00:00
latest docker-py bugfix (npipe) (#513)
* socket: handle npipe close on Windows (https://github.com/docker/docker-py/pull/3056)
Fixes https://github.com/docker/docker-py/issues/3045
Cherry-picked from 30022984f6
Co-authored-by: Nick Santos <nick.santos@docker.com>
* Add changelog fragment.
Co-authored-by: Nick Santos <nick.santos@docker.com>
This commit is contained in:
parent
a239c0b2db
commit
2957138153
2
changelogs/fragments/513-api-npipe.yml
Normal file
2
changelogs/fragments/513-api-npipe.yml
Normal file
@ -0,0 +1,2 @@
|
||||
bugfixes:
|
||||
- "vendored latest Docker SDK for Python bugfix (https://github.com/ansible-collections/community.docker/pull/513, https://github.com/docker/docker-py/issues/3045)."
|
||||
@ -29,6 +29,11 @@ class SocketError(Exception):
|
||||
pass
|
||||
|
||||
|
||||
# NpipeSockets have their own error types
|
||||
# pywintypes.error: (109, 'ReadFile', 'The pipe has been ended.')
|
||||
NPIPE_ENDED = 109
|
||||
|
||||
|
||||
def read(socket, n=4096):
|
||||
"""
|
||||
Reads at most n bytes from socket
|
||||
@ -48,6 +53,15 @@ def read(socket, n=4096):
|
||||
except EnvironmentError as e:
|
||||
if e.errno not in recoverable_errors:
|
||||
raise
|
||||
except Exception as e:
|
||||
is_pipe_ended = (isinstance(socket, NpipeSocket) and
|
||||
len(e.args) > 0 and
|
||||
e.args[0] == NPIPE_ENDED)
|
||||
if is_pipe_ended:
|
||||
# npipes don't support duplex sockets, so we interpret
|
||||
# a PIPE_ENDED error as a close operation (0-length read).
|
||||
return 0
|
||||
raise
|
||||
|
||||
|
||||
def read_exactly(socket, n):
|
||||
|
||||
Loading…
Reference in New Issue
Block a user