mirror of https://github.com/docker/docker-py.git
Merge pull request #2886 from Aposhian/fix-disable-buffering
fix(transport): remove disable_buffering option
This commit is contained in:
commit
dbb28a5af1
|
@ -23,7 +23,6 @@ class UnixHTTPConnection(httplib.HTTPConnection):
|
||||||
self.base_url = base_url
|
self.base_url = base_url
|
||||||
self.unix_socket = unix_socket
|
self.unix_socket = unix_socket
|
||||||
self.timeout = timeout
|
self.timeout = timeout
|
||||||
self.disable_buffering = False
|
|
||||||
|
|
||||||
def connect(self):
|
def connect(self):
|
||||||
sock = socket.socket(socket.AF_UNIX, socket.SOCK_STREAM)
|
sock = socket.socket(socket.AF_UNIX, socket.SOCK_STREAM)
|
||||||
|
@ -33,13 +32,8 @@ class UnixHTTPConnection(httplib.HTTPConnection):
|
||||||
|
|
||||||
def putheader(self, header, *values):
|
def putheader(self, header, *values):
|
||||||
super().putheader(header, *values)
|
super().putheader(header, *values)
|
||||||
if header == 'Connection' and 'Upgrade' in values:
|
|
||||||
self.disable_buffering = True
|
|
||||||
|
|
||||||
def response_class(self, sock, *args, **kwargs):
|
def response_class(self, sock, *args, **kwargs):
|
||||||
if self.disable_buffering:
|
|
||||||
kwargs['disable_buffering'] = True
|
|
||||||
|
|
||||||
return httplib.HTTPResponse(sock, *args, **kwargs)
|
return httplib.HTTPResponse(sock, *args, **kwargs)
|
||||||
|
|
||||||
|
|
||||||
|
|
Loading…
Reference in New Issue