summaryrefslogtreecommitdiff
path: root/docker/utils/socket.py
diff options
context:
space:
mode:
Diffstat (limited to 'docker/utils/socket.py')
-rw-r--r--docker/utils/socket.py9
1 files changed, 8 insertions, 1 deletions
diff --git a/docker/utils/socket.py b/docker/utils/socket.py
index ed34350..164b845 100644
--- a/docker/utils/socket.py
+++ b/docker/utils/socket.py
@@ -5,6 +5,11 @@ import struct
import six
+try:
+ from ..transport import NpipeSocket
+except ImportError:
+ NpipeSocket = type(None)
+
class SocketError(Exception):
pass
@@ -14,10 +19,12 @@ def read(socket, n=4096):
"""
Reads at most n bytes from socket
"""
+
recoverable_errors = (errno.EINTR, errno.EDEADLK, errno.EWOULDBLOCK)
# wait for data to become available
- select.select([socket], [], [])
+ if not isinstance(socket, NpipeSocket):
+ select.select([socket], [], [])
try:
if hasattr(socket, 'recv'):